Package org.nuxeo.runtime.pubsub

Interface PubSubProvider

All Known Implementing Classes:
AbstractPubSubProvider, MemPubSubProvider, StreamPubSubProvider
public interface PubSubProvider
The SPI of a Publish/Subscribe implementation of the PubSubService.
Since:
9.1

  • Method Summary

    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 Details

    • 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