Package | Description |
---|---|
software.chronicle.datagrid.internal.pubsub | |
software.chronicle.datagrid.pubsub |
This package contains interfaces that are related to the
handling of Subscriptions, Publishing and similar within Chronicle-Datagrid
|
Modifier and Type | Method and Description |
---|---|
SubscriberBuilder<M> |
VanillaSubscriberBuilder.withMessageHandler(@NotNull SubscriberBuilder.MessageConsumer<? super M> handler) |
Constructor and Description |
---|
VanillaSubscriber(@NotNull Runnable endOfSubscriptionHandler,
@NotNull BooleanSupplier tcpBufferFullSupplier,
boolean indexAware,
long index,
M usingMessage,
@NotNull Runnable endOfBootstrapHandler,
SubscriberBuilder.MessageConsumer<? super M> messageHandler) |
Modifier and Type | Method and Description |
---|---|
SubscriberBuilder<M> |
SubscriberBuilder.withMessageHandler(SubscriberBuilder.MessageConsumer<? super M> handler)
Sets the message handler for the subscriber.
|
Copyright © 2021. All rights reserved.