Class AmqpWSTransportFactory
- java.lang.Object
-
- org.apache.activemq.transport.TransportFactory
-
- org.apache.activemq.transport.amqp.AmqpWSTransportFactory
-
- All Implemented Interfaces:
BrokerServiceAware
public class AmqpWSTransportFactory extends TransportFactory implements BrokerServiceAware
Factory for creating WebSocket aware AMQP Transports.
-
-
Constructor Summary
Constructors Constructor Description AmqpWSTransportFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Transport
compositeConfigure(Transport transport, WireFormat format, Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and ResponseCorrelator transport layers so that the resulting transport can more efficiently be used as part of a composite transport.protected Transport
createInactivityMonitor(AmqpTransportFilter transport, WireFormat format)
protected Transport
createTransport(URI location, WireFormat wireFormat)
Factory method to create a new transportTransportServer
doBind(URI location)
protected String
getDefaultWireFormatType()
void
setBrokerService(BrokerService brokerService)
-
Methods inherited from class org.apache.activemq.transport.TransportFactory
bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, findTransportFactory, getOption, registerTransportFactory, serverConfigure
-
-
-
-
Method Detail
-
getDefaultWireFormatType
protected String getDefaultWireFormatType()
- Overrides:
getDefaultWireFormatType
in classTransportFactory
-
doBind
public TransportServer doBind(URI location) throws IOException
- Specified by:
doBind
in classTransportFactory
- Throws:
IOException
-
compositeConfigure
public Transport compositeConfigure(Transport transport, WireFormat format, Map options)
Description copied from class:TransportFactory
Similar to configure(...) but this avoid adding in the MutexTransport and ResponseCorrelator transport layers so that the resulting transport can more efficiently be used as part of a composite transport.- Overrides:
compositeConfigure
in classTransportFactory
- Returns:
-
createTransport
protected Transport createTransport(URI location, WireFormat wireFormat) throws MalformedURLException, UnknownHostException, IOException
Factory method to create a new transport- Overrides:
createTransport
in classTransportFactory
- Throws:
IOException
UnknownHostException
MalformedURLException
-
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interfaceBrokerServiceAware
-
createInactivityMonitor
protected Transport createInactivityMonitor(AmqpTransportFilter transport, WireFormat format)
-
-