Package com.atlassian.bamboo.cluster

Class PerNodeLocalQueueDispatcherImpl

java.lang.Object

com.atlassian.bamboo.cluster.PerNodeLocalQueueDispatcherImpl

All Implemented Interfaces:

PerNodeLocalQueueDispatcher

public class PerNodeLocalQueueDispatcherImpl
extends Object
implements PerNodeLocalQueueDispatcher

Responsible for dispatching CrossNodesEvent from PerNodeLocalQueue to remote node.

Since:

9.5

Method Summary

Modifier and Type	Method	Description
static PerNodeLocalQueueDispatcherImpl	create(TapePerNodeLocalQueueWithStats queue, Executor dispatcherExecutor, Map<Class<? extends io.grpc.stub.AbstractAsyncStub<?>>,? extends io.grpc.stub.AbstractAsyncStub<?>> stubs, TapePerNodeLocalQueueCriticalHandler perNodeLocalQueueCriticalHandler, MetadataInfo metadataInfo)
boolean	dispatch(@NotNull CrossNodesEvent crossNodesEvent)	Dispatches CrossNodesEvent to remote node ensuring data durability.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

create

public static PerNodeLocalQueueDispatcherImpl create(TapePerNodeLocalQueueWithStats queue,
 Executor dispatcherExecutor,
 Map<Class<? extends io.grpc.stub.AbstractAsyncStub<?>>,? extends io.grpc.stub.AbstractAsyncStub<?>> stubs,
 TapePerNodeLocalQueueCriticalHandler perNodeLocalQueueCriticalHandler,
 MetadataInfo metadataInfo)

dispatch

public boolean dispatch(@NotNull
 @NotNull CrossNodesEvent crossNodesEvent)

Description copied from interface: PerNodeLocalQueueDispatcher

Dispatches CrossNodesEvent to remote node ensuring data durability.

Specified by:

dispatch in interface PerNodeLocalQueueDispatcher

Parameters:

crossNodesEvent - event to dispatch

Returns:

true if event was dispatched, false otherwise

toString

public String toString()

Overrides:

toString in class Object