services.moleculer.eventbus

Class RemoteListenerEndpoint

java.lang.Object

services.moleculer.service.Endpoint

services.moleculer.eventbus.ListenerEndpoint

services.moleculer.eventbus.RemoteListenerEndpoint

public class RemoteListenerEndpoint
extends ListenerEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	currentNodeID
protected Transporter	transporter

Fields inherited from class services.moleculer.eventbus.ListenerEndpoint

group, hashCode, logger, serviceName, subscribe

Fields inherited from class services.moleculer.service.Endpoint

nodeID

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RemoteListenerEndpoint(Transporter transporter, java.lang.String nodeID, java.lang.String service, java.lang.String group, java.lang.String subscribe)

Method Summary

Modifier and Type	Method and Description
boolean	isLocal()
void	on(java.lang.String name, io.datatree.Tree payload, Groups groups, boolean broadcast)

Methods inherited from class services.moleculer.eventbus.ListenerEndpoint

equals, getGroup, getServiceName, getSubscribe, hashCode

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

currentNodeID

protected final java.lang.String currentNodeID

transporter

protected Transporter transporter

Constructor Detail

RemoteListenerEndpoint

protected RemoteListenerEndpoint(Transporter transporter,
                                 java.lang.String nodeID,
                                 java.lang.String service,
                                 java.lang.String group,
                                 java.lang.String subscribe)

Method Detail

on

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

Specified by:

on in class ListenerEndpoint

Throws:

java.lang.Exception

isLocal

public boolean isLocal()

Specified by:

isLocal in class ListenerEndpoint