activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r386583 - /incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/multicast/MulticastTransportTest.java
Date Fri, 17 Mar 2006 09:13:32 GMT
Author: jstrachan
Date: Fri Mar 17 01:13:31 2006
New Revision: 386583

URL: http://svn.apache.org/viewcvs?rev=386583&view=rev
Log:
enforce loop back mode false

Modified:
    incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/multicast/MulticastTransportTest.java

Modified: incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/multicast/MulticastTransportTest.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/multicast/MulticastTransportTest.java?rev=386583&r1=386582&r2=386583&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/multicast/MulticastTransportTest.java
(original)
+++ incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/multicast/MulticastTransportTest.java
Fri Mar 17 01:13:31 2006
@@ -19,7 +19,6 @@
 import org.apache.activemq.openwire.OpenWireFormat;
 import org.apache.activemq.transport.CommandJoiner;
 import org.apache.activemq.transport.Transport;
-import org.apache.activemq.transport.udp.UdpTransport;
 import org.apache.activemq.transport.udp.UdpTransportTest;
 import org.apache.activemq.util.IntSequenceGenerator;
 
@@ -43,6 +42,7 @@
         
         OpenWireFormat wireFormat = createWireFormat();
         MulticastTransport transport = new MulticastTransport(wireFormat, new URI(multicastURI));
+        transport.setLoopBackMode(false);
         transport.setSequenceGenerator(new IntSequenceGenerator());
         return new CommandJoiner(transport, wireFormat);
     }
@@ -50,6 +50,7 @@
     protected Transport createConsumer() throws Exception {
         OpenWireFormat wireFormat = createWireFormat();
         MulticastTransport transport = new MulticastTransport(wireFormat, new URI(multicastURI));
+        transport.setLoopBackMode(false);
         transport.setSequenceGenerator(new IntSequenceGenerator());
         return new CommandJoiner(transport, wireFormat);
     }



Mime
View raw message