mirror of https://github.com/apache/activemq.git
https://issues.apache.org/jira/browse/AMQ-2484,https://issues.apache.org/jira/browse/AMQ-2324: Forwarded message cannot be distributed to the original broker, Avoid stuck messages in a network of brokers - apply the new policy to two test cases
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1142605 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
d226f5089f
commit
c8be8aa387
|
@ -67,6 +67,9 @@ public class TwoBrokerQueueClientsReconnectTest extends JmsMultipleBrokersTestSu
|
|||
}
|
||||
|
||||
public void doOneClientReceivesOnly() throws Exception {
|
||||
// allow immediate replay back to origin
|
||||
applyRateLimitNetworkFilter(0);
|
||||
|
||||
// Bridge brokers
|
||||
bridgeBrokers(broker1, broker2);
|
||||
bridgeBrokers(broker2, broker1);
|
||||
|
@ -113,6 +116,9 @@ public class TwoBrokerQueueClientsReconnectTest extends JmsMultipleBrokersTestSu
|
|||
}
|
||||
|
||||
public void doOneClientReceivesOnlyAfterReconnect() throws Exception {
|
||||
// allow immediate replay back to origin
|
||||
applyRateLimitNetworkFilter(0);
|
||||
|
||||
// Bridge brokers
|
||||
bridgeBrokers(broker1, broker2);
|
||||
bridgeBrokers(broker2, broker1);
|
||||
|
|
Loading…
Reference in New Issue