Package com.atlassian.bamboo.cluster.event

Class AbstractCrossNodesEvent<R>

java.lang.Object

com.atlassian.bamboo.cluster.event.AbstractCrossNodesEvent<R>

Type Parameters:

R - type of gRPC request message

All Implemented Interfaces:

CrossNodesEvent, Serializable

Direct Known Subclasses:

AbstractPluginEvent, AtlassianCacheAbstractEvent, HidePlanEvent, HideStageEvent, InvalidateAllLatestResultSummariesEvent, InvalidateBuildNumbersRangeEvent, InvalidateLatestResultSummaryEvent, InvalidatePlanCacheEvent, InvalidateRepositoryCacheEvent, InvalidateSpecsStateForPlanRequestEvent, InvalidateUserSessionsEvent, RefreshAdministrationConfigurationEvent, RefreshClusterLifecycleStateEvent

public abstract class AbstractCrossNodesEvent<R>
extends Object
implements CrossNodesEvent

Base class for cross nodes events transferred using PerNodeLocalQueueDispatcherImpl.

Since:

9.5

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.atlassian.bamboo.cluster.event.CrossNodesEvent

CrossNodesEvent.Type

Constructor Summary

Constructors

Constructor	Description
AbstractCrossNodesEvent()

Method Summary

Modifier and Type	Method	Description
abstract void	send(CrossNodesEventsServiceGrpc.CrossNodesEventsServiceStub stub, @NotNull MetadataInfo metadataInfo, @NotNull io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)
protected abstract R	toGrpcRequestMessage(@NotNull MetadataInfo metadataInfo)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.bamboo.cluster.event.CrossNodesEvent

equals, getType, hashCode, isEmpty, isNotEmpty, toString

Constructor Detail

AbstractCrossNodesEvent

public AbstractCrossNodesEvent()

Method Detail

send

public abstract void send(@NotNull
                          CrossNodesEventsServiceGrpc.CrossNodesEventsServiceStub stub,
                          @NotNull
                          @NotNull MetadataInfo metadataInfo,
                          @NotNull
                          @NotNull io.grpc.stub.StreamObserver<CrossNodesCommunication.CommonResponse> responseObserver)

toGrpcRequestMessage

@NotNull
protected abstract R toGrpcRequestMessage(@NotNull
                                          @NotNull MetadataInfo metadataInfo)