FAQ Database Discussion Community


RabbitMQ: Change the default port of the server

rabbitmq
Hi I'm fairly new to the rabbitMQ and i'm using c# on Windows and i need to change the port to communicate with the server. I've searched a lot in the rabbitMQ documentation but it can be very confused. Can someone teach me the steps to change the port? Initially...

Select nth to nth row while table still have values unselected with python and pyodbc

python-2.7,sql-server-2005,rabbitmq,pyodbc,python-pika
I have a table with 10,000 rows and I want to select the first 1000 rows and then select again and this time, the next set of rows, which is 1001-2001. I am using the BETWEEN clause in order to select the range of values. I can also increment the...

Using ZeroMQ or other MQ to send objects [closed]

json,node.js,rabbitmq,zeromq,mqtt
I am wondering how I can send objects via a message queue. My question is two-fold: (1) are there any message queues like ZeroMQ that support Java objects and JSON out of the box? (2) are there any message queues that don't require you to serialize/deserialize objects on both ends?...

RabbitMQ: server side Calculation for every received Message

rabbitmq,message-queue,spring-amqp,spring-rabbit
I'm working with RabbitMQ and I want on the server side to conduct a calculation each time an Exchange receives a message. I have a queue for ratings and when too many bad reviews (let's say more than ten) received, then a consumer should be notified. What options are there...

Spring Integration RabbitMQ ConnectionFactory gracefully stop retry if RabbitMQ is down

spring,rabbitmq,spring-integration
I have a Configured Spring integration with RabbitMQ as message broker. I have a scenario where the application may be deployed in production with RabbitMQ down.When it happens the application continuosly tries to reconnect org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer run WARNING: Consumer raised exception, processing can restart if the connection factory supports it. Exception...

PHPUnit RabbitMQ: write test for create connection function

php,phpunit,rabbitmq
I'm facing the following problem. I've wrote a function that create a connection object (AMQPConnection) given the required parameters. Now I want to write the corresponding unit test. I just don't know how to do it without having the RabbitMQ broker running. Here is the function in question: public function...

Message queues and application structure

service,rabbitmq,message-queue,soa,amqp
I've read the documentation and I'm pretty sure I understand the concept of the different components present in an AMQP based message queue. However, I am having a hard time mapping that to an actual service oriented implementation. Could someone give a sort of "textbook" example of two services communicating...

RabbitMQ returns same message again and again

c#,rabbitmq,message-queue
I try to unit test a rather basic scenario - worker queue with 2 workers and 1 publisher scenario, but it keeps returning the same message over and over again from the queue. The following code in the test just puts the 1 to 100 messages to the queue and...

Trying to set expiration to messages (individual), still 'ready' in queue?

rabbitmq
I am trying to publish RabbitMQ messages to a queue (which by default has no TTL set), where each message published can specify an individual TTL. I believe that I am doing this as follows in C#: public override bool PostData(object data, int? ttl = null) { try { _channel.QueueDeclare(_queue,...

Can I use Pivotal's Redis and RabbitMQ for Cloud Foundry on Pivotal Web Services

redis,rabbitmq,cloudfoundry
Currently, the only RabbitMQ service on PWS looks kinda iffy. I was wondering If I could use Pivotals solutions https://network.pivotal.io/products/p-redis https://network.pivotal.io/products/pivotal-rabbitmq-service On Pivotal's own http://run.pivotal.io , or If to run theseI have to have an on premises Cloud Foundry. Can I run these on Pivotal Web Services? ...

pika.exceptions.ProbableAuthenticationError when trying to send message to remote queue

python,rabbitmq,pika
I'm trying to run RabbitMQ Python tutorial but with sender on virtualbox host machine and receiver and queue on virtualbox guest machine. So I modified mentioned send.py code by only replacing localhost with 192.168.1.5. When I run it, i receive following error: ... File "/home/damian/.virtualenvs/kivy_1.9/local/lib/python2.7/site-packages/pika/adapters/base_connection.py", line 153, in _check_state_on_disconnect raise...

RabbitMQ message conversion issue

rabbitmq,spring-amqp
I am facing issue while converting message into Object format after consuming message at consumer end. I couldn't able to convert back to Student object. FYI, at producer end am using spring RabbitTemplate and at consumer end plain java api(Note#: I cannot use spring at consumer end) Issue: org.codehaus.jackson.map.JsonMappingException: Can...

Error 'invalid parameter include_src' when provisionning RabbitMQ with Puppet on Vagrant

rabbitmq,vagrant,puppet,git-submodules
I am trying to install the RabbitMQ module on my virtual machine. I used : git submodule add https://github.com/puppetlabs/puppetlabs-rabbitmq.git and I installed every dependecy I could find the same way (which are, like listed in this answer : stdlib, epel, staging and erlang). I reduced my manifest to the bare...

How to consume one message?

java,rabbitmq
With example in rabbitmq, consumer get all messages from queue at one time. How to consume one message and exit? QueueingConsumer consumer = new QueueingConsumer(channel); channel.basicConsume(QUEUE_NAME, true, consumer); while (true) { QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String message = new String(delivery.getBody()); System.out.println(" [x] Received '" + message + "'"); } ...

“Channel shutdown: connection error”

amazon-ec2,rabbitmq,load-balancing,spring-amqp
I've set up on AWS a RabbitMQ cluster with two nodes, and enabled HA as described here. Then, I set up an Elastic Load Balancer mapping 5672 to the instances' 5672 port, with a periodic health check to the instances' 15672 port (the HTTP management port). Then, I started two...

Django Celery cannot connect to remote RabbitMQ on EC2

django,amazon-ec2,rabbitmq,celery
I created a rabbitmq cluster on two instances on EC2. My django app uses celery for async tasks which in turn uses RabbitMQ for message queue. Whenever I start celery with the command: python manage.py celery worker --loglevel=INFO OR python manage.py celeryd --loglevel=INFO I keep getting following error message related...

Initialize RabbitMQ Exchange with arguments using Powershell

powershell,rabbitmq,rabbitmq-exchange
I am trying to initialize an Exchange using Powershell. I need to define a DLQ, so I am trying the following syntax: $exchangeURL = $apiURL + "/exchanges/myHost/myExchange"; $body = "{""type"":""fanout"",""auto_delete"":false,""durable"":true,""arguments"":[{""x-dead-letter-exchange"": ""myExchangeDLQ""}]}" $response = Invoke-WebRequest -Uri $exchangeURL -Headers $headers -Method Put -ContentType "application/json" -Body $body I get this error: Invoke-WebRequest :...

RabbitMQ into AWS Redshift using NodeJS

javascript,node.js,amazon-web-services,rabbitmq,amazon-redshift
I have a RabbitMQ consumer listening to a queue in RabbitMQ and receiving event data in NodeJS. I would like to have the consumer send each data event to AWS Redishit (possibly using their JavaScript SDK), but I cannot find any examples of how to do this, nor can I...

Why is there a delay in Spring AMQP Message dispatching from a filled Queue?

java,spring,rabbitmq,spring-amqp
I am using Spring AMQP in my message driven application. I noticed that there is a nearly constant delay of around 300ms between invocations of my message listener, even though I am sure that the queue is filled with messages. The logfile below shows this delay between BlockingQueueConsumer.nextMessage and BlockingQueueConsumer.handle...

Gathering distributed data into central database

wcf,rabbitmq,msmq,zeromq,dds
I was assigned to update existing system of gathering data coming from points of sale and inserting it into central database. The one that is working now is based on FTP/SFTP transmission, where the information is sent once a day, usually at night. Unfortunately, because of unstable connection links (low...

Reprocess failed RabbitMQ messages manually

spring,rabbitmq,spring-amqp
I have a dead-letter queue which stores failed messages. Is there have a way to manually trigger a listener to process the messages in the dead-letter queue? I’m using Spring AMQP.

Whys is Celery worker using /root as home directory?

python,rabbitmq,celery,supervisord
We are using Celery and RabbitMQ to process jobs. They are both being run by Supervisor so that they can be alive. Some jobs expect a file in the home directory of a user A. So we run the celery worker as user A in supervisor. But when the job...

How does RabbitMQ WCF tolerate service failures?

c#,.net,wcf,rabbitmq
Suppose I have a WCF service that I bind/expose using the RabbitMQ WCF interface/binding. If I have clients that make calls to my service through the RabbitMQ WCF interface then what would happen if let's say the service goes down? Would RabbitMQ just store the requests to that service and...

RabbitMqBundle connection not enstablished

symfony2,rabbitmq
I installed https://github.com/videlalvaro/RabbitMqBundle in my sf2 project, with this configuration: old_sound_rabbit_mq: connections: default: host: 'localhost' port: 5672 user: 'guest' password: 'guest' vhost: '/' lazy: false producers: processing: connection: default exchange_options: { name: 'processing', type: direct } class: Assignment\Bundle\MainBundle\RabbitMq\Producer\ProcessingProducer Service configuration: processing_producer: class: Assignment\Bundle\MainBundle\RabbitMq\Producer\ProcessingProducer arguments: [] Producer...

How to consume just one message from rabbit mq on nodejs

node.js,rabbitmq
Im using amqp.node library to integrate rabbitmq into my system. But in consumer i want to process just one message at the time, then acknowledge the message then consume the next message from the queue. The current code is: // Consumer open.then(function(conn) { var ok = conn.createChannel(); ok = ok.then(function(ch)...

Losing mirrored queues

rabbitmq
RabbitMQ cluster of 3 nodes that has mirror-all HA policies defined. Cluster has faulted and partitioned into independent nodes. Cluster was repaired, and as a result of failure some of the queues were lost. Is this a possible scenario even though HA policy to mirror all queues is in place?

Task progress is not updated latest status on Celery+RabbitMQ

python,rabbitmq,celery
I implemented progress feedback of long task with custom states on Celery + RabbitMQ result backend. But the caller can't retrive the latest progess status as I expected. In following code, result.info['step'] always return 0, and then the task will be finished with "result=42". # tasks.py -- celery worker from...

Spring RabbitMQ tutorial results in Connection Refused error

java,spring,rabbitmq,spring-amqp
I'm an experienced Java programmer and am trying out Spring Rabbit MQ for the first time. I followed the messaging-rabbitMQ tutorial exactly using Maven. http://spring.io/guides/gs/messaging-rabbitmq/ I am running on CentOS as a user account. When I ran the application at the very end of the tutorial with java -jar target/gs-messaging-rabbitmq-0.1.0.jar,...

Camel RabbitMQ Request Response Pattern Example

design-patterns,request,apache-camel,rabbitmq,response
I'm looking for a sample code wich use the Camel RabbitMQ Request Response Pattern. My use case : - A request message is depose in a RabbitMQ Queue - A Camel route consume the message, invoke an external Web Service, and reply the response based on the reply-to properties of...

RabbitMQ receive messages sequentially after ACK

node.js,rabbitmq,amqp,messages
I am looking to get the following pattern to receive messages "sequentially" with RabbitMQ. I use Node.js framework as consumer. Lets say there are 3 messages in the queue, I need this pattern: receive msg#1 -> process -> send ACK -> receive msg#2 -> process -> send ACK receive msg#3...

SimpleMessageListenerContainer ChannelTransacted and MaxConcurrentConsumers

transactions,rabbitmq,amqp,spring-amqp
I'm trying to configure a SimpleMessageListenerContainer from Spring AMQP with channeled transactions to dynamically add consumers on demand. The problem is, I don't see consumers being added dynamically when I have a channeled transaction. To be clear, this doesn't dynamically add consumers under load: container.setMaxConcurrentConsumers(5); container.setChannelTransacted(true); container.setTransactionManager(rabbitTransactionManager); But this does:...

How RabbitMQ connection works between 2+ endpoints?

java,c#,python,rabbitmq
I've looked at the tutorial for RabbitMQ RPC. The client and server basicly do the same. Assumed i've 2 or more computer who want to consume from a queue. I wonder how the know from each other if i just pass the own network hostname/ip to the ConnectionFactory. Does this...

erl with centos “Failed to create main carrier for ll_alloc”

linux,centos,rabbitmq,vps,erl
i am having a centos vps. i have installed erlang by the command rpm -Uvh erlang-17.4-1.el6.x86_64.rpm Now whenever i try to run my rabbitmq-server. or i just issue erl command then i get this error. Failed to create main carrier for ll_alloc Aborted is it some memory issue erlang is...

Django Celery Directory Structure and Layout

python,django,rabbitmq,celery,django-celery
I have a django project using the following directory structure. project/ account/ models.py views.py blog/ models.py views.py mediakit/ models.py views.py reports/ celery.py <-- new models.py tasks.py <-- new views.py settings/ __init__.py <-- project settings file system/ cron/ mongodb/ redis/ manage.py Here's the contents of celery.py derived from the celery tutorial...

Dead-lettering dead-lettered messages in RabbitMQ

rabbitmq,dead-letter
Here's what we have here: Topic Exchange DLE, which is intended to be a Dead-Letter Exchange Topic Exchange E, which is the "main" Exchange Several Queues (EQ1, ..., EQn) bound to E (and initialized with x-dead-letter-exchange = DLE), each with own Routing Key. These queues are the ones being consumed...

Play Framework send message via rabbit mq

scala,rabbitmq,playframework-2.2
Does anybody out there using rabbitmq with Play Framework? I have an AI written in Scala using Play Framework. And I have a mean stack, which handles a nosql database. I'd like to send json messages via rabbitmq to that AI. I already got things going with nodejs and rabbitmq,...

RabbitMQ channel best practice

java,tomcat,rabbitmq,channel,spring-rabbit
I am creating a REST api to send message to RabbitMQ and was trying to understand what are the best practice for creating/closing channels. I am using RabbitMQ Java client api. Currently I have a class RabbitMQPublisherConnection where I spring inject RabbitMQ connection. This class is then spring injected to...

Spring amqp not publishing message to the queue but to Exchange

spring,rabbitmq,spring-boot,spring-amqp,spring-rabbit
I am trying to test & benchmark spring-amqp for RabbitMQ with multiple queues so I was creating rabbit template for each queue and using it to send message. The message sent is successful and I can see a message published in the exchange but I don't see anything in the...

RabbitMQ topic binding, do they have a priority?

rabbitmq
In RabbitMQ Fifth Tutorial (for Ruby, but they're the same for all languages), they mention: We created three bindings: Q1 is bound with binding key "*.orange.*" and Q2 with "*.*.rabbit" and "lazy.#" and then: "lazy.pink.rabbit" will be delivered to the second queue only once, even though it matches two bindings....

Best Practice for setting up RabbitMQ cluster in production with NServiceBus

rabbitmq,nservicebus,rabbitmq-exchange
Currently we have 2 load balanced web servers. We are just starting to expose some functionality over NSB. If I create two "app" servers would I create a cluster between all 4 servers? Or should I create 2 clusters? i.e. Cluster1: Web Server A, App Server A Cluster2: Web Server...

rabbitmq(pika) throws an exception when use RPC

python,rabbitmq,rpc,producer-consumer,pika
RabbiMQ RPC throws an exception when i build publisher-consumer pattern. This is my code: sender.py # coding:utf-8 import pika import uuid class MessageSender(object): def __init__(self): self.connention = pika.BlockingConnection( pika.ConnectionParameters(host='localhost')) self.channel = self.connention.channel() result = self.channel.queue_declare(exclusive=True) self.callback_queue = result.method.queue print 'MessageSender callback queue is ------', self.callback_queue self.channel.basic_consume( self.on_response, no_ack=True,...

Do to block consumer on empty queue

php,rabbitmq,amqp,consumer
Specifics I have consumer, written in PHP, which tries to consume messages. My goal is simple as - if there are no messages in the queue, release the execution and continue, considering there was "no data retrieved". Current thoughts I tried AMQP_NOWAIT flag, like: $flag = AMQP_NOWAIT; $this->queue->consume($callbackFunction, $flag, $this->consumerTag);...

MassTransit - Where to store state between retries

rabbitmq,masstransit
I am using MassTransit (and RabbitMq for the queues) to do some sequential processing of each message that involves a number of steps. I want to be able to store a "processing-state" info somewhere in IConsumeContext<MyMessage> that will be related to each particular message, so that e.g., if a message...

EasyNetQ.ManagementClient for to get msg rate per queue

c#,rabbitmq,easynetq
I'm using EasyNetQ.ManagementClient nuget package for getting some stats on the rabbit. In the Web Management you can see the msg rates per queue But I can't get the same rates just for queues in code when using EasyNetQ.ManagementClient, is it possible to get them? var managementClient = new ManagementClient("http://ipadress",...

Node MQTT.js problems with RabbitMQ

node.js,rabbitmq,mqtt
Can't connect to my RabbitMQ server (MQTT adapter enabled) with node.js mqtt client. Is there a compatibility issue between these? I can connect to the queue using bluerhinos MQTT PHP library, so I know the queue names and host name etc are correct, and that messages are being retrieved correctly...

Rabbit MQ What data to send as a Message

java,rabbitmq,esb
i am going to integrate some applications using RabbitMQ. Now i am facing the design issue. Right now i am having one application producing message and one application consuming it (in future more are possible). Both applications have access to some database. Application A is some kind of registration application...

Rabbitmq / PhpAmqpLib PRECONDITION_FAILED - unknown delivery tag

php,symfony2,rabbitmq,amqp
I know that this question is asked more then once but this once is different. I am using the PhpAmqpLib (version 2.5.1) and RabbitMq (version 3.5.1). I created a Symfony bundle that is able to crawl a website and uses a worker queue to run it in multiple threads. What...

MessageHandler for Julia

c,rabbitmq,activemq,julia-lang,message-handlers
I'm looking for a message handler for Julia, because I want to integrate it in a bigger project with other services. The other services are using RabbitMQ, but I have not been able to find any RabbitMQ or ActiveMQ drivers for Julia. Is anyone aware of a message handler driver...

What's wrong with RabbitMQ in Spring Boot

java,maven,rabbitmq,spring-boot
I am trying to run the sample project from Create a RabbitMQ message receiver.But it's throwing exception java.lang.IllegalArgumentException: Attribute 'exclude' is of type [Class[]], but [String[]] was expected. Cause: at org.springframework.core.annotation.AnnotationAttributes.doGet(AnnotationAttributes.java:117) at org.springframework.core.annotation.AnnotationAttributes.getStringArray(AnnotationAttributes.java:70) at...

RabbitMQ and channels Java thread safety

java,multithreading,rabbitmq
in this guide https://www.rabbitmq.com/api-guide.html RabbitMQ guys state: Channels and Concurrency Considerations (Thread Safety) Channel instances must not be shared between threads. Applications should prefer using a Channel per thread instead of sharing the same Channel across multiple threads. While some operations on channels are safe to invoke concurrently, some are...

Celery/RabbitMQ unacked messages blocking queue?

python,rabbitmq,celery,urllib2
I have invoked a task that fetches some information remotely with urllib2 a few thousand times. The tasks are scheduled with a random eta (within a week) so they all don't hit the server at the same time. Sometimes I get a 404, sometimes not. I am handling the error...

how to clear a queue routingkey binding in rabbitmq (.net)

c#,.net,rabbitmq,message-queue
How can I clear all routing key binding from a queue in rabbitmq? The QueueUnbind method need the routingkey parameter, but I just want to clear all bindings....

spring rabbit is it required to declare queue for send a message

java,spring,rabbitmq
I need to send a message to a queue with name "myQueue" to the MQ server. Should I declare all required beans in spring, like Queue and etc for it. It seems to me useless because I only need to send to server, and receive if possible, I`m not going...

spring-rabbit client using lots of cpu

java,rabbitmq,spring-amqp,spring-rabbit
I am running a spring-boot application in ec2 on a c3.large machine. It initializes a spring-rabbit client, which starts up its own thread. After profiling my application using YourKit, I see that a lot of time is spent inside the rabbit client thread, inside: com.rabbitmq.client.impl.AMQConnection$MainLoop.run() specifically down in java.io.DataStream.readUnsignedByte() To...

RabbitMQ on Windows - enable the Firehose on service restart

rabbitmq,rabbitmqctl
Is there a way to setup RabbitMQ in a way that the Firehose is autamatically enabled (for a single virtual host preferably) after a Windows or RabbitMQ service restart?

How to stop Rabbitmq Consumer after processing 10 messages?

rabbitmq,php-amqplib
I was running consumer from crontab and it processing all the messages one by one, Is there any way to consume only 10 or 20 messages and then stop to consumer. So next time cron will call to consumer and same process will happen again....

Is there a way to specify a different Error Queue when using EasyNetQ.Hosepipe?

c#,.net,rabbitmq,message-queue,easynetq
I recently posted the following question... Custom Error Queue Name when using EasyNetQ for RabbitMQ? ... and was provided with a solution on how to use different, application specific Error Queue names when using EasyNetQ, rather than having all unhandled exceptions go into the default error queue (EasyNetQ_Default_Error_Queue). What I'd...

How to get properly all queue messages from RabbitMQ in Spring?

spring,rabbitmq,mqtt,stomp,spring-websocket
I am using Spring, Spring-Websocket, STOMP for my application, and RabbitMQ as broker. I need to log all messages going through RabbitMQ to Postgresql tables. I know that I can write @MessageMapping in Spring and log there, but my problem is that some clients talk to RabbitMQ directly through MQTT...

Extract headers from message using spring-rabbit without declaring queues in annotation

java,rabbitmq,messaging,spring-rabbit,spring-rabbitmq
Now I can do like this: @RabbitListener(queues = {ENTITY_KEY + "-snapshots", ENTITY_KEY + "-updates"}) public void handleMessage(ProviderOddsOffer offer, @Header("update_type") Long updateType) { ... } Can I do it without declaring queues in annotation itself?...

Rabbitmq hello world connection only works on localhost (python)

python,rabbitmq
I have this simple code taken from the rabbitmq tutorial (http://www.rabbitmq.com/tutorials/tutorial-one-python.html) import pika import logging logging.basicConfig() connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost')) channel = connection.channel() channel.queue_declare(queue='hello') print ' [*] Waiting for messages. To exit press CTRL+C' def callback(ch, method, properties, body): print " [x] Received %r" % (body,) channel.basic_consume(callback, queue='hello', no_ack=True) channel.start_consuming()...

RabbitMQ RPC accros multiple rabbitMQ instances

rabbitmq,spring-amqp,federation,rabbitmq-shovel
I have three clients each with their own RabbitMQ instances and I have an application (let's call it appA) that has its own RabbitMQ instance, the three client applications (app1, app2, app3) wants to make use of a service on appA. The service on appA requires RPC communication, app1, app2...

MassTransit 3.0.1 (prerelease) with RabbitMQ fails to process messages using same configuration/setup as 2.9.9

c#,rabbitmq,masstransit
Here's the MT 2.9.9 version that works: public sealed class DiagnosticConsumer : Consumes<DiagnosticMessage>.All { public void Consume(DiagnosticMessage message) { Console.WriteLine("Got {0} with timestamp {1}", message.Message, message.Timestamp); } } Bus setup: var bus = ServiceBusFactory.New(sbc => { sbc.UseRabbitMq(r => r.ConfigureHost(new Uri("rabbitmq://localhost/notifications/tests"), c => { c.SetUsername("test_user"); c.SetPassword("testuser123"); })); sbc.ReceiveFrom("rabbitmq://localhost/notifications/tests");...

How do I configure rabbitmq queue via puppet

rabbitmq,puppet,rabbitmq-exchange
I'm trying to install rabbitmq via puppet. I'm using the puppetlabs-rabbitmq module. It also has section to configure queues and exchanges, which are Native Types. I can't figure out how to use these native types. My code for rabbitmq installation: class rabbitmq-concrete{ $tools = ["vim-enhanced","mc"] package { $tools: ensure =>...

RabbitMQ: How to prevent QueueDeclare to automatically generate a new Queue

c#,rabbitmq,message-queue
With RabbitMQ I am doing something similar to this: channel.QueueDeclare(QueueName, true, false, false, null); By default RabbitMQ creates a new queue if none of the existing matches the name provided. I would like to have an exception thrown instead. Is that possible? Thanks...

Celery worker will not pick up a new task after the current one is finished

python,django,rabbitmq,celery
I have three tasks: @app.task(name='timey') def timey(): print "timey" while True: pass return 1 @app.task(name='endtimey') def endtimey(): for i in range(10): print "ENDTIMEY", time() sleep(3) return 1 @app.task(name='nexttask') def nexttask(n): print "NEXT TASK" return 1 If the only thing I do is chain endtimey and nexttask together - chain(endtimey.s() |...

Spring Autowire inside of SpringBootApplication class is behaving differently between nearly identical applications

spring,rabbitmq,spring-boot
I have two SpringBoot applications where I'm using RabbitMQ to communicate messages across a queue. One application is built to send messages and the other listens for the sent messages. Each application consists of an @SpringBootApplication file which has one @Autowired dependency at the attribute level (one application has the...

Masstransit temporary queue

c#,rabbitmq,masstransit
I'm developing client application which use masstransit and rabbitmq. On application start I'm creating new queue with unique name for communication with server applications via masstransit(request/response model). On application closing I should delete this queue, but if client application crushes queue will present on rabbitmq. Is it possible to create...

RabbitMQ Queued messages keep increasing

python,rabbitmq,celery
We have a Windows based Celery/RabbitMQ server that executes long-running python tasks out-of-process for our web application. What this does, for example, is take a CSV file and process each line. For every line it books one or more records in our database. This seems to work fine, I can...

How can i stop my SimpleMessageListenerContainer from getting stuck in shutdown/restart loop?

java,spring,rabbitmq,amqp
I have a SimpleMessageListenerContainer which I am using with RabbitMQ and Java. In most instances I am having no problems, however on some occassions when a message is sent to a queue there appears to be an exception which causes the SMLC to get in a loop trying to shutdown...

RabbitMQ, NodeJS, Express internal server errror

node.js,rabbitmq
Anyone know why this is not working. These pieces of code have been taken from examples. I have no stack trace to show you as my NodeJS debugging skills are currently rubbish. Any help would be much appreciated. Note I do have the RabbitMQ server running and a receiver has...

RabbitMQ and ActiveMQ running on the same machine

rabbitmq,activemq
For testing purposes I need ActiveMQ and RabbitMQ running on the same Windows machine. I have both installed, but I can't run them together: I need to stop one service in order to have the other one running. This is the error I get trying to start RabbitMQ having ActiveMQ...

Queue routing to default exchange even when DLX argument set

node.js,rabbitmq,node-amqp
Really confused here... Have a queue with dead letter props set... var amqp = require('amqp'), conn = amqp.createConnection(); var key = "batch.delay." + (new Date().getTime()).toString(); var options = { arguments: { "x-dead-letter-exchange": "immediate", "x-message-ttl": 30000, "x-expires": 40000, "x-dead-letter-routing-key": 'hit.api' } }; conn.queue(key, options); and defining the actual exchange... conn.exchange('immediate', {...

Spring-AMQP Transactionnal publish without Exception

java,spring,rabbitmq,spring-amqp,spring-rabbit
I am trying to use a Transactionnal RabbitMQ channel with Spring-AMQP but I want to actually swallow Exceptions to log them and being able to recover them. Using channelTransacted=true forces the Channel to also join the current transactionManager (Hibernate in my case) and that results in the commit Exception being...

Is it possible to connect MQTT client to RabbitMQ having Node.JS as intermediate gateway?

node.js,rabbitmq,mqtt
This is what I want to do: I want to connect my client using MQTT to Node.JS server and then from there(Node.JS Server) I want to handle all pub/sub. When client publishes any message, it will go to Node.JS server and from there it will be sent to RabbitMQ and...

Not able to build rabbitmq-c for iOS application

ios,objective-c,c,xcode,rabbitmq
I am trying to use RabbitMq in an iOS app. As recommended, I am using this Objective-C wrapper, which stipulates : There is nothing to build. Just include the source and header files into your Xcode project and link it againt librabbitmq-c. However, I have been unable to build the...

how to pass a value from a recursive function into an array in a different method

php,arrays,codeigniter,recursion,rabbitmq
I'm struggling to pass a value from a recursive function into an array in a different method. I have written my recursive function below. function get_parent_basket_id($parent_id) { if($parent_id==NULL){ return false; } $baskets = $this->Model_cds_clients->clients($parent_id)->result(); if(count($baskets)==0){ return false; } foreach ($baskets as $row) { if($row->parent_id==0){ return $row->id; } else { $this->get_parent_basket_id($row->parent_id);...

Ack or Nack in rabbitMQ

php,rabbitmq,amqp,php-amqp
I'm using rabbitMQ, I take every message from queue with basic_get without automatically acking procedure, which means the message remain in queue until I ack or nack the message. Sometimes I've messages that can't be processed because of some exception thrown, which prevented them from being fully processed. Question is...

How to call another method when we are using RabbitMQ Publish and Subscriber pattern?

rabbitmq,publish-subscribe
I have a program where i need to process transactions from two sources, first one is from RabbitMQ and another from Database. For first one, I am using RabbitMQ publish and subscriber pattern so that whenever if any transactions comes into queue then this method can process that transaction, but...

Is there a size limit on a RabbitMQ message header?

rabbitmq,spring-amqp
I plan on storing stacktraces in the RabbitMQ message header. Do message headers have a size limit?

Queues with random GUID being generated in RabbitMQ server

rabbitmq,celery
Queues with a random GUID are being generated comming from exchange 'celeryresults'. This happened when I fired a task from the shell, using delay method, but I forgot to enter parameters of my original function in the arguments list of delay. Error displayed in terminal where I run the celery...

Implementing a job queue with rabbitmq

php,rabbitmq,job-queue
I have built a rabbitmq wrapper which publishes messages to consumers and this is working well. Can I also build a work queue (like gearman) in rabbitmq which can distribute long running tasks to consumers and the consumers, in turn, notify the publisher with the results. I guess this would...

spring boot rabbitmq MappingJackson2MessageConverter custom object conversion

java,json,rabbitmq,spring-boot,spring-amqp
I'm trying to create a simple spring boot app with spring boot that "produce" messages to a rabbitmq exchange/queue and another sample spring boot app that "consume" these messages. So I have two apps (or microservices if you wish). 1) "producer" microservice 2) "consumer" microservice The "producer" has 2 domain...

How to setup RabbitMQ for different environments?

rabbitmq
We have been working on a application using RabbitMQ which is installed in local development server. Now we want to move this application to integration and QA environments then the problem is do we need to setup RabbitMQ in different environments or is there any ways to have one central...

celery worker not working though rabbitmq has queue buildup

python,python-2.7,rabbitmq,celery,digital-ocean
I am getting in touch with celery and I wrote a task by following Tutorial but somehow worker not getting up and I get following log After entering command: celery worker -A tasks -l debug I get a log: Running a worker with superuser privileges when the worker accepts messages...

Rabbitmq 3.5.1 slow publish rate

php,rabbitmq
I've setup rabbitmq with default config both on my pc and server and noticed a strange behavior on rabbitmq publish rate, no matter how fast i publish messages to rabbitmq the publish rate stays at 12/s both on my pc and the server while these two systems are quite different...

Spring-amqp two queues with different TTL

rabbitmq,spring-amqp
In our application, we use RabbitMQ and spring-amqp(1.4.3.RELEASE). We have two Queues there. Both of them have TTL(60000 and 100000) configured. When we start the application, it gives the following errors: [pool-4-thread-1] ERROR org.springframework.amqp.rabbit.connection.CachingConnectionFactory - Channel shutdown: channel error; protocol method: #method(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'queue1'...

Access objects within a Consumer

c#,rabbitmq,masstransit
I am working on a project that consumes messages using MassTransit and RabbitMQ in C# I'm building a prototype and right now the consumer project is a console application. Within the Main program.cs class, I connect to the bus and subscribe to accept messages from the publisher like this: var...

How to configure simple RabbitMQ message producer with Spring Integration

rabbitmq,spring-integration,amqp
I'd like to configure a simple RabbitMQ message producer using Spring Integration constructs. The requirement is very basic: just a simple fire-and-forget, sending an event message to a queue, no response required. I've configured the connection factory, RabbitTemplate and outbound channel adapter (see below), but missing the last piece: the...

RabbitMQ LVC is giving all messages

c#,rabbitmq
So i installed the RabbitMQ plugin https://github.com/rabbitmq/rabbitmq-lvc-plugin and i'm using in c#, sending the same value through the exchange and everytime that the subscriber is up he receives all the messages, and if i keep sending the same message my consumer will get, i don't know if this is how...

Custom Error Queue Name when using EasyNetQ for RabbitMQ?

c#,.net,rabbitmq,message-queue,easynetq
Rather than having my unhandled exceptions go into EasyNetQ_Default_Error_Queue I wondered if there is a way that I can explicitly state the name of an Error Queue that should be used for a given application, so errors don't ALL end up in this one EasyNetQ_Default_Error_Queue? I can see how to...

Installing rabbitmq on centos7

rabbitmq
Ièm trying to install rabbotmq on centos7. Following the official instructions, I ran: sudo yum install rabbitmq-server-3.5.1-1.noarch.rpm and I get this error: Loaded plugins: fastestmirror Examining rabbitmq-server-3.5.1-1.noarch.rpm: rabbitmq-server-3.5.1-1.noarch Marking rabbitmq-server-3.5.1-1.noarch.rpm to be installed Resolving Dependencies --> Running transaction check ---> Package rabbitmq-server.noarch 0:3.5.1-1 will be installed --> Processing Dependency: erlang...

How can I get the status of a rabbitmq-shovel by the http api

rabbitmq,rabbitmqctl,rabbitmq-shovel
Using "rabbitmqctl eval 'rabbit_shovel_status:status().'" I can get the shovels status in my rabbitmq server. I activated the modules 'rabbitmq_shovel' and 'rabbitmq_shovel_management'. I created some dynamic shovels with the HTTP API, the problem I have is that, I want to be able to GET the status of the shovels using the...

RabbitMQ - basic reject with metadata

rabbitmq,amqp
I've got a consumer that rejects messages and knows exactly why those messages were rejected. She'd like to provide the "why" as well as the "what" to the producer when rejecting a message. What's a good queue architecture for nack'ing messages but also sending back metadata describing why the message...

WebRequest timeout from Windows Service and Server

c#,rabbitmq
Currently we have a Windows Service which processes messages from RabbitMQ. It does this by using a web request to a URi. We then read the response and then proceed from there if it is successful. Process Messages Method //Deserialze the response PMResponse res = (PMResponse)ser.ReadObject(GetResponse(addr + paramArgs)); GetResponse Method...

Improve performance of RabbitMQ publish (RabbitMQ C# client)

c#,rabbitmq,publish,amqp
I'm using the following code to publish messages to a RabbitMQ queue: ConnectionFactory factory = new ConnectionFactory { HostName = hostName, Port = port, UserName = userName, Password = password, VirtualHost = "/", Protocol = Protocols.DefaultProtocol }; connection = factory.CreateConnection(); channel = connection.CreateModel(); channel.QueueDeclare(queue, true, false, false, null); foreach (string...

RabbitMQ with Unity IOC Container in .NET

.net,rabbitmq,unity
I am using Unity App Block as my IOC container for my service layer of a WCF project. This works quite well using the Unity.WCF library to plug it into each WCF service. I recently introduced RabbitMQ into my service layer and I am currently using the "using" blocks to...

Purpose of declaring an exchange on a RabbitMQ consumer

java,rabbitmq,rabbitmq-exchange
I have a Java consumer application that connects to a RabbitMQ (3.2.4) non-deletable fanout exchange called "my_exhange_foo": Connection connection = connectionFactory.newConnection(consumerPool); Channel channel = connection.createChannel(); channel.exchangeDeclare("my_exhange_foo", "fanout"); // is this necessary? String queueName = channel.queueDeclare().getQueue(); channel.queueBind(queueName, "my_exhange_foo", ""); QueueingConsumer consumer = new QueueingConsumer(channel); channel.basicConsume(queueName, true, consumer); The client...

rabbitMQ persistency when consummers die

queue,rabbitmq,persistence
I would like consummers to subscribe to events, in case one of them die, I'd like the messages to be persisted for this consummer, so it gets them once it is online. If the producer creates N queues, 1 per consummer, then it works. But the producer shall not not...

How can PhantomJS communicate through RabbitMQ?

rabbitmq,phantomjs
I am new to RabbitMQ. I work with PhantomJS and use JavaScript to do stuff. Now, I need to send some of my results to the RabbitMQ in order to read them using another script. I mean, I want PhantomJS to communicate with RabbitMQ. To send some messages and to...

How can I get a stack trace from my own code on errors in RabbitMQ subscription handler?

node.js,rabbitmq,node-amqp
If an error is thrown inside a node.js function that handles incoming messages from RabbitMQ, the stack trace is from the node-amqp code instead of the one in my handler (and the error is commonly "cannot call method indexOf of undefined", regardless of what the actual error is). Is there...