public class MulticastTransport extends UdpTransport
Constructor and Description |
---|
MulticastTransport(OpenWireFormat wireFormat,
java.net.URI remoteLocation) |
Modifier and Type | Method and Description |
---|---|
protected void |
bind(java.net.DatagramSocket socket,
java.net.SocketAddress localAddress) |
protected java.net.InetSocketAddress |
createAddress(java.net.URI remoteLocation)
Creates an address from the given URI
|
protected CommandChannel |
createCommandChannel() |
protected DatagramHeaderMarshaller |
createDatagramHeaderMarshaller() |
protected void |
doStop(ServiceStopper stopper) |
long |
getKeepAliveInterval() |
protected java.net.InetAddress |
getMulticastAddress() |
protected java.lang.String |
getProtocolName() |
protected java.lang.String |
getProtocolUriScheme() |
protected java.net.MulticastSocket |
getSocket() |
int |
getTimeToLive() |
boolean |
isLoopBackMode() |
void |
setKeepAliveInterval(long keepAliveInterval) |
void |
setLoopBackMode(boolean loopBackMode) |
protected void |
setSocket(java.net.MulticastSocket socket) |
void |
setTimeToLive(int timeToLive) |
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
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, updateURIs
public MulticastTransport(OpenWireFormat wireFormat, java.net.URI remoteLocation) throws java.net.UnknownHostException, java.io.IOException
java.net.UnknownHostException
java.io.IOException
public long getKeepAliveInterval()
public void setKeepAliveInterval(long keepAliveInterval)
public boolean isLoopBackMode()
public void setLoopBackMode(boolean loopBackMode)
public int getTimeToLive()
public void setTimeToLive(int timeToLive)
protected java.lang.String getProtocolName()
getProtocolName
in class UdpTransport
protected java.lang.String getProtocolUriScheme()
getProtocolUriScheme
in class UdpTransport
protected void bind(java.net.DatagramSocket socket, java.net.SocketAddress localAddress) throws java.net.SocketException
bind
in class UdpTransport
java.net.SocketException
protected void doStop(ServiceStopper stopper) throws java.lang.Exception
doStop
in class UdpTransport
java.lang.Exception
protected CommandChannel createCommandChannel() throws java.io.IOException
createCommandChannel
in class UdpTransport
java.io.IOException
protected java.net.InetAddress getMulticastAddress()
protected java.net.MulticastSocket getSocket()
protected void setSocket(java.net.MulticastSocket socket)
protected java.net.InetSocketAddress createAddress(java.net.URI remoteLocation) throws java.net.UnknownHostException, java.io.IOException
UdpTransport
createAddress
in class UdpTransport
java.net.UnknownHostException
java.io.IOException
protected DatagramHeaderMarshaller createDatagramHeaderMarshaller()
createDatagramHeaderMarshaller
in class UdpTransport
Copyright © 2005-2017. All Rights Reserved.