PHPackages                             teclaelvis/rabbitmq-phalcon-adapter - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Utility & Helpers](/categories/utility)
4. /
5. teclaelvis/rabbitmq-phalcon-adapter

ActiveLibrary[Utility & Helpers](/categories/utility)

teclaelvis/rabbitmq-phalcon-adapter
===================================

Adapter package for phalcon project

1.0.4(2y ago)016MITPHPPHP >=7.0

Since Aug 16Pushed 2y ago1 watchersCompare

[ Source](https://github.com/teclaelvis01/phalcon-rabbitmq-adapter)[ Packagist](https://packagist.org/packages/teclaelvis/rabbitmq-phalcon-adapter)[ RSS](/packages/teclaelvis-rabbitmq-phalcon-adapter/feed)WikiDiscussions main Synced today

READMEChangelogDependencies (1)Versions (6)Used By (0)

phalcon-rabbitmq-adapter
========================

[](#phalcon-rabbitmq-adapter)

Adapter for phalcon queue manager

Installation
------------

[](#installation)

```
composer require teclaelvis/rabbitmq-phalcon-adapter:1.0.2
```

Initial configuration
---------------------

[](#initial-configuration)

We need to create a new instance of the `QueueManagerFactory` class and pass the adapter as a parameter.

```
use Pmqelvis\QueueManagerFactory;
use Pmqelvis\RabbitMQAdapter;

require __DIR__ . '/vendor/autoload.php';

// // create a new instance of the rabbitmq adapter

$adapter = new RabbitMQAdapter('localhost', 5672, 'guest', 'guest');
$queueFactory = new QueueManagerFactory($adapter);
```

If you are working with a `ssl connection`, you can use the follow code:

```
$adapter = new RabbitMQAdapter('localhost', 5672, 'guest', 'guest', true);

// continue with the configuration
...
```

in Phalcon we can use the `QueueManagerFactory` class as a service, for example:

```
$di->set('queue', function () use ($config) {
    $ssl = getenv('APPLICATION_ENV') != 'development';
    $adapter = new RabbitMQAdapter(
        $config->rabbitmq->host,
        $config->rabbitmq->port,
        $config->rabbitmq->user,
        $config->rabbitmq->password,
        $ssl
    );
    return new QueueManagerFactory($adapter);
});
```

and then we can use it in our logic to get the queue manager:

```
$queueFactory = $this->di->get('queue');

...
```

Producer configuration
----------------------

[](#producer-configuration)

The example below shows how to configure a producer

```
use Pmqelvis\QueueManagerFactory;
use Pmqelvis\RabbitMQAdapter;

require __DIR__ . '/vendor/autoload.php';

/**
 *  before we need get the QueueManagerFactory instance
 * $queueFactory = new QueueManagerFactory($adapter);
 */
...
...

$queue = $queueFactory->build('test', 'producer', 'test-exchange');
// or
$queue = $queueFactory->buildProducer('test' ,'test-exchange');
$queue->publish('Hello World from my library');

```

Consumer configuration
----------------------

[](#consumer-configuration)

The example below shows how to configure a consumer

```
use Pmqelvis\QueueManagerFactory;
use Pmqelvis\RabbitMQAdapter;

require __DIR__ . '/vendor/autoload.php';

/**
 *  before we need get the QueueManagerFactory instance
 * $queueFactory = new QueueManagerFactory($adapter);
 */
...
...

$queue = $queueFactory->build('test','consumer' ,'test-exchange');
// or
$queue = $queueFactory->buildConsumer('test' ,'test-exchange');

$queue->consume(function ($message) {
    echo $message->body;
    $message->ack();
});

```

The code above will consume the messages from the queue and print the message body and `$message->ack()` will acknowledge the message.

RabbitMQAdapter options
-----------------------

[](#rabbitmqadapter-options)

OptionTypeDefaultDescriptionhoststring''RabbitMQ hostportint5672RabbitMQ portuserstring''RabbitMQ userpasswordstring''RabbitMQ passwordsslboolfalseEnable ssl modeoptionsarray\[\]RabbitMQ connection optionsQueueManagerFactory options
---------------------------

[](#queuemanagerfactory-options)

The `QueueManagerFactory->build()` method accepts the following options:

OptionTypeDefaultDescriptionqueueNamestring''Queue nametypestring''Queue type (producer or consumer)exchangeNamestring''Exchange nameexchangeTypestring''Exchange typeif type is `consumer` the method returns a `ConsumeQueue` instance, if type is `producer` the method returns a `ProducerQueue` instance.

###  Health Score

21

—

LowBetter than 18% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity6

Limited adoption so far

Community7

Small or concentrated contributor base

Maturity43

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~18 days

Total

5

Last Release

981d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/6711316?v=4)[Elvis Reyes](/maintainers/teclaelvis01)[@teclaelvis01](https://github.com/teclaelvis01)

---

Top Contributors

[![teclaelvis01](https://avatars.githubusercontent.com/u/6711316?v=4)](https://github.com/teclaelvis01 "teclaelvis01 (1 commits)")

### Embed Badge

![Health badge](/badges/teclaelvis-rabbitmq-phalcon-adapter/health.svg)

```
[![Health](https://phpackages.com/badges/teclaelvis-rabbitmq-phalcon-adapter/health.svg)](https://phpackages.com/packages/teclaelvis-rabbitmq-phalcon-adapter)
```

###  Alternatives

[bschmitt/laravel-amqp

AMQP wrapper for Laravel and Lumen to publish and consume messages

2822.5M7](/packages/bschmitt-laravel-amqp)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)