org.apache.activemq.transport.udp

Class UdpTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.udp.UdpTransportFactory

Direct Known Subclasses:

MulticastTransportFactory

public class UdpTransportFactory
extends TransportFactory

Author:

David Martin Clavo david(dot)martin(dot)clavo(at)gmail.com (logging improvement modifications)

Constructor Summary

Constructors

Constructor and Description
UdpTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
protected OpenWireFormat	asOpenWireFormat(WireFormat wf)
Transport	compositeConfigure(Transport transport, WireFormat format, java.util.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.
Transport	configure(Transport transport, WireFormat format, java.util.Map options) Fully configures and adds all need transport filters so that the transport can be used by the JMS client.
protected Transport	configure(Transport transport, WireFormat format, java.util.Map options, boolean acceptServer) Configures the transport
protected Transport	configureClientSideNegotiator(Transport transport, WireFormat format, UdpTransport udpTransport)
protected ReplayStrategy	createReplayStrategy()
protected ReplayStrategy	createReplayStrategy(Replayer replayer)
protected Transport	createTransport(int port, WireFormat wf)
protected Transport	createTransport(java.net.URI location, WireFormat wf) Factory method to create a new transport
TransportServer	doBind(java.net.URI location)

Methods inherited from class org.apache.activemq.transport.TransportFactory

bind, bind, bind, compositeConnect, compositeConnect, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, getDefaultWireFormatType, getOption, registerTransportFactory, serverConfigure

Methods inherited from class java.lang.Object

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

Constructor Detail

UdpTransportFactory

public UdpTransportFactory()

Method Detail

doBind

public TransportServer doBind(java.net.URI location)
                       throws java.io.IOException

Specified by:

doBind in class TransportFactory

Throws:

java.io.IOException

configure

public Transport configure(Transport transport,
                  WireFormat format,
                  java.util.Map options)
                    throws java.lang.Exception

Description copied from class: TransportFactory

Fully configures and adds all need transport filters so that the transport can be used by the JMS client.

Overrides:

configure in class TransportFactory

Returns:

Throws:

java.lang.Exception

compositeConfigure

public Transport compositeConfigure(Transport transport,
                           WireFormat format,
                           java.util.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(java.net.URI location,
                        WireFormat wf)
                             throws java.net.UnknownHostException,
                                    java.io.IOException

Description copied from class: TransportFactory

Factory method to create a new transport

Overrides:

createTransport in class TransportFactory

Throws:

java.net.UnknownHostException

java.io.IOException

createTransport

protected Transport createTransport(int port,
                        WireFormat wf)
                             throws java.net.UnknownHostException,
                                    java.io.IOException

Throws:

java.net.UnknownHostException

java.io.IOException

configure

protected Transport configure(Transport transport,
                  WireFormat format,
                  java.util.Map options,
                  boolean acceptServer)
                       throws java.lang.Exception

Configures the transport

Parameters:

acceptServer - true if this transport is used purely as an 'accept' transport for new connections which work like TCP SocketServers where new connections spin up a new separate UDP transport

Throws:

java.lang.Exception

createReplayStrategy

protected ReplayStrategy createReplayStrategy(Replayer replayer)

createReplayStrategy

protected ReplayStrategy createReplayStrategy()

configureClientSideNegotiator

protected Transport configureClientSideNegotiator(Transport transport,
                                      WireFormat format,
                                      UdpTransport udpTransport)

asOpenWireFormat

protected OpenWireFormat asOpenWireFormat(WireFormat wf)