PHPackages                             dada-amater/nette-rabbitmq - 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. [Queues & Workers](/categories/queues)
4. /
5. dada-amater/nette-rabbitmq

ActiveLibrary[Queues & Workers](/categories/queues)

dada-amater/nette-rabbitmq
==========================

v2.1.0(7y ago)033MITPHPPHP >=7.1

Since May 6Pushed 7y agoCompare

[ Source](https://github.com/dada-amater/nette-rabbitmq)[ Packagist](https://packagist.org/packages/dada-amater/nette-rabbitmq)[ Docs](https://github.com/gameeapp/nette-rabbitmq)[ RSS](/packages/dada-amater-nette-rabbitmq/feed)WikiDiscussions master Synced 2w ago

READMEChangelog (1)Dependencies (5)Versions (26)Used By (0)

[![Latest Stable Version](https://camo.githubusercontent.com/1db503045c52a17fe8f07d58c5d29c7eb3acb081bafe010f154f228a1ea996be/68747470733a2f2f706f7365722e707567782e6f72672f67616d65652f6e657474652d7261626269746d712f762f737461626c65)](https://packagist.org/packages/gamee/nette-rabbitmq)[![License](https://camo.githubusercontent.com/2224e00ebf3890742a4e5a9beb7f879f7bb6440acb6fee444c9fb9147d5a2a95/68747470733a2f2f706f7365722e707567782e6f72672f67616d65652f6e657474652d7261626269746d712f6c6963656e7365)](https://packagist.org/packages/gamee/nette-rabbitmq)[![Total Downloads](https://camo.githubusercontent.com/80bcc965e934ccf04b071345a2b23831e7ff30102dcd82689a93a8ed41906d13/68747470733a2f2f706f7365722e707567782e6f72672f67616d65652f6e657474652d7261626269746d712f646f776e6c6f616473)](https://packagist.org/packages/gamee/nette-rabbitmq)

Nette RabbitMQ
==============

[](#nette-rabbitmq)

Nette extension for RabbitMQ (using composer package [jakubkulhan/bunny](https://github.com/jakubkulhan/bunny))

Example setup
-------------

[](#example-setup)

### Downloading composer package

[](#downloading-composer-package)

```
composer require gamee/nette-rabbitmq

```

### Extension registration

[](#extension-registration)

config.neon:

```
extensions:
	rabbitmq: Gamee\RabbitMQ\DI\RabbitMQExtension

```

### Example configuration

[](#example-configuration)

```
services:
	- TestConsumer

rabbitmq:
	connections:
		default:
			user: guest
			password: guest
			host: localhost
			port: 5672

	queues:
		testQueue:
			connection: default

	exchanges:
		testExchange:
			connection: default
			type: fanout
			queueBindings:
				testQueue:
					routingKey: testRoutingKey

	producers:
		testProducer:
			exchange: testExchange
			# queue: testQueue
			contentType: application/json
			deliveryMode: 2 # Producer::DELIVERY_MODE_PERSISTENT

	consumers:
		testConsumer:
			queue: testQueue
			callback: [@TestConsumer, consume]
			qos:
				prefetchSize: 0
				prefetchCount: 5

```

### Publishing messages

[](#publishing-messages)

Note: Queue will be created automatically after publishing first message.

services.neon:

```
services:
	- TestQueue(@Gamee\RabbitMQ\Client::getProducer(testProducer))

```

TestQueue.php:

```