Hello Friends i want to know about the expriation Property in RabbitMQ. And what happens if I do not set this property. I am new in rabbitMQ please help me. AMQP.BasicProperties properties = new AMQP.BasicProperties(); properties.setExpiration("43200
I am trying to publish a message to rabbitmq. this works in production environment env with the same code so I suspect this is a configuration issue. rbqueue = RabbitMQClientQueue('cn-dip-v3', host = rabbitmq_config['host'], username = rabbitmq_confi
I am using Eclipse, Tomcat and Rabbit MQ. I want to be able to consume messages of a queue as soon as they hit the queue. I have managed to do this using a Java class in Eclipse (see below), but have not been able to get this working when deploying t
I create RabbitMQ listener: $connection = new AMQPConnection( $AMQP_config['server'], $AMQP_config['port'], $AMQP_config['user'], $AMQP_config['password'], $AMQP_config['virtual_host'] ); $channel = $connection->channel(); $channel->basic_qos( null,
I am using RabbitMQ to communicate work between a master and a number of worker nodes. The master kicks things off, seeding a value in the queue. Workers read the queue, do stuff, and usually write more work items to the same queue for other workers.
I am new to RabbitMQ, so please excuse me for trivial questions: 1) In case of clustering in RabbitMQ, if a node fails, load shift to another node (without stopping the other nodes). Similarly, we can also add new fresh nodes to the existing cluster
What library should I use etc? I've used it with node.js but I can't work out how to use it with mono (C#) on linux. --------------Solutions------------- After several hours I got a basic sample working. Firstly, download rabbitmq-dotnet-client-3.4.3
The below code shows how I am setting header and message type to AMQP message. MessageProperties properties = new MessageProperties(); properties.setHeader("KEY", "HOUSE"); properties.setContentType(MessageProperties.CONTENT_TYPE_JSON); Message messa
Is there a way to dispatch RabbitMQ messages (once received by your application) using the Guava EventBus? So I am talking about the consumer-side of the story, not about RabbitMQ producers.
My platform runs through a lot of tasks (several thousand per day). Some of the longer tasks them keep failing with the following error: Traceback (most recent call last): File "/app/.heroku/python/lib/python2.7/site-packages/billiard/pool.py", line
The base problem is as follows: Two nodes communicating over a single socket; Request-reply pattern; Both nodes are client and server, i.e. node A makes requests to node B and node B makes requests to node A; This would be easily solved with two sock
I am using Celery with https://github.com/gjedeer/celery-php for PHP. Reliability is important for our project. So I want to be sure that all tasks that scheduled are executed even Rabbitmq crash. So I scheduled one task, then I stopped Rabbitmq and
I'm using 2 servers to open 200 channels each, with 100 consumers each. Each consumers sends and receives, hence the 2 to 1 ratio of channels to consumers (this is all based in Java, Spring, etc..). What I'm seeing is a dramatic decrease in performan
I knew Spring AMQP support failover well, but my question is, how can I load-balanced the connections between consumer side and cluster nodes of RabbitMQ broker? Any response will be greatly appreciated. Regards. --------------Solutions-------------
I'm planning on using rabbitmq to achieve push notification in my web app. Each user will have a queue. I want to prevent unauthorised users from subscribing to other people's queues. Can this be achieved using an auth token that a user must provide?
I don't know whether it is a bug or a configuration problem. Goal: debug/modify Celery tasks without manually restarting worker each time I make a small change So I've configured Celery+RabbitMQ. Everything works. Added --autoreload option to the cel
I've two instances of my Wordpress project running on a box (separate code base & db). Both of which performs background tasks when triggered by rabbitmq and update data on their respective db. For this I've created two exchanges in rabbitmq (E-1
Here's what I know so far (please correct me): In the RabbitMQ Java client, operations on a channel throw IOException when there is a general network failure (malformed data from broker, authentication failures, missed heartbeats). Operations on a ch
Here is what my application does 1) Client App Send request message with correlationId on REQUEST_QUEUE_1 and waits for the response message on RESPONSE_QUEUE_1 using correlationId 2) Server App receives message from REQUEST_QUEUE_1 3) Server App pro