|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object junit.framework.Assert junit.framework.TestCase org.xmlBlaster.test.client.TestFailSafePing
public class TestFailSafePing
Tests the fail save behavior of the I_XmlBlasterAccess client helper class,
especially the pinging to xmlBlaster. This allows auto detection if the
connection to xmlBlaster is lost.
For a description of what this fail save mode can do for you, please
read the API documentation of I_XmlBlasterAccess.
This is an interesting example, since it creates a XmlBlaster server instance in the same JVM , but in a separate thread, talking over CORBA with it.
Invoke examples:
java junit.textui.TestRunner org.xmlBlaster.test.client.TestFailSafePing java junit.swingui.TestRunner -noloading org.xmlBlaster.test.client.TestFailSafePing
Field Summary | |
---|---|
private I_XmlBlasterAccess |
con
|
private java.lang.String |
contentMime
|
private int |
counter
|
private Global |
glob
|
private static java.util.logging.Logger |
log
|
private static java.lang.String |
ME
|
private MsgUnit[] |
msgUnitArr
|
private java.lang.String |
senderName
|
private int |
serverPort
|
private EmbeddedXmlBlaster |
serverThread
|
private MsgInterceptor |
updateInterceptor
|
Constructor Summary | |
---|---|
TestFailSafePing(Global glob,
java.lang.String testName)
Constructs the TestFailSafePing object. |
|
TestFailSafePing(java.lang.String testName)
|
Method Summary | |
---|---|
void |
doPublish()
TEST: Construct a message and publish it. |
void |
doSubscribe()
TEST: Subscribe to messages with XPATH. |
static void |
main(java.lang.String[] args)
Deprecated. Use the TestRunner from the testsuite to run it: java -Djava.compiler= junit.textui.TestRunner org.xmlBlaster.test.client.TestFailSafePing |
void |
reachedAlive(ConnectionStateEnum oldState,
I_XmlBlasterAccess connection)
This is the callback method invoked from I_XmlBlasterAccess informing the client in an asynchronous mode if the connection was established. |
void |
reachedAliveSync(ConnectionStateEnum oldState,
I_XmlBlasterAccess connection)
Invoked when the dispatcher goes to synch again after having delivered entries which where in the queue when the state changed to ALIVE. |
void |
reachedDead(ConnectionStateEnum oldState,
I_XmlBlasterAccess connection)
This is the callback method invoked from XmlBlasterAccess informing the client that the connection was lost (i.e. |
void |
reachedPolling(ConnectionStateEnum oldState,
I_XmlBlasterAccess connection)
This is the callback method invoked from XmlBlasterAccess informing the client that the connection state has changed to POLLING. |
protected void |
setUp()
Sets up the fixture. |
static junit.framework.Test |
suite()
Method is used by TestRunner to load these tests |
protected void |
tearDown()
Tears down the fixture. |
void |
testFailSafe()
TEST: |
Methods inherited from class junit.framework.TestCase |
---|
countTestCases, createResult, getName, run, run, runBare, runTest, setName, toString |
Methods inherited from class junit.framework.Assert |
---|
assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
private static java.lang.String ME
private Global glob
private static java.util.logging.Logger log
private int serverPort
private EmbeddedXmlBlaster serverThread
private MsgInterceptor updateInterceptor
private I_XmlBlasterAccess con
private java.lang.String senderName
private MsgUnit[] msgUnitArr
private int counter
private final java.lang.String contentMime
Constructor Detail |
---|
public TestFailSafePing(java.lang.String testName)
public TestFailSafePing(Global glob, java.lang.String testName)
testName
- The name used in the test suiteMethod Detail |
---|
protected void setUp()
setUp
in class junit.framework.TestCase
protected void tearDown()
tearDown
in class junit.framework.TestCase
public void doSubscribe()
public void doPublish() throws XmlBlasterException
XmlBlasterException
public void testFailSafe()
public void reachedAlive(ConnectionStateEnum oldState, I_XmlBlasterAccess connection)
reachedAlive
in interface I_ConnectionStateListener
oldState
- The previous state of the connection.public void reachedAliveSync(ConnectionStateEnum oldState, I_XmlBlasterAccess connection)
I_ConnectionStateListener
reachedAliveSync
in interface I_ConnectionStateListener
oldState
- is always ALIVE.public void reachedPolling(ConnectionStateEnum oldState, I_XmlBlasterAccess connection)
I_ConnectionStateListener
reachedPolling
in interface I_ConnectionStateListener
oldState
- The previous state of the connection.public void reachedDead(ConnectionStateEnum oldState, I_XmlBlasterAccess connection)
I_ConnectionStateListener
reachedDead
in interface I_ConnectionStateListener
oldState
- The previous state of the connection.public static junit.framework.Test suite()
public static void main(java.lang.String[] args)
java -Djava.compiler= junit.textui.TestRunner org.xmlBlaster.test.client.TestFailSafePing
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |