services.moleculer.eventbus

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 Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	group
protected int	hashCode
protected org.slf4j.Logger	logger
protected boolean	privateAccess Private Listener; only the local Broker can access it and cannot be called remotely.
protected java.lang.String	serviceName
protected java.lang.String	subscribe

Fields inherited from class services.moleculer.service.Endpoint

nodeID

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ListenerEndpoint(java.lang.String nodeID, java.lang.String serviceName, java.lang.String group, java.lang.String subscribe, boolean privateAccess)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
int	hashCode()
abstract boolean	isLocal()
boolean	isPrivate()
abstract void	on(Context ctx, Groups groups, boolean broadcast)

Methods inherited from class services.moleculer.service.Endpoint

getNodeID

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected final org.slf4j.Logger logger

serviceName

protected final java.lang.String serviceName

group

protected final java.lang.String group

subscribe

protected final java.lang.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 Detail

ListenerEndpoint

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

Method Detail

on

public abstract void on(Context ctx,
                        Groups groups,
                        boolean broadcast)
                 throws java.lang.Exception

Throws:

java.lang.Exception

isLocal

public abstract boolean isLocal()

isPrivate

public boolean isPrivate()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object