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	Description
protected Transporter	transporter

Fields inherited from class ListenerEndpoint

group, hashCode, logger, privateAccess, serviceName, subscribe

Fields inherited from class Endpoint

nodeID

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RemoteListenerEndpoint(String nodeID, String service, String group, String subscribe, Transporter transporter)

Method Summary

Modifier and Type	Method	Description
boolean	isLocal()
void	on(Context ctx, Groups groups, boolean broadcast)

Methods inherited from class ListenerEndpoint

equals, hashCode, isPrivate

Methods inherited from class Endpoint

getNodeID

Methods inherited from class Object

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

Field Details

transporter

protected Transporter transporter

Constructor Details

RemoteListenerEndpoint

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

Method Details

on

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

Specified by:

on in class ListenerEndpoint

Throws:

Exception

isLocal

public boolean isLocal()

Specified by:

isLocal in class ListenerEndpoint