NO-JIRA Adding a test playing with network disconnects and failover

apache · Sep 5, 2018 · 05ce7c6 · 05ce7c6
1 parent 0d9f5eb
commit 05ce7c6
Show file tree

Hide file tree

Showing 4 changed files with 946 additions and 2 deletions.
diff --git a/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java b/artemis-server/src/test/java/org/apache/activemq/artemis/tests/util/ActiveMQTestBase.java
@@ -1219,7 +1219,7 @@ protected static final Map<String, Object> generateParams(final int node, final
       return params;
    }
 
-   protected static final TransportConfiguration getNettyAcceptorTransportConfiguration(final boolean live) {
+   protected TransportConfiguration getNettyAcceptorTransportConfiguration(final boolean live) {
       if (live) {
          return new TransportConfiguration(NETTY_ACCEPTOR_FACTORY);
       }
@@ -1231,14 +1231,15 @@ protected static final TransportConfiguration getNettyAcceptorTransportConfigura
       return new TransportConfiguration(NETTY_ACCEPTOR_FACTORY, server1Params);
    }
 
-   protected static final TransportConfiguration getNettyConnectorTransportConfiguration(final boolean live) {
+   protected TransportConfiguration getNettyConnectorTransportConfiguration(final boolean live) {
       if (live) {
          return new TransportConfiguration(NETTY_CONNECTOR_FACTORY);
       }
 
       Map<String, Object> server1Params = new HashMap<>();
 
       server1Params.put(org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants.PORT_PROP_NAME, org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants.DEFAULT_PORT + 1);
+      server1Params.put(org.apache.activemq.artemis.core.remoting.impl.netty.TransportConstants.NETTY_CONNECT_TIMEOUT, 1000);
       return new TransportConfiguration(NETTY_CONNECTOR_FACTORY, server1Params);
    }