zserio.runtime.pubsub

Interface PubsubInterface

public interface PubsubInterface

Interface for Pub/Sub client backends.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PubsubInterface.Callback Callback passed to the subscribe method and called when a message with subscribed topic arrives.

Method Summary

Modifier and Type	Method and Description
void	publish(java.lang.String topic, byte[] data, java.lang.Object context) Publishes given data as a specified topic.
int	subscribe(java.lang.String topic, PubsubInterface.Callback callback, java.lang.Object context) Subscribes a topic.
void	unsubscribe(int subscriptionId) Unsubscribes the subscription with the given ID.

Method Detail

publish

void publish(java.lang.String topic,
             byte[] data,
             java.lang.Object context)

Publishes given data as a specified topic.

Parameters:

topic - Topic definition.

data - Data to publish.

context - Context specific for a particular Pub/Sub implementation.

subscribe

int subscribe(java.lang.String topic,
              PubsubInterface.Callback callback,
              java.lang.Object context)

Subscribes a topic.

Parameters:

topic - Topic definition to subscribe. Note that the definition format depends on the particular Pub/Sub backend implementation and therefore e.g. wildcards can be used only if they are supported by Pub/Sub backend.

callback - Callback to be called when a message with the specified topic arrives.

context - Context specific for a particular Pub/Sub implementation.

Returns:

Subscription ID.

unsubscribe

void unsubscribe(int subscriptionId)

Unsubscribes the subscription with the given ID.

Parameters:

subscriptionId - ID of the subscription to be unsubscribed.