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

give test some more time

This commit is contained in:
Dejan Bosanac 2014-12-19 16:13:01 +01:00
parent b969358445
commit 9927824c27
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-unit-tests/src/test/java/org/apache/activemq/usecases/AbstractTwoBrokerNetworkConnectorWildcardIncludedDestinationTestSupport.java
View File

@ -87,14 +87,14 @@ public abstract class AbstractTwoBrokerNetworkConnectorWildcardIncludedDestinati
public void sendReceive(String broker1, String dest1, boolean topic1, String broker2, String dest2, boolean topic2, int send, int expected) throws Exception{
MessageConsumer client = createConsumer(broker2, createDestination(dest2, topic2));
Thread.sleep(1000);
Thread.sleep(2000);
sendMessages(broker1, createDestination(dest1, topic1), send);
MessageIdList msgs = getConsumerMessages(broker2, client);
msgs.setMaximumDuration(1000);
msgs.setMaximumDuration(10000);
msgs.waitForMessagesToArrive(send);
assertEquals(expected, msgs.getMessageCount());
client.close();
Thread.sleep(500);
Thread.sleep(1000);
}
protected abstract void addIncludedDestination(NetworkConnector networkConnector);