From a77e964b92c15e242d7556366174b23b2cfe5cef Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Sat, 23 May 2009 06:32:35 +0000 Subject: [PATCH] Fix for https://issues.apache.org/activemq/browse/AMQ-2134 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@777806 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/transport/udp/UdpTransportFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java index 23518cce97..86bec7baf8 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java @@ -60,7 +60,7 @@ public class UdpTransportFactory extends TransportFactory { WireFormat wf = createWireFormat(options); int port = location.getPort(); OpenWireFormat openWireFormat = asOpenWireFormat(wf); - UdpTransport transport = new UdpTransport(openWireFormat, port); + UdpTransport transport = (UdpTransport) createTransport(location, wf); Transport configuredTransport = configure(transport, wf, options, true); UdpTransportServer server = new UdpTransportServer(location, transport, configuredTransport, createReplayStrategy());