Mojo::RabbitMQ::Client::LocalQueue - Callback queue

       Copyright (C) 2015-2017, Sebastian Podjasek and others

       Based on AnyEvent::RabbitMQ::LocalQueue - Copyright (C) 2010 Masahito Ikuta, maintained by
       "bobtfish@bobtfish.net"

       This program is free software, you can redistribute it and/or modify it under the terms of the Artistic
       License version 2.0.

perl v5.34.0                                       2022-05-28             Mojo::RabbitMQ:...ent::LocalQueue(3pm)

       Mojo::RabbitMQ::Client::LocalQueue is a queue for callbacks expecting some content to be received.

       Mojo::RabbitMQ::Client::LocalQueue implements following methods:

   get
         $queue->get(sub { process_message($_[0]) })

       Registers a callback which is executed when new message is pushed to queue.

   push
         $queue->push("Some content");
         $queue->push({objects => 'are also welcome});

       Pushes content to queue and also drains all declared callbacks.

       Mojo::RabbitMQ::Client::LocalQueue - Callback queue

       Mojo::RabbitMQ::Client, Mojo::RabbitMQ::Client::Channel

         use Mojo::RabbitMQ::Client::LocalQueue

         my $queue = Mojo::RabbitMQ::Client::LocalQueue->new();

         # Register callback when content appears
         $queue->get(sub { say "got expected content: " . $_[0] });

         # Push some content to consume
         $queue->push("It Works!");

         # This prints:
         # got expected content: It Works!