@Override
    public void handleMessage(final RedisMessagePayload command, final String topic) {
        if (!publisherIdentifier.equals(command.getIdentifier())) {
            LOGGER.trace("Processing Redis message payload [{}] at [{}]", command, publisherIdentifier);
            switch (command.getMessageType()) {
                case ADD, UPDATE -> {
                    val result = getMessageResult(command);
                    ticketCache.put(result.ticket().getId(), result.ticket());
                }
                case DELETE -> {
                    val result = getMessageResult(command);
                    ticketCache.invalidate(result.ticket().getId());
                }
                case DELETE_ALL -> ticketCache.invalidateAll();
            }
        }
    }
This is {@link DefaultRedisTicketRegistryMessageListener}.

@author Misagh Moayyed
@since 7.0.0
support/cas-server-support-redis-ticket-registry/src/main/java/org/apereo/cas/ticket/registry/sub/DefaultRedisTicketRegistryMessageListener.java