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 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)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String	getGroup()
java.lang.String	getServiceName()
java.lang.String	getSubscribe()
int	hashCode()
abstract boolean	isLocal()
abstract void	on(java.lang.String name, io.datatree.Tree payload, 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

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)

Method Detail

on

public abstract void on(java.lang.String name,
                        io.datatree.Tree payload,
                        Groups groups,
                        boolean broadcast)
                 throws java.lang.Exception

Throws:

java.lang.Exception

isLocal

public abstract boolean isLocal()

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

getServiceName

public java.lang.String getServiceName()

getGroup

public java.lang.String getGroup()

getSubscribe

public java.lang.String getSubscribe()