Skip to content

Instantly share code, notes, and snippets.

@vmarcinko

vmarcinko/QueueConsumer.java

Created May 31, 2019 08:33
Show Gist options
  • Save vmarcinko/21f53b06f34f84d9c8f5d5b4f92be564 to your computer and use it in GitHub Desktop.
Save vmarcinko/21f53b06f34f84d9c8f5d5b4f92be564 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
QueueConsumer.java
@EventListener(OnGrantedEvent.class)
public void onGrantedEvent() {
logger.info("Granted leadership");
startProcessingTask();
}
@EventListener(OnRevokedEvent.class)
public void onRevokedEvent() {
logger.info("Revoked leadership");
stopProcessingTask();
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment