Interface ConsumerBuilder.SubscriptionListener

Enclosing interface:

ConsumerBuilder

public static interface ConsumerBuilder.SubscriptionListener

Callback to modify a consumer subscription before the link creation.

This allows looking up the last processed offset for a stream consumer and attaching to this offset.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ConsumerBuilder.SubscriptionListener.Context	Subscription context.

Method Summary

Modifier and Type	Method	Description
void	preSubscribe(ConsumerBuilder.SubscriptionListener.Context context)	Pre-subscription callback.

Method Details

preSubscribe

void preSubscribe(ConsumerBuilder.SubscriptionListener.Context context)

Pre-subscription callback.

It is called before the link is created but also every time it recovers, e.g. after a connection failure.

Configuration set with ConsumerBuilder.SubscriptionListener.Context.streamOptions() overrides the one set with ConsumerBuilder.stream().

Parameters:

context - subscription context