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

Fields inherited from class services.moleculer.eventbus.ListenerEndpoint

group, hashCode, logger, privateAccess, serviceName, subscribe

Fields inherited from class services.moleculer.service.Endpoint

nodeID

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class services.moleculer.eventbus.ListenerEndpoint

equals, hashCode, isPrivate

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

transporter

protected Transporter transporter

Constructor Detail

RemoteListenerEndpoint

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

Method Detail

on

public void on(Context ctx,
               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