Package org.cometd.oort
Class OortMulticastConfigurer
java.lang.Object
org.eclipse.jetty.util.component.AbstractLifeCycle
org.cometd.oort.OortMulticastConfigurer
- All Implemented Interfaces:
org.eclipse.jetty.util.component.LifeCycle
public class OortMulticastConfigurer
extends org.eclipse.jetty.util.component.AbstractLifeCycle
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
org.eclipse.jetty.util.component.AbstractLifeCycle.AbstractLifeCycleListener, org.eclipse.jetty.util.component.AbstractLifeCycle.StopException
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle
org.eclipse.jetty.util.component.LifeCycle.Listener
-
Field Summary
Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
FAILED, STARTED, STARTING, STOPPED, STOPPING
-
Constructor Summary
Constructors Constructor Description OortMulticastConfigurer(Oort oort)
-
Method Summary
Modifier and Type Method Description protected void
doStart()
protected void
doStop()
long
getAdvertiseInterval()
java.net.InetAddress
getBindAddress()
long
getConnectTimeout()
java.net.InetAddress
getGroupAddress()
java.util.List<java.net.NetworkInterface>
getGroupInterfaces()
int
getGroupPort()
int
getMaxTransmissionLength()
int
getTimeToLive()
boolean
join(long timeout)
protected void
receive(java.lang.String cometURL)
void
setAdvertiseInterval(long advertiseInterval)
void
setBindAddress(java.net.InetAddress bindAddress)
void
setConnectTimeout(long connectTimeout)
void
setGroupAddress(java.net.InetAddress groupAddress)
void
setGroupInterfaces(java.util.List<java.net.NetworkInterface> groupInterfaces)
void
setGroupPort(int groupPort)
void
setMaxTransmissionLength(int maxTransmissionLength)
void
setTimeToLive(int timeToLive)
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle
addEventListener, getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeEventListener, setEventListeners, start, stop, toString
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
OortMulticastConfigurer
-
-
Method Details
-
getBindAddress
public java.net.InetAddress getBindAddress()- Returns:
- the address to bind the receiver multicast socket to
-
setBindAddress
public void setBindAddress(java.net.InetAddress bindAddress)- Parameters:
bindAddress
- the address to bind the receiver multicast socket to
-
getGroupAddress
public java.net.InetAddress getGroupAddress()- Returns:
- the multicast address onto which Oort URLs are advertised
-
setGroupAddress
public void setGroupAddress(java.net.InetAddress groupAddress)- Parameters:
groupAddress
- the multicast address onto which Oort URLs are advertised
-
getGroupPort
public int getGroupPort()- Returns:
- the port the receiver multicast socket listens to
-
setGroupPort
public void setGroupPort(int groupPort)- Parameters:
groupPort
- the port the receiver multicast socket listens to
-
getGroupInterfaces
public java.util.List<java.net.NetworkInterface> getGroupInterfaces()- Returns:
- the interfaces that receive multicast messages
-
setGroupInterfaces
public void setGroupInterfaces(java.util.List<java.net.NetworkInterface> groupInterfaces)- Parameters:
groupInterfaces
- the interfaces that receive multicast messages
-
getTimeToLive
public int getTimeToLive()- Returns:
- the multicast time-to-live
-
setTimeToLive
public void setTimeToLive(int timeToLive)- Parameters:
timeToLive
- the multicast time-to-live
-
getAdvertiseInterval
public long getAdvertiseInterval()- Returns:
- the advertisement interval in milliseconds
-
setAdvertiseInterval
public void setAdvertiseInterval(long advertiseInterval)- Parameters:
advertiseInterval
- the advertisement interval in milliseconds
-
getConnectTimeout
public long getConnectTimeout()- Returns:
- the timeout to connect to another Oort node
-
setConnectTimeout
public void setConnectTimeout(long connectTimeout)- Parameters:
connectTimeout
- the timeout to connect to another Oort node
-
getMaxTransmissionLength
public int getMaxTransmissionLength()- Returns:
- the max Oort URL length (must be smaller than the max transmission unit)
-
setMaxTransmissionLength
public void setMaxTransmissionLength(int maxTransmissionLength)- Parameters:
maxTransmissionLength
- the max Oort URL length (must be smaller than the max transmission unit)
-
doStart
protected void doStart() throws java.lang.Exception- Overrides:
doStart
in classorg.eclipse.jetty.util.component.AbstractLifeCycle
- Throws:
java.lang.Exception
-
doStop
protected void doStop() throws java.lang.Exception- Overrides:
doStop
in classorg.eclipse.jetty.util.component.AbstractLifeCycle
- Throws:
java.lang.Exception
-
join
public boolean join(long timeout) -
receive
protected void receive(java.lang.String cometURL)
-