@Override
    public void publishMessageToQueue(final BaseMessageQueueCommand cmd) {
        FunctionUtils.doAndHandle(__ -> {
            if (cmd instanceof final TicketAwareQueueCommand taqm) {
                val topic = ticketCatalog.find(taqm.getTicketId()).getProperties().getStorageName();
                publishMessage(cmd, topic);
            } else {
                for (val ticketDefinition : ticketCatalog.findAll()) {
                    val topic = ticketDefinition.getProperties().getStorageName();
                    publishMessage(cmd, topic);
                }
            }
        });
    }
This is {@link KafkaTicketRegistryPublisher}.

@author Misagh Moayyed
@since 7.2.0
support/cas-server-support-kafka-ticket-registry/src/main/java/org/apereo/cas/ticket/registry/publisher/KafkaTicketRegistryPublisher.java