|
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.persistence.TestPersistenceXMLDB
public class TestPersistenceXMLDB
This client tests the persistence driver, the $lt;persistent> flag.
Invoke examples:
java junit.textui.TestRunner org.xmlBlaster.test.persistence.TestPersistenceXMLDB java junit.swingui.TestRunner org.xmlBlaster.test.persistence.TestPersistenceXMLDB
Field Summary | |
---|---|
private Global |
glob
|
private static java.util.logging.Logger |
log
|
private static java.lang.String |
ME
|
private int |
numReceived
|
private java.lang.String |
publishOid
|
private I_XmlBlasterAccess |
senderConnection
|
private java.lang.String |
senderContent
|
private java.lang.String |
senderName
|
private java.lang.String |
senderPasswd
|
private int |
serverPort
|
private EmbeddedXmlBlaster |
serverThread1
|
private EmbeddedXmlBlaster |
serverThread2
|
private EmbeddedXmlBlaster |
st
|
private java.lang.String |
subscribeString
|
Constructor Summary | |
---|---|
TestPersistenceXMLDB(Global glob,
java.lang.String testName)
Constructs the TestPersistenceXMLDB object. |
Method Summary | |
---|---|
protected I_XmlBlasterAccess |
connectClient(java.lang.String name,
java.lang.String passwd)
Connects a client at the server. |
protected void |
disconnectClient(I_XmlBlasterAccess sc)
Disconnects a client from the server. |
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.persistence.TestPersistenceXMLDB |
void |
sendPersistent(I_XmlBlasterAccess sc)
Publish a persistent message. |
protected void |
setUp()
Sets up the fixture. |
protected EmbeddedXmlBlaster |
startServer()
Starts a xmlBlaster serverthread. |
protected void |
stopServer(EmbeddedXmlBlaster st)
Stops a xmlBlaster serverthread. |
protected void |
subscribe(I_XmlBlasterAccess sc)
Subscribes to publishOid at the given connection. |
static junit.framework.Test |
suite()
Method is used by TestRunner to load these tests |
protected void |
tearDown()
|
void |
testPersistent()
TEST: Subscribes to the message with the given key per XPATH. |
java.lang.String |
update(java.lang.String cbSessionId,
UpdateKey updateKey,
byte[] content,
UpdateQos updateQos)
This is the callback method invoked from xmlBlaster delivering us a new asynchronous message. |
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 final java.lang.String ME
private Global glob
private static java.util.logging.Logger log
private final java.lang.String senderName
private final java.lang.String senderPasswd
private java.lang.String publishOid
private java.lang.String subscribeString
private I_XmlBlasterAccess senderConnection
private java.lang.String senderContent
private int numReceived
private EmbeddedXmlBlaster st
private EmbeddedXmlBlaster serverThread1
private EmbeddedXmlBlaster serverThread2
private int serverPort
Constructor Detail |
---|
public TestPersistenceXMLDB(Global glob, java.lang.String testName)
glob
- Keeps global args and parameters.testName
- The name used in the test suite.Method Detail |
---|
protected EmbeddedXmlBlaster startServer()
protected void stopServer(EmbeddedXmlBlaster st)
st
- keeps the server threadprotected I_XmlBlasterAccess connectClient(java.lang.String name, java.lang.String passwd)
name
- The loginname.passwd
- The loginpassword.
protected void disconnectClient(I_XmlBlasterAccess sc)
sc
- A connection of a client to xmlBlaster.protected void setUp()
setUp
in class junit.framework.TestCase
protected void tearDown()
tearDown
in class junit.framework.TestCase
public void sendPersistent(I_XmlBlasterAccess sc)
sc
- A connection of a client to xmlBlaster.protected void subscribe(I_XmlBlasterAccess sc)
sc
- A connection of a client to xmlBlaster.public void testPersistent()
public java.lang.String update(java.lang.String cbSessionId, UpdateKey updateKey, byte[] content, UpdateQos updateQos)
update
in interface I_Callback
cbSessionId
- The session ID specified by the client which registered the callback.
You can specify a cbSessionId during connection (with ConnectQos)
and this is bounced back here so you can authenticate the message.updateKey
- The arrived key containing the topic namecontent
- The arrived message content. This is your payload.I_Callback.update(String, UpdateKey, byte[], UpdateQos)
public static junit.framework.Test suite()
public static void main(java.lang.String[] args)
java -Djava.compiler= junit.textui.TestRunner org.xmlBlaster.test.persistence.TestPersistenceXMLDB
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |