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

This closes #202

This commit is contained in:
Clebert Suconic 2015-10-20 13:03:17 -04:00
parent efce1d7a71 3e6f229436
commit 9608c3165b
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionFactoryImpl.java
View File

@ -375,9 +375,11 @@ public class ClientSessionFactoryImpl implements ClientSessionFactoryInternal, C
public void connectionReadyForWrites(final Object connectionID, final boolean ready) {
synchronized (connectionReadyLock) {
connectionReadyForWrites = ready;
for (ConnectionLifeCycleListener lifeCycleListener : lifeCycleListeners) {
lifeCycleListener.connectionReadyForWrites(connectionID, ready);
if (connectionReadyForWrites != ready) {
connectionReadyForWrites = ready;
for (ConnectionLifeCycleListener lifeCycleListener : lifeCycleListeners) {
lifeCycleListener.connectionReadyForWrites(connectionID, ready);
}
}
}
}

8
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/bridge/BridgeTest.java
View File

@ -152,7 +152,6 @@ public class BridgeTest extends ActiveMQTestBase {
final String forwardAddress = "forwardAddress";
final String queueName1 = "queue1";
// Map<String, TransportConfiguration> connectors = new HashMap<String, TransportConfiguration>();
TransportConfiguration server0tc = new TransportConfiguration(getConnector(), server0Params);
TransportConfiguration server1tc = new TransportConfiguration(getConnector(), server1Params);
@ -161,10 +160,9 @@ public class BridgeTest extends ActiveMQTestBase {
connectors.put(server1tc.getName(), server1tc);
server0.getConfiguration().setConnectorConfigurations(connectors);
// final int messageSize = 1024 * 1024 * 5;
final int messageSize = 1024 * 10;
final int messageSize = 1024 * 1024 * 5;
final int numMessages = 100000;
final int numMessages = 10;
ArrayList<String> connectorConfig = new ArrayList<String>();
connectorConfig.add(server1tc.getName());
@ -270,7 +268,7 @@ public class BridgeTest extends ActiveMQTestBase {
final int messageSize = 1024;
final int numMessages = 10000;
final int numMessages = 10;
ArrayList<String> connectorConfig = new ArrayList<String>();
connectorConfig.add(server1tc.getName());