Class ListenerEndpoint

java.lang.Object
services.moleculer.service.Endpoint
services.moleculer.eventbus.ListenerEndpoint
Direct Known Subclasses:
LocalListenerEndpoint, RemoteListenerEndpoint
public abstract class ListenerEndpoint extends Endpoint

  • Field Details

    • logger

      protected final org.slf4j.Logger logger

    • serviceName

      protected final String serviceName

    • group

      protected final String group

    • subscribe

      protected final String subscribe

    • privateAccess

      protected final boolean privateAccess
      Private Listener; only the local Broker can access it and cannot be called remotely.

    • hashCode

      protected final int hashCode

  • Constructor Details

    • ListenerEndpoint

      protected ListenerEndpoint(String nodeID, String serviceName, String group, String subscribe, boolean privateAccess)

  • Method Details

    • on

      public abstract void on(Context ctx, Groups groups, boolean broadcast) throws Exception
      Throws:
      Exception

    • isLocal

      public abstract boolean isLocal()

    • isPrivate

      public boolean isPrivate()

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object