@Test
    void verifyOperation() {
        val receiver = new DefaultQueueableTicketRegistryMessageReceiver(ticketRegistry,
            new PublisherIdentifier(UUID.randomUUID().toString()), applicationContext);
        var ticket = new TicketGrantingTicketImpl("TGT-334455", CoreAuthenticationTestUtils.getAuthentication(),
            NeverExpiresExpirationPolicy.INSTANCE);
        val cmd = new AddTicketMessageQueueCommand(new PublisherIdentifier(), ticket);
        assertDoesNotThrow(() -> receiver.receive(cmd));
        assertNotNull(ticketRegistry.getTicket("TGT-334455"));
    }
This is {@link AMQPTicketRegistryQueueReceiverTests}.

@author Misagh Moayyed
@since 7.0.0
support/cas-server-support-amqp-ticket-registry/src/test/java/org/apereo/cas/ticket/registry/AMQPTicketRegistryQueueReceiverTests.java