|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjunit.framework.Assert
junit.framework.TestCase
org.apache.qpid.test.utils.QpidTestCase
org.apache.qpid.test.utils.QpidBrokerTestCase
org.apache.qpid.server.persistent.NoLocalAfterRecoveryTest
public class NoLocalAfterRecoveryTest
QPID-1813 : We do not store the client id with a message so on store restart that information is lost and we are unable to perform no local checks. QPID-1813 highlights the lack of testing here as the broker will NPE as it assumes that the client id of the publisher will always exist
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
QpidBrokerTestCase.MessageType |
Field Summary | |
---|---|
protected org.apache.qpid.jms.ConnectionURL |
_connectionURL
|
protected String |
MY_TOPIC_SUBSCRIPTION_NAME
|
protected static int |
SEND_COUNT
|
Fields inherited from class org.apache.qpid.test.utils.QpidBrokerTestCase |
---|
_broker, _brokerLanguage, _brokerLogPrefix, _brokerOutputStream, _brokerPersistent, _brokers, _configFile, _connectionFactory, _connections, _initialContext, _interleaveBrokerLog, _logger, _output, _outputFile, _testName, BROKER_READY, CONTENT, CPP, DEFAULT_MANAGEMENT_PORT, DEFAULT_MESSAGE_SIZE, DEFAULT_PORT, DEFAULT_SSL_PORT, DEFAULT_VM_PORT, EXTERNAL, INDEX, JAVA, LOGMONITOR_TIMEOUT, QPID_HOME, QpidHome, QUEUE, RECEIVE_TIMEOUT, TOPIC, VM |
Fields inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
MEMORY_STORE_CLASS_NAME, MS_CLASS_NAME_KEY |
Constructor Summary | |
---|---|
NoLocalAfterRecoveryTest()
|
Method Summary | |
---|---|
protected List<Message> |
assertReceiveMessage(MessageConsumer messageConsumer,
int count)
|
void |
bytesReceived(long count)
|
void |
bytesSent(long count)
|
void |
failoverComplete()
|
boolean |
preFailover(boolean redirect)
|
boolean |
preResubscribe()
|
protected List<Message> |
receiveMessage(MessageConsumer messageConsumer,
int count)
|
protected void |
setUp()
|
void |
test()
|
Methods inherited from class org.apache.qpid.test.utils.QpidTestCase |
---|
getTestProfileMessageStoreClassName, run |
Methods inherited from class junit.framework.TestCase |
---|
countTestCases, createResult, getName, run, 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, failNotEquals, failNotSame, failSame |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected final String MY_TOPIC_SUBSCRIPTION_NAME
protected static final int SEND_COUNT
protected org.apache.qpid.jms.ConnectionURL _connectionURL
Constructor Detail |
---|
public NoLocalAfterRecoveryTest()
Method Detail |
---|
protected void setUp() throws Exception
setUp
in class QpidBrokerTestCase
Exception
public void test() throws Exception
Exception
protected List<Message> assertReceiveMessage(MessageConsumer messageConsumer, int count) throws JMSException
JMSException
protected List<Message> receiveMessage(MessageConsumer messageConsumer, int count) throws JMSException
JMSException
public void bytesSent(long count)
bytesSent
in interface org.apache.qpid.jms.ConnectionListener
public void bytesReceived(long count)
bytesReceived
in interface org.apache.qpid.jms.ConnectionListener
public boolean preFailover(boolean redirect)
preFailover
in interface org.apache.qpid.jms.ConnectionListener
public boolean preResubscribe()
preResubscribe
in interface org.apache.qpid.jms.ConnectionListener
public void failoverComplete()
failoverComplete
in interface org.apache.qpid.jms.ConnectionListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |