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 InMemoryBroadcaster
INSTANCE
-
Constructor Summary
Constructors Constructor Description InMemoryBroadcaster()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
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 Detail
-
INSTANCE
public static final InMemoryBroadcaster INSTANCE
-
-
Method Detail
-
send
public void send(ByteBuffer buff)
Description copied from interface:Broadcaster
Send a message.- Specified by:
send
in interfaceBroadcaster
- Parameters:
buff
- the buffer
-
addListener
public void addListener(Broadcaster.Listener listener)
Description copied from interface:Broadcaster
Add a listener for new messages.- Specified by:
addListener
in interfaceBroadcaster
- Parameters:
listener
- the listener
-
removeListener
public void removeListener(Broadcaster.Listener listener)
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
public void setBroadcastConfig(DynamicBroadcastConfig broadcastConfig)
Description copied from interface:Broadcaster
Change the dynamic broadcasting configuration.- Specified by:
setBroadcastConfig
in interfaceBroadcaster
- Parameters:
broadcastConfig
- the new configuration
-
-