public class InMemoryBroadcaster extends java.lang.Object implements Broadcaster
Broadcaster.Listener
Modifier and Type | Field and Description |
---|---|
static InMemoryBroadcaster |
INSTANCE |
Constructor and Description |
---|
InMemoryBroadcaster() |
Modifier and Type | Method and 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(java.nio.ByteBuffer buff)
Send a message.
|
void |
setBroadcastConfig(DynamicBroadcastConfig broadcastConfig)
Change the dynamic broadcasting configuration.
|
public static final InMemoryBroadcaster INSTANCE
public void send(java.nio.ByteBuffer buff)
Broadcaster
send
in interface Broadcaster
buff
- the bufferpublic void addListener(Broadcaster.Listener listener)
Broadcaster
addListener
in interface Broadcaster
listener
- the listenerpublic void removeListener(Broadcaster.Listener listener)
Broadcaster
removeListener
in interface Broadcaster
listener
- the listenerpublic void close()
Broadcaster
close
in interface Broadcaster
public void setBroadcastConfig(DynamicBroadcastConfig broadcastConfig)
Broadcaster
setBroadcastConfig
in interface Broadcaster
broadcastConfig
- the new configurationCopyright © 2012–2022 The Apache Software Foundation. All rights reserved.