org.apache.activemq.transport.multicast
Class MulticastTransport
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.transport.TransportSupport
org.apache.activemq.transport.TransportThreadSupport
org.apache.activemq.transport.udp.UdpTransport
org.apache.activemq.transport.multicast.MulticastTransport
- All Implemented Interfaces:
- Runnable, Service, Transport
public class MulticastTransport
- extends UdpTransport
A multicast based transport.
- Version:
- $Revision: 564814 $
Methods inherited from class org.apache.activemq.transport.udp.UdpTransport |
connect, createCommandDatagramChannel, createLocalAddress, createReplayer, doStart, getBufferPool, getChannel, getCommandChannel, getDatagramSize, getLocalSocketAddress, getMinmumWireFormatVersion, getPort, getReceiveCounter, getRemoteAddress, getReplayBuffer, getReplayStrategy, getSequenceGenerator, getTargetAddress, getWireFormat, isReplayEnabled, isTrace, isUseLocalHost, oneway, oneway, resolveHostName, run, setBufferPool, setChannel, setCommandChannel, setDatagramSize, setMinmumWireFormatVersion, setPort, setReplayBuffer, setReplayEnabled, setReplayStrategy, setSequenceGenerator, setTargetEndpoint, setTrace, setUseLocalHost, toString |
Methods inherited from class org.apache.activemq.transport.TransportSupport |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, onException, reconnect, request, request, setTransportListener |
MulticastTransport
public MulticastTransport(OpenWireFormat wireFormat,
URI remoteLocation)
throws UnknownHostException,
IOException
- Throws:
UnknownHostException
IOException
getKeepAliveInterval
public long getKeepAliveInterval()
setKeepAliveInterval
public void setKeepAliveInterval(long keepAliveInterval)
isLoopBackMode
public boolean isLoopBackMode()
setLoopBackMode
public void setLoopBackMode(boolean loopBackMode)
getTimeToLive
public int getTimeToLive()
setTimeToLive
public void setTimeToLive(int timeToLive)
getProtocolName
protected String getProtocolName()
- Overrides:
getProtocolName
in class UdpTransport
getProtocolUriScheme
protected String getProtocolUriScheme()
- Overrides:
getProtocolUriScheme
in class UdpTransport
bind
protected void bind(DatagramSocket socket,
SocketAddress localAddress)
throws SocketException
- Overrides:
bind
in class UdpTransport
- Throws:
SocketException
doStop
protected void doStop(ServiceStopper stopper)
throws Exception
- Overrides:
doStop
in class UdpTransport
- Throws:
Exception
createCommandChannel
protected CommandChannel createCommandChannel()
throws IOException
- Overrides:
createCommandChannel
in class UdpTransport
- Throws:
IOException
getMulticastAddress
protected InetAddress getMulticastAddress()
getSocket
protected MulticastSocket getSocket()
setSocket
protected void setSocket(MulticastSocket socket)
createAddress
protected InetSocketAddress createAddress(URI remoteLocation)
throws UnknownHostException,
IOException
- Description copied from class:
UdpTransport
- Creates an address from the given URI
- Overrides:
createAddress
in class UdpTransport
- Throws:
UnknownHostException
IOException
createDatagramHeaderMarshaller
protected DatagramHeaderMarshaller createDatagramHeaderMarshaller()
- Overrides:
createDatagramHeaderMarshaller
in class UdpTransport
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.