Uses of Interface
com.lmax.disruptor.EventHandlerIdentity
Packages that use EventHandlerIdentity
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
A DSL-style API for setting up the disruptor pattern around a ring buffer.
-
Uses of EventHandlerIdentity in com.lmax.disruptor
Subinterfaces of EventHandlerIdentity in com.lmax.disruptorModifier and TypeInterfaceDescriptioninterfaceEventHandler<T>Callback interface to be implemented for processing events as they become available in theRingBuffer(package private) interfaceinterfaceCallback interface to be implemented for processing events as they become available in theRingBufferwith support for throwing aRewindableExceptionwhen an even cannot be processed currently but may succeed on retry.interfaceUsed by theBatchEventProcessorto set a callback allowing theEventHandlerto notify when it has finished consuming an event if this happens after theEventHandler.onEvent(Object, long, boolean)call.Classes in com.lmax.disruptor that implement EventHandlerIdentityModifier and TypeClassDescriptionfinal classAn aggregate collection ofEventHandlers that get called in sequence for each event. -
Uses of EventHandlerIdentity in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as EventHandlerIdentityModifier and TypeFieldDescriptionprivate final EventHandlerIdentityExceptionHandlerSetting.handlerIdentityFields in com.lmax.disruptor.dsl with type parameters of type EventHandlerIdentityModifier and TypeFieldDescriptionprivate final Map<EventHandlerIdentity, EventProcessorInfo> ConsumerRepository.eventProcessorInfoByEventHandlerMethods in com.lmax.disruptor.dsl with parameters of type EventHandlerIdentityModifier and TypeMethodDescriptionvoidConsumerRepository.add(EventProcessor eventprocessor, EventHandlerIdentity handlerIdentity, SequenceBarrier barrier) final EventHandlerGroup<T> Disruptor.after(EventHandlerIdentity... handlers) Create a group of event handlers to be used as a dependency.ConsumerRepository.getBarrierFor(EventHandlerIdentity handlerIdentity) Disruptor.getBarrierFor(EventHandlerIdentity handler) Get theSequenceBarrierused by a specific handler.ConsumerRepository.getEventProcessorFor(EventHandlerIdentity handlerIdentity) private EventProcessorInfoConsumerRepository.getEventProcessorInfo(EventHandlerIdentity handlerIdentity) ConsumerRepository.getSequenceFor(EventHandlerIdentity handlerIdentity) longDisruptor.getSequenceValueFor(EventHandlerIdentity handler) Gets the sequence value for the specified event handlers.Disruptor.handleExceptionsFor(EventHandlerIdentity eventHandler) Override the default exception handler for a specific handler.Constructors in com.lmax.disruptor.dsl with parameters of type EventHandlerIdentityModifierConstructorDescription(package private)ExceptionHandlerSetting(EventHandlerIdentity handlerIdentity, ConsumerRepository consumerRepository)