org.nuxeo.runtime.pubsub

Interface PubSubProvider

All Known Implementing Classes:

AbstractPubSubProvider, MemPubSubProvider, RedisPubSubProvider, StreamPubSubProvider

public interface PubSubProvider

The SPI of a Publish/Subscribe implementation of the {@link PubSubService).

Since:

9.1

Method Summary

Modifier and Type	Method and Description
void	close() Frees the resources.
void	initialize(Map<String,String> options, Map<String,List<BiConsumer<String,byte[]>>> subscribers) Initializes the resources for this provider and registers the local subscribers map.
void	publish(String topic, byte[] message) Publishes a message to the given topic.

Method Detail

initialize

void initialize(Map<String,String> options,
                Map<String,List<BiConsumer<String,byte[]>>> subscribers)

Initializes the resources for this provider and registers the local subscribers map.

The options taken from the PubSubProviderDescriptor The subscribers map structure is thread-safe. The implementation must not modify the subscribers map in any way.

close

void close()

Frees the resources.

publish

void publish(String topic,
             byte[] message)

Publishes a message to the given topic.

Parameters:

topic - the topic

message - the message