Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.event

Interface EventStream

All Superinterfaces:

AutoCloseable, ResultStream<EventWithToken>

All Known Implementing Classes:

BufferedEventStream

public interface EventStream
extends ResultStream<EventWithToken>

Represents a stream of Events. It can be consumed in a blocking and non-blocking approach. Each event is accompanied with a token, which can be used to reopen a new stream at the same position.

Method Summary

Modifier and Type	Method	Description
void	excludePayloadType(String payloadType, String revision)	Instructs AxonServer to not send messages with the given payloadType and revision.

Methods inherited from interface io.axoniq.axonserver.connector.ResultStream

close, getError, isClosed, next, nextIfAvailable, nextIfAvailable, onAvailable, peek

Method Detail

excludePayloadType

void excludePayloadType(String payloadType,
                        String revision)

Instructs AxonServer to not send messages with the given payloadType and revision. This method is in no way a guarantee that these message will no longer be sent at all. Some messages may already have been en-route, and AxonServer may decide to send messages every once in a while as a "beacon" to relay progress of the tracking token. It may choose, however, to omit the actual payload, in that case.

Parameters:

payloadType - the type of payload to exclude from the stream

revision - the revision of the payload to exclude from the stream