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
Method Summary |
protected OpenWireFormat |
asOpenWireFormat(WireFormat wf)
|
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. |
Transport |
configure(Transport transport,
WireFormat format,
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,
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(URI location,
WireFormat wf)
Factory method to create a new transport |
TransportServer |
doBind(String brokerId,
URI location)
|
Methods inherited from class org.apache.activemq.transport.TransportFactory |
bind, compositeConnect, compositeConnect, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, getDefaultWireFormatType, serverConfigure |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
UdpTransportFactory
public UdpTransportFactory()
doBind
public TransportServer doBind(String brokerId,
URI location)
throws IOException
- Specified by:
doBind
in class TransportFactory
- Throws:
IOException
configure
public Transport configure(Transport transport,
WireFormat format,
Map options)
throws 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:
Exception
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 wf)
throws UnknownHostException,
IOException
- Description copied from class:
TransportFactory
- Factory method to create a new transport
- Overrides:
createTransport
in class TransportFactory
- Throws:
UnknownHostException
IOException
configure
protected Transport configure(Transport transport,
WireFormat format,
Map options,
boolean acceptServer)
throws 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:
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)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.