Package org.nuxeo.runtime.pubsub
Class StreamPubSubProvider
java.lang.Object
org.nuxeo.runtime.pubsub.AbstractPubSubProvider
org.nuxeo.runtime.pubsub.StreamPubSubProvider
- All Implemented Interfaces:
PubSubProvider
A Pub/Sub provider based on Nuxeo Stream.
- Since:
- 10.1
-
Nested Class Summary
-
Field Summary
Modifier and TypeFieldDescriptionprotected LogAppender<Record>
protected static final String
protected static final String
protected static final String
static final String
protected static final String
protected static final String
protected String
protected Name
protected String
protected static final Random
protected Thread
Fields inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubProvider
namespace, subscribers
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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
Publishes a message to the given topic.protected void
Methods inherited from class org.nuxeo.runtime.pubsub.AbstractPubSubProvider
localPublish
-
Field Details
-
GROUP_PREFIX
- See Also:
-
LOG_CONFIG_OPT
- See Also:
-
DEFAULT_LOG_CONFIG
- See Also:
-
LOG_NAME_OPT
- See Also:
-
CODEC_OPT
- See Also:
-
DEFAULT_CODEC
- See Also:
-
RANDOM
-
logConfig
-
logName
-
appender
-
thread
-
codec
-
nodeId
-
-
Constructor Details
-
StreamPubSubProvider
public StreamPubSubProvider()
-
-
Method Details
-
initialize
public void initialize(Map<String, String> options, Map<String, List<BiConsumer<String, byte[]>>> subscribers) Description copied from interface:PubSubProvider
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.- Specified by:
initialize
in interfacePubSubProvider
- Overrides:
initialize
in classAbstractPubSubProvider
-
startConsumerThread
protected void startConsumerThread() -
publish
Description copied from interface:PubSubProvider
Publishes a message to the given topic.- Parameters:
topic
- the topicmessage
- the message
-
close
public void close()Description copied from interface:PubSubProvider
Frees the resources.- Specified by:
close
in interfacePubSubProvider
- Overrides:
close
in classAbstractPubSubProvider
-