xmlBlaster 2.2.0 API

org.xmlBlaster.test.qos
Class TestPtDQueueRedeliver

java.lang.Object
  extended by junit.framework.Assert
      extended by junit.framework.TestCase
          extended by org.xmlBlaster.test.qos.TestPtDQueueRedeliver
All Implemented Interfaces:
junit.framework.Test

public class TestPtDQueueRedeliver
extends junit.framework.TestCase

This client does test if a subscriber can reconnect to its session and its callback queue holded the messages during downtime.

See method testPersistentPtp() for a description.

This client may be invoked multiple time on the same xmlBlaster server, as it cleans up everything after his tests are done.

Invoke examples:

    java junit.textui.TestRunner org.xmlBlaster.test.qos.TestPtDQueueRedeliver
    java junit.swingui.TestRunner -noloading org.xmlBlaster.test.qos.TestPtDQueueRedeliver
 


Field Summary
private  boolean connectedRcv
           
private  I_XmlBlasterAccess conRcv
           
private  I_XmlBlasterAccess conSnd
           
private  Global glob
           
private static java.util.logging.Logger log
           
private static java.lang.String ME
           
private  java.lang.String oid
           
private  java.lang.String passwd
           
private  int serverPort
           
private  EmbeddedXmlBlaster serverThread
           
private  java.lang.String sessionNameRcv
           
private  java.lang.String sessionNameSnd
           
private  MsgInterceptor updateInterceptorRcv
           
private  MsgInterceptor updateInterceptorSnd
           
 
Constructor Summary
TestPtDQueueRedeliver()
          For Junit
TestPtDQueueRedeliver(Global glob, java.lang.String testName)
          Constructs the TestPtDQueueRedeliver object.
 
Method Summary
static void main(java.lang.String[] args)
          Invoke:
protected  void setUp()
          Sets up the fixture.
static junit.framework.Test suite()
          Method is used by TestRunner to load these tests
protected  void tearDown()
          Cleaning up.
 void testPersistentPtp()
           1.
 
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 final Global glob

log

private static java.util.logging.Logger log

passwd

private java.lang.String passwd

serverPort

private int serverPort

oid

private java.lang.String oid

serverThread

private EmbeddedXmlBlaster serverThread

sessionNameRcv

private java.lang.String sessionNameRcv

conRcv

private I_XmlBlasterAccess conRcv

connectedRcv

private boolean connectedRcv

updateInterceptorRcv

private MsgInterceptor updateInterceptorRcv

sessionNameSnd

private java.lang.String sessionNameSnd

conSnd

private I_XmlBlasterAccess conSnd

updateInterceptorSnd

private MsgInterceptor updateInterceptorSnd
Constructor Detail

TestPtDQueueRedeliver

public TestPtDQueueRedeliver()
For Junit


TestPtDQueueRedeliver

public TestPtDQueueRedeliver(Global glob,
                             java.lang.String testName)
Constructs the TestPtDQueueRedeliver object.

Parameters:
testName - The name used in the test suite and to login to xmlBlaster
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()
Cleaning up.

Overrides:
tearDown in class junit.framework.TestCase

testPersistentPtp

public void testPersistentPtp()

1. xmlBlaster starts and sender sends persistent and forceQueuing PtP message.

2. xmlBlaster stops and starts again

3. receiver start and should receive the message


suite

public static junit.framework.Test suite()
Method is used by TestRunner to load these tests


main

public static void main(java.lang.String[] args)
Invoke:
   java org.xmlBlaster.test.qos.TestPtDQueueRedeliver
   java -Djava.compiler= junit.textui.TestRunner org.xmlBlaster.test.qos.TestPtDQueueRedeliver
 


xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.