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

https://issues.apache.org/jira/browse/AMQ-3275 - make udp protocol work 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1089864 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2011-04-07 12:59:24 +00:00
parent 47833b7fb1
commit 24ed4fe5ae
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/pom.xml
View File

@ -445,12 +445,6 @@
<exclude>**/RendezvousDiscoverTransportTest.*</exclude>
<exclude>**/MissingDataFileTest.*</exclude>
<!-- UDP related tests someimes fail on some platforms -->
<exclude>**/UdpTransportTest.*</exclude>
<exclude>**/UdpTransportUsingServerTest.*</exclude>
<exclude>**/UdpSendReceiveWithTwoConnectionsTest.*</exclude>
<exclude>**/UdpSendReceiveWithTwoConnectionsAndLargeMessagesTest.*</exclude>
<!-- m2 tests failing since move from assembly -->
<exclude>**/TwoBrokerMessageNotSentToRemoteWhenNoConsumerTest.*</exclude>
<exclude>**/TwoBrokerQueueClientsReconnectTest.*</exclude>

8
activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java
View File

@ -37,6 +37,7 @@ import org.apache.activemq.transport.reliable.ReplayStrategy;
import org.apache.activemq.transport.reliable.Replayer;
import org.apache.activemq.transport.tcp.TcpTransportFactory;
import org.apache.activemq.util.IOExceptionSupport;
import org.apache.activemq.util.IntSequenceGenerator;
import org.apache.activemq.util.IntrospectionSupport;
import org.apache.activemq.util.URISupport;
import org.apache.activemq.wireformat.WireFormat;
@ -60,7 +61,7 @@ public class UdpTransportFactory extends TransportFactory {
WireFormat wf = createWireFormat(options);
int port = location.getPort();
OpenWireFormat openWireFormat = asOpenWireFormat(wf);
UdpTransport transport = (UdpTransport) createTransport(location, wf);
UdpTransport transport = (UdpTransport) createTransport(location.getPort(), wf);
Transport configuredTransport = configure(transport, wf, options, true);
UdpTransportServer server = new UdpTransportServer(location, transport, configuredTransport, createReplayStrategy());
@ -105,6 +106,11 @@ public class UdpTransportFactory extends TransportFactory {
return new UdpTransport(wireFormat, location);
}
protected Transport createTransport(int port, WireFormat wf) throws UnknownHostException, IOException {
OpenWireFormat wireFormat = asOpenWireFormat(wf);
return new UdpTransport(wireFormat, port);
}
/**
* Configures the transport
*

2
activemq-core/src/test/java/org/apache/activemq/transport/udp/UdpSendReceiveWithTwoConnectionsAndLargeMessagesTest.java
View File

@ -24,7 +24,7 @@ public class UdpSendReceiveWithTwoConnectionsAndLargeMessagesTest extends UdpSen
protected void setUp() throws Exception {
largeMessages = true;
//messageCount = 2;
messageCount = 2;
super.setUp();
}