services.moleculer.eventbus

Class LocalListenerEndpoint

java.lang.Object

services.moleculer.service.Endpoint

services.moleculer.eventbus.ListenerEndpoint

services.moleculer.eventbus.LocalListenerEndpoint

public class LocalListenerEndpoint
extends ListenerEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	asyncLocalInvocation Invoke all local listeners via Thread pool (true) or directly (false)
protected java.util.concurrent.ExecutorService	executor
protected Listener	listener Listener instance (it's a field / inner class in Service object)

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

Constructor and Description
LocalListenerEndpoint(java.util.concurrent.ExecutorService executor, java.lang.String nodeID, java.lang.String service, java.lang.String group, java.lang.String subscribe, Listener listener, boolean asyncLocalInvocation)

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

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

listener

protected Listener listener

Listener instance (it's a field / inner class in Service object)

asyncLocalInvocation

protected boolean asyncLocalInvocation

Invoke all local listeners via Thread pool (true) or directly (false)

executor

protected java.util.concurrent.ExecutorService executor

Constructor Detail

LocalListenerEndpoint

public LocalListenerEndpoint(java.util.concurrent.ExecutorService executor,
                             java.lang.String nodeID,
                             java.lang.String service,
                             java.lang.String group,
                             java.lang.String subscribe,
                             Listener listener,
                             boolean asyncLocalInvocation)

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