1 18 package org.apache.activemq.transport.stomp; 19 20 import java.util.Map ; 21 22 import org.apache.activemq.transport.Transport; 23 import org.apache.activemq.transport.tcp.TcpTransportFactory; 24 import org.apache.activemq.util.IntrospectionSupport; 25 import org.apache.activemq.wireformat.WireFormat; 26 27 32 public class StompTransportFactory extends TcpTransportFactory { 33 34 protected String getDefaultWireFormatType() { 35 return "stomp"; 36 } 37 38 public Transport compositeConfigure(Transport transport, WireFormat format, Map options) { 39 transport = new StompTransportFilter(transport, new LegacyFrameTranslator()); 40 IntrospectionSupport.setProperties(transport, options); 41 return super.compositeConfigure(transport, format, options); 42 } 43 44 protected boolean isUseInactivityMonitor(Transport transport) { 45 return false; 47 } 48 } 49 | Popular Tags |