Class InMemoryBroadcaster
- java.lang.Object
-
- org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.InMemoryBroadcaster
-
- All Implemented Interfaces:
Broadcaster
public class InMemoryBroadcaster extends Object implements 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 Modifier and Type Field Description static InMemoryBroadcasterINSTANCE
-
Constructor Summary
Constructors Constructor Description InMemoryBroadcaster()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddListener(Broadcaster.Listener listener)Add a listener for new messages.voidclose()Close the broadcaster.voidremoveListener(Broadcaster.Listener listener)Remove a listener.voidsend(ByteBuffer buff)Send a message.voidsetBroadcastConfig(DynamicBroadcastConfig broadcastConfig)Change the dynamic broadcasting configuration.
-
-
-
Field Detail
-
INSTANCE
public static final InMemoryBroadcaster INSTANCE
-
-
Method Detail
-
send
public void send(ByteBuffer buff)
Description copied from interface:BroadcasterSend a message.- Specified by:
sendin interfaceBroadcaster- Parameters:
buff- the buffer
-
addListener
public void addListener(Broadcaster.Listener listener)
Description copied from interface:BroadcasterAdd a listener for new messages.- Specified by:
addListenerin interfaceBroadcaster- Parameters:
listener- the listener
-
removeListener
public void removeListener(Broadcaster.Listener listener)
Description copied from interface:BroadcasterRemove a listener.- Specified by:
removeListenerin interfaceBroadcaster- Parameters:
listener- the listener
-
close
public void close()
Description copied from interface:BroadcasterClose the broadcaster.- Specified by:
closein interfaceBroadcaster
-
setBroadcastConfig
public void setBroadcastConfig(DynamicBroadcastConfig broadcastConfig)
Description copied from interface:BroadcasterChange the dynamic broadcasting configuration.- Specified by:
setBroadcastConfigin interfaceBroadcaster- Parameters:
broadcastConfig- the new configuration
-
-