org.apache.activemq.transport.amqp

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 and Description
AmqpWSTransportFactory()

Method Summary

Modifier and Type	Method and 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 transport
TransportServer	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AmqpWSTransportFactory

public AmqpWSTransportFactory()

Method Detail

getDefaultWireFormatType

protected String getDefaultWireFormatType()

Overrides:

getDefaultWireFormatType in class TransportFactory

doBind

public TransportServer doBind(URI location)
                       throws IOException

Specified by:

doBind in class TransportFactory

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 class TransportFactory

Returns:

createTransport

protected Transport createTransport(URI location,
                                    WireFormat wireFormat)
                             throws MalformedURLException,
                                    UnknownHostException,
                                    IOException

Factory method to create a new transport

Overrides:

createTransport in class TransportFactory

Throws:

IOException

UnknownHostException

MalformedURLException

setBrokerService

public void setBrokerService(BrokerService brokerService)

Specified by:

setBrokerService in interface BrokerServiceAware

createInactivityMonitor

protected Transport createInactivityMonitor(AmqpTransportFilter transport,
                                            WireFormat format)