Package org.cometd.oort

Class 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 Detail

      • OortMulticastConfigurer

        public OortMulticastConfigurer​(Oort oort)

    • Method Detail

      • 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 class org.eclipse.jetty.util.component.AbstractLifeCycle
        Throws:
        java.lang.Exception

      • doStop

        protected void doStop()
               throws java.lang.Exception
        Overrides:
        doStop in class org.eclipse.jetty.util.component.AbstractLifeCycle
        Throws:
        java.lang.Exception

      • join

        public boolean join​(long timeout)

      • receive

        protected void receive​(java.lang.String cometURL)