Interface BackendMessagingService

public interface BackendMessagingService

Service for proxy-to-backend communication.

Enables bidirectional messaging between the proxy and backend servers running the Bridge plugin.

Method Summary

Modifier and Type	Method	Description
void	broadcastToBackends(String channel, byte[] data)	Broadcasts a message to all backend servers.
void	registerHandler(String channel, BiConsumer<String,byte[]> handler)	Registers a handler for messages from backends.
boolean	sendToBackend(String serverName, String channel, byte[] data)	Sends a message to a specific backend server.
void	unregisterHandler(String channel)	Unregisters a handler for messages from backends.

Method Details

sendToBackend

boolean sendToBackend(@Nonnull
 String serverName,
 @Nonnull
 String channel,
 @Nonnull
 byte[] data)

Sends a message to a specific backend server.

Parameters:

serverName - the name of the backend server

channel - the channel to send on

data - the message data

Returns:

true if the message was queued for delivery

broadcastToBackends

void broadcastToBackends(@Nonnull
 String channel,
 @Nonnull
 byte[] data)

Broadcasts a message to all backend servers.

Parameters:

channel - the channel to send on

data - the message data

registerHandler

void registerHandler(@Nonnull
 String channel,
 @Nonnull
 BiConsumer<String,byte[]> handler)

Registers a handler for messages from backends.

Parameters:

channel - the channel to listen on

handler - the handler that receives (serverName, data)

unregisterHandler

void unregisterHandler(@Nonnull
 String channel)

Unregisters a handler for messages from backends.

Parameters:

channel - the channel to stop listening on