consumerListeners.put(notification, listener);
listeners.put(notification, listener);
log.info("Registered listener for notification: " + notification);
consumerListeners.put(notification, listener);
listeners.put(notification, listener);
log.info("Registered listener for notification: " + notification);