---
name: "Mojo::RabbitMQ::Client::LocalQueue"
section: "3pm"
platform: "linux"
package: "libmojo-rabbitmq-client-perl"
version: "0.3.1-3"
release: "Debian 13 (Trixie)"
platforms: ["linux"]
url: "https://new.carta.tech/Mojo::RabbitMQ::Client::LocalQueue"
---

# Mojo::RabbitMQ::Client::LocalQueue(3pm)

Callback queue

## NAME

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

## SYNOPSIS

```
  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!
```

## DESCRIPTION

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

## METHODS

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.

## SEE ALSO

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

## COPYRIGHT AND LICENSE

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.