software.chronicle.datagrid.internal.pubsub

Class RemoteTopicPublisher<T,M>

java.lang.Object

net.openhft.chronicle.core.io.SimpleCloseable

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

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

All Implemented Interfaces:

Closeable, AutoCloseable, net.openhft.chronicle.core.io.ManagedCloseable, net.openhft.chronicle.core.io.QueryCloseable, net.openhft.chronicle.core.io.ReferenceOwner, TopicPublisher<T,M>, KeyedView

Direct Known Subclasses:

RemoteQueueView

public class RemoteTopicPublisher<T,M>
extends net.openhft.chronicle.network.connection.AbstractStatelessClient<TopicPublisherHandler.EventId>
implements TopicPublisher<T,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

Modifier	Constructor and Description
	RemoteTopicPublisher(@NotNull RequestContext context, @NotNull Asset asset)
protected	RemoteTopicPublisher(@NotNull RequestContext context, @NotNull Asset asset, String view)

Method Summary

Modifier and Type	Method and Description
void	publish(T topic, M message) Publish the given message to the provided topic.
@NotNull Publisher<M>	publisher(T topic) Creates and returns a new Publisher for the provided topic.
void	registerSubscriber(T topic, @NotNull Subscriber<? super M> subscriber) Registers and associates the provided subscriber with the provided topic.
void	registerTopicSubscriber(@NotNull TopicSubscriber<? super T,? super M> topicSubscriber) Add a subscription to this group.
void	unregisterSubscriber(T topic, @NotNull Subscriber<? super M> subscriber) Unregisters and disassociates the provided subscriber from the provided topic.
void	unregisterTopicSubscriber(@NotNull TopicSubscriber<? super T,? super M> topicSubscriber) Unregister a TopicSubscriber

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 software.chronicle.datagrid.pubsub.TopicPublisher

registerTopicSubscriber

Methods inherited from interface software.chronicle.datagrid.tree.KeyedView

keyedView

Methods inherited from interface java.io.Closeable

close

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

referenceId, referenceName, temporary

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

createdHere, throwExceptionIfClosed, warnAndCloseIfNotClosed

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

closeQuietly, closeQuietly

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

isClosing

Constructor Detail

RemoteTopicPublisher

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

RemoteTopicPublisher

protected RemoteTopicPublisher(@NotNull
                               @NotNull RequestContext context,
                               @NotNull
                               @NotNull Asset asset,
                               String view)

Method Detail

publish

public void publish(@NotNull
                    T topic,
                    @NotNull
                    M message)

Description copied from interface: TopicPublisher

Publish the given message to the provided topic.

Specified by:

publish in interface TopicPublisher<T,M>

Parameters:

topic - to publish to

message - to publish.

registerTopicSubscriber

public void registerTopicSubscriber(@NotNull
                                    @NotNull TopicSubscriber<? super T,? super M> topicSubscriber)

Description copied from interface: TopicPublisher

Add a subscription to this group.

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

This method is asynchronous and the provided subscriber will be eligible for receiving events as some later unspecified time.

Specified by:

registerTopicSubscriber in interface TopicPublisher<T,M>

Parameters:

topicSubscriber - to listen to events.

unregisterTopicSubscriber

public void unregisterTopicSubscriber(@NotNull
                                      @NotNull TopicSubscriber<? super T,? super M> topicSubscriber)

Description copied from interface: TopicPublisher

Unregister a TopicSubscriber

This method is asynchronous and the provided subscriber will be prevented from receiving events as some later unspecified time.

Specified by:

unregisterTopicSubscriber in interface TopicPublisher<T,M>

Parameters:

topicSubscriber - to unregister

publisher

@NotNull
public @NotNull Publisher<M> publisher(@NotNull
                                                T topic)

Description copied from interface: TopicPublisher

Creates and returns a new Publisher for the provided topic.

Specified by:

publisher in interface TopicPublisher<T,M>

Parameters:

topic - to create a Publisher for

Returns:

a new Publisher for the provided topic

registerSubscriber

public void registerSubscriber(@NotNull
                               T topic,
                               @NotNull
                               @NotNull Subscriber<? super M> subscriber)

Description copied from interface: TopicPublisher

Registers and associates the provided subscriber with the provided topic.

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

This method is asynchronous and the provided subscriber will be eligible for receiving events as some later unspecified time.

Specified by:

registerSubscriber in interface TopicPublisher<T,M>

Parameters:

topic - to associate with the given subscriber

subscriber - to register

unregisterSubscriber

public void unregisterSubscriber(@NotNull
                                 T topic,
                                 @NotNull
                                 @NotNull Subscriber<? super M> subscriber)

Description copied from interface: TopicPublisher

Unregisters and disassociates the provided subscriber from the provided topic.

This method is asynchronous and the provided subscriber will be prevented from receiving events as some later unspecified time.

Specified by:

unregisterSubscriber in interface TopicPublisher<T,M>

Parameters:

topic - to disassociates from the given subscriber

subscriber - to unregister