org.axonframework.axonserver.connector.event.axon

Class EventBuffer

java.lang.Object

org.axonframework.axonserver.connector.event.axon.EventBuffer

All Implemented Interfaces:

AutoCloseable, BlockingStream<TrackedEventMessage<?>>, TrackingEventStream

public class EventBuffer
extends Object
implements TrackingEventStream

Client-side buffer of messages received from the server. Once consumed from this buffer, the client is notified of a permit being consumed, potentially triggering a permit refresh, if flow control is enabled.

This class is intended for internal use. Be cautious.

Since:

4.0

Author:

Marc Gathier, Allard Buijze

Constructor Summary

Constructors

Constructor and Description
EventBuffer(io.axoniq.axonserver.connector.event.EventStream delegate, EventUpcaster upcasterChain, Serializer serializer, boolean disableEventBlacklisting) Initializes an Event Buffer, passing messages through given upcasterChain and deserializing events using given serializer.

Method Summary

Modifier and Type	Method and Description
void	blacklist(TrackedEventMessage<?> trackedEventMessage) Report the stream that a specific message was ignored by the consumer.
void	close()
boolean	hasNextAvailable(int timeout, TimeUnit timeUnit) Checks whether or not the next message in the stream is available.
TrackedEventMessage<?>	nextAvailable() Returns the next available message in the stream.
Optional<TrackedEventMessage<?>>	peek() Checks whether or not the next message in the stream is immediately available.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.common.stream.BlockingStream

asStream, hasNextAvailable

Constructor Detail

EventBuffer

public EventBuffer(io.axoniq.axonserver.connector.event.EventStream delegate,
                   EventUpcaster upcasterChain,
                   Serializer serializer,
                   boolean disableEventBlacklisting)

Initializes an Event Buffer, passing messages through given upcasterChain and deserializing events using given serializer.

Parameters:

delegate - the EventStream to delegate operations to

upcasterChain - the upcasterChain to translate serialized representations before deserializing

serializer - the serializer capable of deserializing incoming messages

disableEventBlacklisting - specifying whether events should or should not be included in the buffer

Method Detail

blacklist

public void blacklist(TrackedEventMessage<?> trackedEventMessage)

Report the stream that a specific message was ignored by the consumer. Stream implementation can use this information for instance to blacklist similar messages. ----

This implementation removes events from the stream based on the payload type of the given message.

Specified by:

blacklist in interface BlockingStream<TrackedEventMessage<?>>

Parameters:

trackedEventMessage - the message containing the payload to blacklist

peek

public Optional<TrackedEventMessage<?>> peek()

Description copied from interface: BlockingStream

Checks whether or not the next message in the stream is immediately available. If so, an Optional with the next message is returned (without moving the stream pointer), otherwise an empty Optional is returned.

Specified by:

peek in interface BlockingStream<TrackedEventMessage<?>>

Returns:

the next event if immediately available

hasNextAvailable

public boolean hasNextAvailable(int timeout,
                                TimeUnit timeUnit)

Description copied from interface: BlockingStream

Checks whether or not the next message in the stream is available. If a message is available when this method is invoked this method returns immediately. If not, this method will block until a message becomes available, returning true or until the given timeout expires, returning false.

To check if the stream has messages available now, pass a zero timeout.

Specified by:

hasNextAvailable in interface BlockingStream<TrackedEventMessage<?>>

Parameters:

timeout - the maximum number of time units to wait for messages to become available

timeUnit - the time unit for the timeout

Returns:

true if a message is available or becomes available before the given timeout, false otherwise

nextAvailable

public TrackedEventMessage<?> nextAvailable()

Description copied from interface: BlockingStream

Returns the next available message in the stream. Note that this method blocks for as long as there are no available messages in the stream. In case this blocking behavior is not desired use BlockingStream.hasNextAvailable() with or without a timeout to check if the stream has available messages before calling this method.

Specified by:

nextAvailable in interface BlockingStream<TrackedEventMessage<?>>

Returns:

the next available message

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BlockingStream<TrackedEventMessage<?>>