| Mojo::RabbitMQ::Client::LocalQueue(3pm) | User Contributed Perl Documentation | Mojo::RabbitMQ::Client::LocalQueue(3pm) |
Mojo::RabbitMQ::Client::LocalQueue - Callback queue
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!
Mojo::RabbitMQ::Client::LocalQueue is a queue for callbacks expecting some content to be received.
Mojo::RabbitMQ::Client::LocalQueue implements following methods:
$queue->get(sub { process_message($_[0]) })
Registers a callback which is executed when new message is pushed to queue.
$queue->push("Some content");
$queue->push({objects => 'are also welcome});
Pushes content to queue and also drains all declared callbacks.
Mojo::RabbitMQ::Client, Mojo::RabbitMQ::Client::Channel
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.
| 2022-05-28 | perl v5.34.0 |