Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for NPE in test. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1203662 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2011-11-18 14:23:33 +00:00
parent 8311938134
commit ddb15afe05
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/test/java/org/apache/activemq/bugs/AMQ1853Test.java
View File

@ -335,7 +335,15 @@ public class AMQ1853Test {
bMessageReceiptIsOrdered = previousMessageId.trim().equals(message.getJMSMessageID());
}
AtomicInteger counter = messageList.get(message.getJMSMessageID());
final String jmsMessageId = message.getJMSMessageID();
assertTrue("Did not find expected ", Wait.waitFor(new Wait.Condition() {
@Override
public boolean isSatisified() throws Exception {
return messageList.containsKey(jmsMessageId);
}
}));
AtomicInteger counter = messageList.get(jmsMessageId);
counter.incrementAndGet();
LOG.info("Consumer for destination (" + destinationName + ")\n" + message.getJMSMessageID() + " = currentMessageId\n"
@ -351,7 +359,7 @@ public class AMQ1853Test {
session.rollback(); // rolls back all the consumed messages on the session to
}
} catch (JMSException ex) {
} catch (Exception ex) {
ex.printStackTrace();
LOG.error("Error reading JMS Message from destination " + destinationName + ".");
}