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
- Version:
- $Revision: 777806 $
- Author:
- David Martin Clavo david(dot)martin(dot)clavo(at)gmail.com (logging improvement modifications)
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(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, registerTransportFactory, 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(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 © 2005-2011 Apache Software Foundation. All Rights Reserved.