@Override
    @SuppressWarnings("FutureReturnValueIgnored")
    public void accept(final BasicAcknowledgeablePubsubMessage message) {
        FunctionUtils.doAndHandle(o -> {
            val subName = message.getProjectSubscriptionName().getSubscription();
            LOGGER.debug("Message received from [{}] subscription: [{}]", subName,
                message.getPubsubMessage().getData().toStringUtf8());
            val command = pubSubMessageConverter.fromPubSubMessage(message.getPubsubMessage(), BaseMessageQueueCommand.class);
            messageQueueTicketRegistryReceiver.receive(command);
            Objects.requireNonNull(message.ack());
        }, (CheckedFunction<Throwable, Object>) e -> {
            LoggingUtils.error(LOGGER, e);
            return message.nack();
        }).accept(message);
    }
This is {@link GoogleCloudTicketRegistryMessageQueueConsumer}.

@author Misagh Moayyed
@since 7.0.0
support/cas-server-support-gcp-pubsub-ticket-registry/src/main/java/org/apereo/cas/ticket/registry/GoogleCloudTicketRegistryMessageQueueConsumer.java