public interface EventSink<E>
Modifier and Type | Method and Description |
---|---|
void |
publishEvent(EventTranslator<E> translator)
Publishes an event to the ring buffer.
|
<A> void |
publishEvent(EventTranslatorOneArg<E,A> translator,
A arg0)
Allows one user supplied argument.
|
<A,B,C> void |
publishEvent(EventTranslatorThreeArg<E,A,B,C> translator,
A arg0,
B arg1,
C arg2)
Allows three user supplied arguments
|
<A,B> void |
publishEvent(EventTranslatorTwoArg<E,A,B> translator,
A arg0,
B arg1)
Allows two user supplied arguments.
|
void |
publishEvent(EventTranslatorVararg<E> translator,
java.lang.Object... args)
Allows a variable number of user supplied arguments
|
void |
publishEvents(EventTranslator<E>[] translators)
Publishes multiple events to the ring buffer.
|
void |
publishEvents(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize)
Publishes multiple events to the ring buffer.
|
<A> void |
publishEvents(EventTranslatorOneArg<E,A> translator,
A[] arg0)
Allows one user supplied argument per event.
|
<A> void |
publishEvents(EventTranslatorOneArg<E,A> translator,
int batchStartsAt,
int batchSize,
A[] arg0)
Allows one user supplied argument per event.
|
<A,B,C> void |
publishEvents(EventTranslatorThreeArg<E,A,B,C> translator,
A[] arg0,
B[] arg1,
C[] arg2)
Allows three user supplied arguments per event.
|
<A,B,C> void |
publishEvents(EventTranslatorThreeArg<E,A,B,C> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1,
C[] arg2)
Allows three user supplied arguments per event.
|
<A,B> void |
publishEvents(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
<A,B> void |
publishEvents(EventTranslatorTwoArg<E,A,B> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
void |
publishEvents(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
void |
publishEvents(EventTranslatorVararg<E> translator,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
boolean |
tryPublishEvent(EventTranslator<E> translator)
Attempts to publish an event to the ring buffer.
|
<A> boolean |
tryPublishEvent(EventTranslatorOneArg<E,A> translator,
A arg0)
Allows one user supplied argument.
|
<A,B,C> boolean |
tryPublishEvent(EventTranslatorThreeArg<E,A,B,C> translator,
A arg0,
B arg1,
C arg2)
Allows three user supplied arguments
|
<A,B> boolean |
tryPublishEvent(EventTranslatorTwoArg<E,A,B> translator,
A arg0,
B arg1)
Allows two user supplied arguments.
|
boolean |
tryPublishEvent(EventTranslatorVararg<E> translator,
java.lang.Object... args)
Allows a variable number of user supplied arguments
|
boolean |
tryPublishEvents(EventTranslator<E>[] translators)
Attempts to publish multiple events to the ring buffer.
|
boolean |
tryPublishEvents(EventTranslator<E>[] translators,
int batchStartsAt,
int batchSize)
Attempts to publish multiple events to the ring buffer.
|
<A> boolean |
tryPublishEvents(EventTranslatorOneArg<E,A> translator,
A[] arg0)
Allows one user supplied argument.
|
<A> boolean |
tryPublishEvents(EventTranslatorOneArg<E,A> translator,
int batchStartsAt,
int batchSize,
A[] arg0)
Allows one user supplied argument.
|
<A,B,C> boolean |
tryPublishEvents(EventTranslatorThreeArg<E,A,B,C> translator,
A[] arg0,
B[] arg1,
C[] arg2)
Allows three user supplied arguments per event.
|
<A,B,C> boolean |
tryPublishEvents(EventTranslatorThreeArg<E,A,B,C> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1,
C[] arg2)
Allows three user supplied arguments per event.
|
<A,B> boolean |
tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
<A,B> boolean |
tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator,
int batchStartsAt,
int batchSize,
A[] arg0,
B[] arg1)
Allows two user supplied arguments per event.
|
boolean |
tryPublishEvents(EventTranslatorVararg<E> translator,
int batchStartsAt,
int batchSize,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
boolean |
tryPublishEvents(EventTranslatorVararg<E> translator,
java.lang.Object[]... args)
Allows a variable number of user supplied arguments per event.
|
void publishEvent(EventTranslator<E> translator)
translator
- The user specified translation for the eventboolean tryPublishEvent(EventTranslator<E> translator)
translator
- The user specified translation for the event<A> void publishEvent(EventTranslatorOneArg<E,A> translator, A arg0)
translator
- The user specified translation for the eventarg0
- A user supplied argument.publishEvent(EventTranslator)
<A> boolean tryPublishEvent(EventTranslatorOneArg<E,A> translator, A arg0)
translator
- The user specified translation for the eventarg0
- A user supplied argument.tryPublishEvent(EventTranslator)
<A,B> void publishEvent(EventTranslatorTwoArg<E,A,B> translator, A arg0, B arg1)
translator
- The user specified translation for the eventarg0
- A user supplied argument.arg1
- A user supplied argument.publishEvent(EventTranslator)
<A,B> boolean tryPublishEvent(EventTranslatorTwoArg<E,A,B> translator, A arg0, B arg1)
translator
- The user specified translation for the eventarg0
- A user supplied argument.arg1
- A user supplied argument.tryPublishEvent(EventTranslator)
<A,B,C> void publishEvent(EventTranslatorThreeArg<E,A,B,C> translator, A arg0, B arg1, C arg2)
translator
- The user specified translation for the eventarg0
- A user supplied argument.arg1
- A user supplied argument.arg2
- A user supplied argument.publishEvent(EventTranslator)
<A,B,C> boolean tryPublishEvent(EventTranslatorThreeArg<E,A,B,C> translator, A arg0, B arg1, C arg2)
translator
- The user specified translation for the eventarg0
- A user supplied argument.arg1
- A user supplied argument.arg2
- A user supplied argument.publishEvent(EventTranslator)
void publishEvent(EventTranslatorVararg<E> translator, java.lang.Object... args)
translator
- The user specified translation for the eventargs
- User supplied arguments.publishEvent(EventTranslator)
boolean tryPublishEvent(EventTranslatorVararg<E> translator, java.lang.Object... args)
translator
- The user specified translation for the eventargs
- User supplied arguments.publishEvent(EventTranslator)
void publishEvents(EventTranslator<E>[] translators)
With this call the data that is to be inserted into the ring buffer will be a field (either explicitly or captured anonymously), therefore this call will require an instance of the translator for each value that is to be inserted into the ring buffer.
translators
- The user specified translation for each eventvoid publishEvents(EventTranslator<E>[] translators, int batchStartsAt, int batchSize)
With this call the data that is to be inserted into the ring buffer will be a field (either explicitly or captured anonymously), therefore this call will require an instance of the translator for each value that is to be inserted into the ring buffer.
translators
- The user specified translation for each eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batchboolean tryPublishEvents(EventTranslator<E>[] translators)
translators
- The user specified translation for the eventboolean tryPublishEvents(EventTranslator<E>[] translators, int batchStartsAt, int batchSize)
translators
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batch<A> void publishEvents(EventTranslatorOneArg<E,A> translator, A[] arg0)
translator
- The user specified translation for the eventarg0
- A user supplied argument.publishEvents(com.lmax.disruptor.EventTranslator[])
<A> void publishEvents(EventTranslatorOneArg<E,A> translator, int batchStartsAt, int batchSize, A[] arg0)
translator
- The user specified translation for each eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batcharg0
- An array of user supplied arguments, one element per event.publishEvents(EventTranslator[])
<A> boolean tryPublishEvents(EventTranslatorOneArg<E,A> translator, A[] arg0)
translator
- The user specified translation for each eventarg0
- An array of user supplied arguments, one element per event.tryPublishEvents(com.lmax.disruptor.EventTranslator[])
<A> boolean tryPublishEvents(EventTranslatorOneArg<E,A> translator, int batchStartsAt, int batchSize, A[] arg0)
translator
- The user specified translation for each eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batcharg0
- An array of user supplied arguments, one element per event.tryPublishEvents(EventTranslator[])
<A,B> void publishEvents(EventTranslatorTwoArg<E,A,B> translator, A[] arg0, B[] arg1)
translator
- The user specified translation for the eventarg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.publishEvents(com.lmax.disruptor.EventTranslator[])
<A,B> void publishEvents(EventTranslatorTwoArg<E,A,B> translator, int batchStartsAt, int batchSize, A[] arg0, B[] arg1)
translator
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batch.arg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.publishEvents(EventTranslator[])
<A,B> boolean tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator, A[] arg0, B[] arg1)
translator
- The user specified translation for the eventarg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.tryPublishEvents(com.lmax.disruptor.EventTranslator[])
<A,B> boolean tryPublishEvents(EventTranslatorTwoArg<E,A,B> translator, int batchStartsAt, int batchSize, A[] arg0, B[] arg1)
translator
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batch.arg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.tryPublishEvents(EventTranslator[])
<A,B,C> void publishEvents(EventTranslatorThreeArg<E,A,B,C> translator, A[] arg0, B[] arg1, C[] arg2)
translator
- The user specified translation for the eventarg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.arg2
- An array of user supplied arguments, one element per event.publishEvents(com.lmax.disruptor.EventTranslator[])
<A,B,C> void publishEvents(EventTranslatorThreeArg<E,A,B,C> translator, int batchStartsAt, int batchSize, A[] arg0, B[] arg1, C[] arg2)
translator
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The number of elements in the batch.arg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.arg2
- An array of user supplied arguments, one element per event.publishEvents(EventTranslator[])
<A,B,C> boolean tryPublishEvents(EventTranslatorThreeArg<E,A,B,C> translator, A[] arg0, B[] arg1, C[] arg2)
translator
- The user specified translation for the eventarg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.arg2
- An array of user supplied arguments, one element per event.publishEvents(com.lmax.disruptor.EventTranslator[])
<A,B,C> boolean tryPublishEvents(EventTranslatorThreeArg<E,A,B,C> translator, int batchStartsAt, int batchSize, A[] arg0, B[] arg1, C[] arg2)
translator
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batch.arg0
- An array of user supplied arguments, one element per event.arg1
- An array of user supplied arguments, one element per event.arg2
- An array of user supplied arguments, one element per event.publishEvents(EventTranslator[])
void publishEvents(EventTranslatorVararg<E> translator, java.lang.Object[]... args)
translator
- The user specified translation for the eventargs
- User supplied arguments, one Object[] per event.publishEvents(com.lmax.disruptor.EventTranslator[])
void publishEvents(EventTranslatorVararg<E> translator, int batchStartsAt, int batchSize, java.lang.Object[]... args)
translator
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batchargs
- User supplied arguments, one Object[] per event.publishEvents(EventTranslator[])
boolean tryPublishEvents(EventTranslatorVararg<E> translator, java.lang.Object[]... args)
translator
- The user specified translation for the eventargs
- User supplied arguments, one Object[] per event.publishEvents(com.lmax.disruptor.EventTranslator[])
boolean tryPublishEvents(EventTranslatorVararg<E> translator, int batchStartsAt, int batchSize, java.lang.Object[]... args)
translator
- The user specified translation for the eventbatchStartsAt
- The first element of the array which is within the batch.batchSize
- The actual size of the batch.args
- User supplied arguments, one Object[] per event.publishEvents(EventTranslator[])