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
      • 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, RUNNING, 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)