@Override
    public void receive(final BaseMessageQueueCommand command) throws Exception {
        LOGGER.debug("[{}] received message [{}]", ticketRegistryId, command);
        if (command.getPublisherIdentifier().equals(this.ticketRegistryId)) {
            LOGGER.trace("Ignoring inbound command on ticket registry with id [{}]", this.ticketRegistryId);
        } else {
            LOGGER.debug("Accepting message from ticket registry id [{}]. Executing command [{}]", command.getPublisherIdentifier(), command);
            command.withPublisherIdentifier(this.ticketRegistryId).execute(this.ticketRegistry);
        }
        applicationContext.publishEvent(new QueueableTicketRegistryMessageReceivedEvent(this, command));
    }
This is {@link BaseQueueableTicketRegistryMessageReceiver}.

@author Misagh Moayyed
@since 6.5.0
core/cas-server-core-tickets-api/src/main/java/org/apereo/cas/ticket/registry/pubsub/queue/BaseQueueableTicketRegistryMessageReceiver.java