Skip to content

Instantly share code, notes, and snippets.

@ederign

ederign/createWs.java

Last active Sep 28, 2018
Embed
What would you like to do?
public void createWatchServiceJMS(String fileSystemName) {
clusterService.createConsumer(
ClusterService.DestinationType.PubSub,
getChannelName(fileSystemName),
WatchEventsWrapper.class,
(we) -> {
if (!we.getNodeId().equals(nodeId)) {
eventsPublisher.accept(we);
}
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment