1 18 package org.apache.activemq.transport.multicast; 19 20 import java.io.IOException ; 21 import java.net.URI ; 22 import java.net.UnknownHostException ; 23 24 import org.apache.activemq.openwire.OpenWireFormat; 25 import org.apache.activemq.transport.Transport; 26 import org.apache.activemq.transport.udp.UdpTransportFactory; 27 import org.apache.activemq.wireformat.WireFormat; 28 29 34 public class MulticastTransportFactory extends UdpTransportFactory { 35 36 protected Transport createTransport(URI location, WireFormat wf) throws UnknownHostException , IOException { 37 OpenWireFormat wireFormat = asOpenWireFormat(wf); 38 return new MulticastTransport(wireFormat, location); 39 } 40 } 41 | Popular Tags |