PubSubProvider (Nuxeo 2021.70.4 API Documentation)

All Known Implementing Classes:

AbstractPubSubProvider, MemPubSubProvider, RedisPubSubProvider, StreamPubSubProvider
```
public interface PubSubProvider
```
The SPI of a Publish/Subscribe implementation of the PubSubService.

Since:

9.1

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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