Comments (4)
Hi,
There is no function 'connection', but you can use the third parameter in publish or consume.
\Amqp::consume('some-queue', function ($message, $resolver) { }, config('amqp')['properties']['YOUR_CONNECTION'])
from laravel-amqp.
@bzrncev We are trying to use this approach for publish
, but we're running into issues where the message is sent to both the default queue configured in settings as well as the requested queue sent along with the publish method.
This doesn't work
Amqp::publish('', $data, ['queue' => $queueName]);
This publishes to the default Queue in settings as well as the inserted $queueName
This kinda work's
Amqp::publish('EmailNotification', $data, ['queue' => $queueName]);
This causes knock-on effects with other services having to then be restarted in a particular way, any ideas why this occurs as we just want to use one connection, have a default Queue, but be able to independently publish to a separate Queue without populating to the default Queue within the settings file.
from laravel-amqp.
Right now this library support to define multiple connections but you can only use one. (use in config)
@bzrncev interesting workarround :)
I will not close this issue in favor for discussion on if and how this could be implemented.
Thank you for this suggestion.
from laravel-amqp.
Hi, multiple instances can be placed in dfferent hosts, so need to be separated in https://github.com/bschmitt/laravel-amqp/blob/master/src/Request.php#L33
For first publish make connect , and rewrite host/port does not applied for next calls
like a sollution i sugget make hash from connection params and store/get connection from connections array by it
from laravel-amqp.
Related Issues (20)
- Azure Service Bus - Support HOT 2
- Broken pipe or closed connection HOT 2
- Looking for help HOT 1
- PHP 8 support HOT 2
- AmazonMQ support HOT 1
- Target class [Amqp] does not exist. HOT 1
- Option for 'x-queue-type' HOT 1
- Configure RabbitMQ - Cluster HOT 1
- How to set initial durable for exchange HOT 1
- Non-static method 'consume' should not be called statically HOT 1
- PhpAmqpLib\Exception\AMQPInvalidFrameException: Invalid frame type 21 in /var/www/rabbit/php/app-rabbit/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Connection/AbstractConnection.php:606
- Unit Tests Schema update
- Support to set queue max length
- Wildcard Routing
- How to return the results via APi to the user when listening consume in the laravel controller HOT 1
- Publish multiple messages - Batch publish HOT 10
- [Question]open and close connections or channels every time when publish message HOT 1
- Publisher and Consumer should not be singletons HOT 2
- Consumer priority HOT 1
- Version 2.0.11 doesn't work on PHP bellow 7.4 version HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from laravel-amqp.