listeners.put(registration.getRegistrationId(), listener);

                    // Start async notification monitoring for this registration
                    startAsyncNotificationMonitoring(registration);

                    log.info("Successfully registered for witness notifications: {}", registration.getRegistrationId());

                    return registration;
                } else {