Class InMemoryBroadcaster
java.lang.Object
org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.InMemoryBroadcaster
- All Implemented Interfaces:
Broadcaster
A mechanism that broadcasts to all registered consumers. It is mainly used for testing.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.Broadcaster
Broadcaster.Listener
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
addListener
(Broadcaster.Listener listener) Add a listener for new messages.void
close()
Close the broadcaster.void
removeListener
(Broadcaster.Listener listener) Remove a listener.void
send
(ByteBuffer buff) Send a message.void
setBroadcastConfig
(DynamicBroadcastConfig broadcastConfig) Change the dynamic broadcasting configuration.
-
Field Details
-
INSTANCE
-
-
Constructor Details
-
InMemoryBroadcaster
public InMemoryBroadcaster()
-
-
Method Details
-
send
Description copied from interface:Broadcaster
Send a message.- Specified by:
send
in interfaceBroadcaster
- Parameters:
buff
- the buffer
-
addListener
Description copied from interface:Broadcaster
Add a listener for new messages.- Specified by:
addListener
in interfaceBroadcaster
- Parameters:
listener
- the listener
-
removeListener
Description copied from interface:Broadcaster
Remove a listener.- Specified by:
removeListener
in interfaceBroadcaster
- Parameters:
listener
- the listener
-
close
public void close()Description copied from interface:Broadcaster
Close the broadcaster.- Specified by:
close
in interfaceBroadcaster
-
setBroadcastConfig
Description copied from interface:Broadcaster
Change the dynamic broadcasting configuration.- Specified by:
setBroadcastConfig
in interfaceBroadcaster
- Parameters:
broadcastConfig
- the new configuration
-