Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-20 17:05:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix test, adjust logging

Browse Source
This commit is contained in:
jbertram 2015-01-26 14:03:54 -06:00
parent 005af9deac
commit dfb7d3c382
3 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core-client/src/main/java/org/apache/activemq/core/client/ActiveMQClientMessageBundle.java
View File

@ -97,8 +97,8 @@ public interface ActiveMQClientMessageBundle
@Message(id = 119013, value = "Timed out waiting to receive cluster topology. Group:{0}", format = Message.Format.MESSAGE_FORMAT)
ActiveMQConnectionTimedOutException connectionTimedOutOnReceiveTopology(DiscoveryGroup discoveryGroup);
@Message(id = 119014, value = "Timed out waiting for response when sending packet {0}", format = Message.Format.MESSAGE_FORMAT)
ActiveMQConnectionTimedOutException timedOutSendingPacket(Byte type);
@Message(id = 119014, value = "Timed out after waiting {0} ms for response when sending packet {1}", format = Message.Format.MESSAGE_FORMAT)
ActiveMQConnectionTimedOutException timedOutSendingPacket(long timeout, Byte type);
@Message(id = 119015, value = "The connection was disconnected because of server shutdown", format = Message.Format.MESSAGE_FORMAT)
ActiveMQDisconnectedException disconnected();

2
activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ChannelImpl.java
View File

@ -403,7 +403,7 @@ public final class ChannelImpl implements Channel
if (response == null)
{
throw ActiveMQClientMessageBundle.BUNDLE.timedOutSendingPacket(packet.getType());
throw ActiveMQClientMessageBundle.BUNDLE.timedOutSendingPacket(connection.getBlockingCallTimeout(), packet.getType());
}
if (response.getType() == PacketImpl.EXCEPTION)

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

@ -54,6 +54,7 @@ import org.apache.activemq.core.server.Queue;
import org.apache.activemq.core.server.cluster.impl.BridgeImpl;
import org.apache.activemq.core.transaction.impl.TransactionImpl;
import org.apache.activemq.spi.core.protocol.RemotingConnection;
import org.apache.activemq.tests.integration.IntegrationTestLogger;
import org.apache.activemq.tests.util.RandomUtil;
import org.apache.activemq.tests.util.ServiceTestBase;
import org.apache.activemq.tests.util.UnitTestCase;
@ -310,13 +311,13 @@ public class BridgeTest extends ServiceTestBase
ignoreSends && packet instanceof SessionSendLargeMessage ||
ignoreSends && packet instanceof SessionSendContinuationMessage && !((SessionSendContinuationMessage) packet).isContinues())
{
System.out.println("Ignored");
IntegrationTestLogger.LOGGER.info("IGNORED: " + packet);
latch.countDown();
return false;
}
else
{
System.out.println(packet);
IntegrationTestLogger.LOGGER.info(packet);
return true;
}
}
@ -359,9 +360,8 @@ public class BridgeTest extends ServiceTestBase
.setReconnectAttemptsOnSameNode(-1)
.setUseDuplicateDetection(false)
.setConfirmationWindowSize(numMessages * messageSize / 2)
.setStaticConnectors(connectorConfig);
bridgeConfiguration.setCallTimeout(500);
.setStaticConnectors(connectorConfig)
.setCallTimeout(5000);
List<BridgeConfiguration> bridgeConfigs = new ArrayList<BridgeConfiguration>();
bridgeConfigs.add(bridgeConfiguration);
@ -423,6 +423,8 @@ public class BridgeTest extends ServiceTestBase
assertTrue("where is the countDown?", myInterceptor.latch.await(30, TimeUnit.SECONDS));
myInterceptor.ignoreSends = false;
server1.getRemotingService().removeIncomingInterceptor(myInterceptor);
IntegrationTestLogger.LOGGER.info("No longer ignoring packets.");
for (int i = 0; i < numMessages; i++)
{