org.xmlBlaster.test.client
Class TestXmlBlasterAccessMultiThreaded

java.lang.Object
  junit.framework.Assert
      junit.framework.TestCase
          org.xmlBlaster.test.client.TestXmlBlasterAccessMultiThreaded

All Implemented Interfaces:

junit.framework.Test, I_ConnectionStateListener

public class TestXmlBlasterAccessMultiThreaded
extends junit.framework.TestCase
implements I_ConnectionStateListener

Tests the thread safety of the I_XmlBlasterAccess client helper class

Invoke examples:

   java junit.textui.TestRunner -noloading org.xmlBlaster.test.client.TestXmlBlasterAccessMultiThreaded
   java junit.swingui.TestRunner -noloading org.xmlBlaster.test.client.TestXmlBlasterAccessMultiThreaded
 

See Also:

I_XmlBlasterAccess

Nested Class Summary

(package private) class

TestXmlBlasterAccessMultiThreaded.PublishThread Helper class for publisher threads

Field Summary

private I_XmlBlasterAccess	con
private java.lang.String	contentMime
private Global	glob
private int	iThread
private static java.util.logging.Logger	log
private static java.lang.String	ME
private int	numPublish
private int	numStart
private int	numStop
private long	reconnectDelay
private java.lang.String	senderName
private int	serverPort
private EmbeddedXmlBlaster	serverThread
private MsgInterceptor	updateInterceptor

Constructor Summary

TestXmlBlasterAccessMultiThreaded(Global glob, java.lang.String testName)

TestXmlBlasterAccessMultiThreaded(java.lang.String testName)

Method Summary

MsgUnit	doPublish(java.lang.String oid, java.lang.String content) 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.TestXmlBlasterAccessMultiThreaded
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.
protected void	tearDown() Tears down the fixture.
void	testPublishThreads() 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

ME

private static java.lang.String ME

glob

private Global glob

log

private static java.util.logging.Logger log

serverPort

private int serverPort

serverThread

private EmbeddedXmlBlaster serverThread

updateInterceptor

private MsgInterceptor updateInterceptor

con

private I_XmlBlasterAccess con

senderName

private java.lang.String senderName

numPublish

private int numPublish

numStop

private int numStop

numStart

private int numStart

iThread

private int iThread

contentMime

private final java.lang.String contentMime

See Also:

Constant Field Values

reconnectDelay

private final long reconnectDelay

See Also:

Constant Field Values

Constructor Detail

TestXmlBlasterAccessMultiThreaded

public TestXmlBlasterAccessMultiThreaded(java.lang.String testName)

TestXmlBlasterAccessMultiThreaded

public TestXmlBlasterAccessMultiThreaded(Global glob,
                                         java.lang.String testName)

Method Detail

setUp

protected void setUp()

Sets up the fixture.

Connect to xmlBlaster and login

Overrides:

setUp in class junit.framework.TestCase

tearDown

protected void tearDown()

Tears down the fixture.

cleaning up .... erase() the previous message OID and logout

Overrides:

tearDown in class junit.framework.TestCase

doSubscribe

public void doSubscribe()

TEST: Subscribe to messages with XPATH.

doPublish

public MsgUnit doPublish(java.lang.String oid,
                         java.lang.String content)
                  throws XmlBlasterException

TEST: Construct a message and publish it.

Throws:

XmlBlasterException

testPublishThreads

public void testPublishThreads()

TEST:

reachedAlive

public 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.

This method is enforced through interface I_ConnectionStateListener

Specified by:

reachedAlive in interface I_ConnectionStateListener

Parameters:

oldState - The previous state of the connection.

reachedAliveSync

public void reachedAliveSync(ConnectionStateEnum oldState,
                             I_XmlBlasterAccess connection)

Description copied from interface: I_ConnectionStateListener

Invoked when the dispatcher goes to synch again after having delivered entries which where in the queue when the state changed to ALIVE. Note that this could take some time or in the worst case it could never been invoked if the queue is never completely processed.

Specified by:

reachedAliveSync in interface I_ConnectionStateListener

Parameters:

oldState - is always ALIVE.

reachedPolling

public void reachedPolling(ConnectionStateEnum oldState,
                           I_XmlBlasterAccess connection)

Description copied from interface: I_ConnectionStateListener

This is the callback method invoked from XmlBlasterAccess informing the client that the connection state has changed to POLLING.

Specified by:

reachedPolling in interface I_ConnectionStateListener

Parameters:

oldState - The previous state of the connection.

reachedDead

public void reachedDead(ConnectionStateEnum oldState,
                        I_XmlBlasterAccess connection)

Description copied from interface: I_ConnectionStateListener

This is the callback method invoked from XmlBlasterAccess informing the client that the connection was lost (i.e. when the state of the connection has gone to DEAD).

Specified by:

reachedDead in interface I_ConnectionStateListener

Parameters:

oldState - The previous state of the connection.

main

public 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.TestXmlBlasterAccessMultiThreaded

Invoke: java org.xmlBlaster.test.client.TestXmlBlasterAccessMultiThreaded