Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
public interface ClusterService {
void connect();
<T> void createConsumer(DestinationType type,
String channel,
Class<T> clazz,
Consumer<T> listener);
void broadcast(DestinationType type,
String channel,
Serializable object);
boolean isAppFormerClustered();
void close();
enum DestinationType {
PubSub,
LoadBalancer
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment