software.chronicle.datagrid.internal.pubsub

Class RemotePublisher<T,M>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

net.openhft.chronicle.network.connection.AbstractStatelessClient<PublisherHandler.EventId>

software.chronicle.datagrid.internal.pubsub.RemotePublisher<T,M>

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, Publisher<M>

public final class RemotePublisher<T,M>
extends net.openhft.chronicle.network.connection.AbstractStatelessClient<PublisherHandler.EventId>
implements Publisher<M>

Field Summary

Fields inherited from class net.openhft.chronicle.network.connection.AbstractStatelessClient

csp, hub

Fields inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

INIT

Constructor Summary

Constructors

Constructor and Description
RemotePublisher(@NotNull RequestContext context, @NotNull Asset asset)

Method Summary

Modifier and Type	Method and Description
void	publish(M event) Publish an event
void	registerSubscriber(boolean bootstrap, int throttlePeriodMs, @NotNull Subscriber<? super M> subscriber, boolean endSubscriptionAfterBootstrap) Registers the provided subscriber as a subscription to this specific topic.
int	subscriberCount()
void	unregisterSubscriber(Subscriber<? super M> subscriber) Unregisters the provided subscriber.

Methods inherited from class net.openhft.chronicle.network.connection.AbstractStatelessClient

attempt, performClose, proxyReturnBoolean, proxyReturnBooleanWithArgs, proxyReturnBooleanWithSequence, proxyReturnByte, proxyReturnByte, proxyReturnInt, proxyReturnInt, proxyReturnLong, proxyReturnLongWithArgs, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnTypedObject, proxyReturnUint16, proxyReturnVoid, proxyReturnVoid, proxyReturnWireConsumer, proxyReturnWireConsumerInOut, proxyReturnWireTypedObject, readBoolean, readInt, sendBytes, sendEvent, sendEventAsync, toParameters, toParameters, writeMetaDataForKnownTID

Methods inherited from class net.openhft.chronicle.core.io.SimpleCloseable

close, isClosed

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface net.openhft.chronicle.core.io.Closeable

closeQuietly, closeQuietly, notifyClosing

Methods inherited from interface net.openhft.chronicle.core.io.QueryCloseable

isClosing, throwExceptionIfClosed

Methods inherited from interface net.openhft.chronicle.core.io.ReferenceOwner

referenceId, referenceName, temporary

Constructor Detail

RemotePublisher

public RemotePublisher(@NotNull
                       @NotNull RequestContext context,
                       @NotNull
                       @NotNull Asset asset)

Method Detail

publish

public void publish(M event)

Description copied from interface: Publisher

Publish an event

Specified by:

publish in interface Publisher<M>

Parameters:

event - to publish

registerSubscriber

public void registerSubscriber(boolean bootstrap,
                               int throttlePeriodMs,
                               @NotNull
                               @NotNull Subscriber<? super M> subscriber,
                               boolean endSubscriptionAfterBootstrap)

Description copied from interface: Publisher

Registers the provided subscriber as a subscription to this specific topic.

Any given instance of a subscriber must at most be registered once with a DataGrid instance at any given time.

Specified by:

registerSubscriber in interface Publisher<M>

Parameters:

bootstrap - to bootstrap

throttlePeriodMs - 0 for no throttling, otherwise the period of throttling in milliseconds

subscriber - to register

endSubscriptionAfterBootstrap - if the subscriptions should be ended automatically after bootstrap

unregisterSubscriber

public void unregisterSubscriber(Subscriber<? super M> subscriber)

Description copied from interface: Publisher

Unregisters the provided subscriber.

Specified by:

unregisterSubscriber in interface Publisher<M>

Parameters:

subscriber - to remove

subscriberCount

public int subscriberCount()

Specified by:

subscriberCount in interface Publisher<M>

Returns:

the number of subscriptions.