Package org.cometd.oort

Class Oort

  • All Implemented Interfaces:
    org.eclipse.jetty.util.component.Container, org.eclipse.jetty.util.component.Destroyable, org.eclipse.jetty.util.component.Dumpable, org.eclipse.jetty.util.component.Dumpable.DumpableContainer, org.eclipse.jetty.util.component.LifeCycle
    @ManagedObject("CometD cloud node")
public class Oort
extends org.eclipse.jetty.util.component.ContainerLifeCycle

    Oort is the cluster manager that links one CometD server to a set of other CometD servers.

    The Oort instance is created and configured by either OortMulticastConfigServlet or OortStaticConfigServlet.

    This class maintains a collection of OortComet instances to each CometD server, created by calls to observeComet(String).

    The key configuration parameter is the Oort URL, which is full public URL of the CometD servlet to which the Oort instance is bound, for example: http://myserver:8080/context/cometd.

    Oort instances can be configured with a shared secret, which allows the Oort instance to distinguish handshakes coming from remote clients from handshakes coming from other Oort comets: the firsts may be subject to a stricter authentication policy than the seconds.

    See Also:
    OortMulticastConfigServlet, OortStaticConfigServlet

    • Field Detail

      • OORT_ATTRIBUTE

        public static final java.lang.String OORT_ATTRIBUTE

      • EXT_OORT_URL_FIELD

        public static final java.lang.String EXT_OORT_URL_FIELD
        See Also:
        Constant Field Values

      • EXT_OORT_ID_FIELD

        public static final java.lang.String EXT_OORT_ID_FIELD
        See Also:
        Constant Field Values

      • EXT_OORT_SECRET_FIELD

        public static final java.lang.String EXT_OORT_SECRET_FIELD
        See Also:
        Constant Field Values

      • EXT_COMET_URL_FIELD

        public static final java.lang.String EXT_COMET_URL_FIELD
        See Also:
        Constant Field Values

      • EXT_OORT_ALIAS_URL_FIELD

        public static final java.lang.String EXT_OORT_ALIAS_URL_FIELD
        See Also:
        Constant Field Values

      • OORT_CLOUD_CHANNEL

        public static final java.lang.String OORT_CLOUD_CHANNEL
        See Also:
        Constant Field Values

      • OORT_SERVICE_CHANNEL

        public static final java.lang.String OORT_SERVICE_CHANNEL
        See Also:
        Constant Field Values

    • Constructor Detail

      • Oort

        public Oort​(BayeuxServer bayeux,
            java.lang.String url)

    • Method Detail

      • doStart

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

      • doStop

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

      • protectOortChannels

        protected void protectOortChannels​(BayeuxServer bayeux)

      • unprotectOortChannels

        protected void unprotectOortChannels​(BayeuxServer bayeux)

      • getScheduler

        protected java.util.concurrent.ScheduledExecutorService getScheduler()

      • getBayeuxServer

        @ManagedAttribute(value="The BayeuxServer of this Oort",
                  readonly=true)
public BayeuxServer getBayeuxServer()

      • getURL

        @ManagedAttribute(value="The URL of this Oort",
                  readonly=true)
public java.lang.String getURL()
        Returns:
        the public absolute URL of the Oort CometD server

      • getId

        @ManagedAttribute(value="The unique ID of this Oort",
                  readonly=true)
public java.lang.String getId()

      • getSecret

        @ManagedAttribute("The secret of this Oort")
public java.lang.String getSecret()

      • setSecret

        public void setSecret​(java.lang.String secret)

      • isAckExtensionEnabled

        @ManagedAttribute("Whether the acknowledgement extension is enabled")
public boolean isAckExtensionEnabled()

      • setAckExtensionEnabled

        public void setAckExtensionEnabled​(boolean value)

      • isBinaryExtensionEnabled

        @ManagedAttribute("Whether the binary extension is enabled")
public boolean isBinaryExtensionEnabled()

      • setBinaryExtensionEnabled

        public void setBinaryExtensionEnabled​(boolean value)

      • setJSONContextClient

        public void setJSONContextClient​(JSONContext.Client jsonContext)

      • setClientTransportFactories

        public void setClientTransportFactories​(java.util.List<ClientTransport.Factory> factories)

      • observeComet

        public OortComet observeComet​(java.lang.String cometURL)

        Connects (if not already connected) and observes another Oort instance (identified by the given URL) via a OortComet instance.

        Parameters:
        cometURL - the Oort URL to observe
        Returns:
        The OortComet instance associated to the Oort instance identified by the URL or null if the given Oort URL represent this Oort instance

      • newOortComet

        protected OortComet newOortComet​(java.lang.String cometURL)

      • configureOortComet

        protected void configureOortComet​(OortComet oortComet)

      • encodeSecret

        protected java.lang.String encodeSecret​(java.lang.String secret)

      • connectComet

        protected void connectComet​(OortComet comet,
                            java.util.Map<java.lang.String,​java.lang.Object> fields)

      • deobserveComet

        public OortComet deobserveComet​(java.lang.String cometURL)

      • getKnownComets

        @ManagedAttribute(value="URLs of known Oorts in the cluster",
                  readonly=true)
public java.util.Set<java.lang.String> getKnownComets()
        Returns:
        the set of known Oort comet servers URLs.

      • getComet

        public OortComet getComet​(java.lang.String cometURL)
        Parameters:
        cometURL - the URL of a Oort comet
        Returns:
        the OortComet instance connected with the Oort comet with the given URL

      • findComet

        protected OortComet findComet​(java.lang.String cometURL)
        Parameters:
        cometURL - the URL of a Oort comet
        Returns:
        the OortComet instance connecting or connected with the Oort comet with the given URL

      • observeChannel

        @ManagedOperation(value="Observes the given channel",
                  impact="ACTION")
public void observeChannel​(@Name(value="channel",description="The channel to observe")
                           java.lang.String channelName)

        Observes the given channel, registering to receive messages from the Oort comets connected to this Oort instance.

        Once observed, all OortComet instances subscribe to the channel and will repeat any messages published to the local channel (with loop prevention), so that the messages are distributed to all Oort comet servers.

        Parameters:
        channelName - the channel to observe

      • deobserveChannel

        @ManagedOperation(value="Deobserves the given channel",
                  impact="ACTION")
public void deobserveChannel​(@Name(value="channel",description="The channel to deobserve")
                             java.lang.String channelId)

      • isOort

        public boolean isOort​(ServerSession session)
        Parameters:
        session - the server session to test
        Returns:
        whether the given server session is one of those created by the Oort internal working
        See Also:
        isOortHandshake(Message)

      • isOortHandshake

        public boolean isOortHandshake​(Message handshake)
        Parameters:
        handshake - the handshake message to test
        Returns:
        whether the given handshake message is coming from another Oort comet that has been configured with the same secret
        See Also:
        isOort(ServerSession)

      • newOortHandshakeFields

        protected java.util.Map<java.lang.String,​java.lang.Object> newOortHandshakeFields​(java.lang.String cometURL,
                                                                                        java.lang.String oortAliasURL)

      • isCometConnected

        protected boolean isCometConnected​(java.lang.String oortURL)
        Parameters:
        oortURL - the comet URL to check for connection
        Returns:
        whether the given comet is connected to this comet

      • joinComets

        protected void joinComets​(Message message)

      • getObservedChannels

        public java.util.Set<java.lang.String> getObservedChannels()

      • getOortSession

        public LocalSession getOortSession()
        Returns:
        the oortSession

      • replacePunctuation

        protected static java.lang.String replacePunctuation​(java.lang.String source,
                                                     char replacement)

      • dump

        public void dump​(java.lang.Appendable out,
                 java.lang.String indent)
          throws java.io.IOException
        Specified by:
        dump in interface org.eclipse.jetty.util.component.Dumpable
        Overrides:
        dump in class org.eclipse.jetty.util.component.ContainerLifeCycle
        Throws:
        java.io.IOException

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class org.eclipse.jetty.util.component.AbstractLifeCycle