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

allow multicast to work via perfer ip4 and more sensible delays

This commit is contained in:
gtully 2015-01-23 13:08:03 +00:00
parent de549f8926
commit f38cb588d3
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
activemq-unit-tests/pom.xml
View File

@ -442,6 +442,7 @@
<exclude>**/SimpleDispatchPolicyTest.java</exclude> <exclude>**/SimpleDispatchPolicyTest.java</exclude>
</excludes> </excludes>
<systemPropertyVariables> <systemPropertyVariables>
<java.net.preferIPv4Stack>true</java.net.preferIPv4Stack>
<org.apache.activemq.default.directory.prefix>target</org.apache.activemq.default.directory.prefix> <org.apache.activemq.default.directory.prefix>target</org.apache.activemq.default.directory.prefix>
<org.apache.activemq.AutoFailTestSupport.disableSystemExit>true</org.apache.activemq.AutoFailTestSupport.disableSystemExit> <org.apache.activemq.AutoFailTestSupport.disableSystemExit>true</org.apache.activemq.AutoFailTestSupport.disableSystemExit>
</systemPropertyVariables> </systemPropertyVariables>

2
activemq-unit-tests/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java
View File

@ -144,7 +144,7 @@ public class DiscoveryTransportBrokerTest extends NetworkTestSupport {
} }
protected StubConnection createFailoverConnection() throws Exception { protected StubConnection createFailoverConnection() throws Exception {
URI failoverURI = new URI("discovery:(" + getDiscoveryUri() + ")?startupMaxReconnectAttempts=5"); URI failoverURI = new URI("discovery:(" + getDiscoveryUri() + ")?startupMaxReconnectAttempts=10&initialReconnectDelay=1000");
Transport transport = TransportFactory.connect(failoverURI); Transport transport = TransportFactory.connect(failoverURI);
StubConnection connection = new StubConnection(transport); StubConnection connection = new StubConnection(transport);
connections.add(connection); connections.add(connection);

2
activemq-unit-tests/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportNoBrokerTest.java
View File

@ -64,7 +64,7 @@ public class DiscoveryTransportNoBrokerTest extends CombinationTestSupport {
final int noConnectionToCreate = 10; final int noConnectionToCreate = 10;
for (int i=0; i<10;i++) { for (int i=0; i<10;i++) {
ActiveMQConnectionFactory factory = ActiveMQConnectionFactory factory =
new ActiveMQConnectionFactory("discovery:(multicast://239.255.2.3:6155?group=" + group +")?closeAsync=false&startupMaxReconnectAttempts=5"); new ActiveMQConnectionFactory("discovery:(multicast://239.255.2.3:6155?group=" + group +")?closeAsync=false&startupMaxReconnectAttempts=10&initialReconnectDelay=1000");
LOG.info("Connecting."); LOG.info("Connecting.");
Connection connection = factory.createConnection(); Connection connection = factory.createConnection();
connection.setClientID("test"); connection.setClientID("test");