public interface PubSubProvider
Modifier and Type | Method and Description |
---|---|
void |
close()
Frees the resources.
|
void |
initialize(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.
|
void initialize(Map<String,List<BiConsumer<String,byte[]>>> subscribers)
The subscribers map structure is thread-safe. The implementation must not modify the subscribers map in any way.
void close()
Copyright © 2017 Nuxeo. All rights reserved.