rabbitmq

Can somebody tell steps to use OpenAMQ C lib to connect to rabbitMQ server.

I am trying to use RabbitMQ in my C/C++ app, so far I have realized that using OpenAMQ's C Client is the only option, but OpenAMQ is AMQP 0-9 something and RabbitMQ server is 0-8. I have read somewhere that people were successful to do minor changes to RabbitMQ to make it work with OpenAMQ C lib.. can somebody experienced with this throw...

how to build rabbitmq server on windows.

I am trying to build rabbitmq server on windows but no luck. Rabbitmq website doesn't help much. Can someone help. ...

how to build rabbitmq C client lib on windows

Can somebody throw some light on how to build rabbitmq C client lib on windows? ...

Messaging pattern question

Process A is calculating values for objects a1, a2, a3 etc. and is sending results to the middleware queue (RabbitMQ). Consumers read the queue and process these results further. Periodically process A has to send a snapshot of these values, so consumers could do some other calculations. Values for these objects might change independent...

Does RabbitMq do round-robin from the exchange to the queues

Hi, I am currently evaluating message queue systems and RabbitMq seems like a good candidate, so I'm digging a little more into it. To give a little context I'm looking to have something like one exchange load balancing the message publishing to multiple queues. I don't want to replicate the messages, so a fanout exchange is not an opt...

Flushing a queue using AMQP, Rabbit, and Ruby

I'm developing a system in Ruby that is going to make use of RabbitMQ to send messages to a queue as it does some work. I am using: Ruby 1.9.1 Stable RabbitMQ 1.7.2 AMQP gem v0.6.7 (http://github.com/tmm1/amqp) Most of the examples I have seen on this gem have their publish calls in an EM.add_periodic_timer block. This doesn't work...

ZooKeeper and RabbitMQ/Qpid together - overkill or a good combination?

Greetings, I'm evaluating some components for a multi-data center distributed system. We're going to be using message queues (via either RabbitMQ or Qpid) so agents can make asynchronous requests to other agents without worrying about addressing, routing, load balancing or retransmission. In many cases, the agents will be interacting w...

What does the following line of a bash script do?

Usually work in Windows, but trying to setup RabbitMQ on my Mac. Can someone let me know what the line below does? [ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && [ "x" != "x$NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=${NODE_IP_ADDRESS} Specifically, I'm curious about the [ "x" = "x$RAB..."] syntax. ...

Open Source Queuing Solutions for peek, mark as done and then remove

I am looking at open source queuing platforms that allow me do the following: I have multiple producers, multiple consumers putting data into a queue in a multithreaded environment with the specific use case: I want the ability for consumers to be able do the following Peek at a message from the queue(which should mark as the message ...

RabbitMQ serializing messages from queue with multiple consumers

Hi there, I'm having a problem where I have a queue set up in shared mode and multiple consumers bound to it. The issue is that it appears that rabbitmq is serializing the messages, that is, only one consumer at a time is able to run. I need this to be parallel, however, I can't seem to figure out how. Each consumer is running in its...

Wait for a single RabbitMQ message with a timeout

I'd like to send a message to a RabbitMQ server and then wait for a reply message (on a "reply-to" queue). Of course, I don't want to wait forever in case the application processing these messages is down - there needs to be a timeout. It sounds like a very basic task, yet I can't find a way to do this. I've now run into this problem wit...

AMQP subscriber inside Rails app

Is it possible to start an AMQP subscriber with my Rails app? Possibly through an initializer or something. I'd like to have it running at the same time that can also interact with Rails models. Below is a pseudo-code example of what I mean. queue.subscribe do |msg,body| Foo.create(....) end ...

Is there an API for listing queues and exchanges on RabbitMQ?

I've looked quite a bit, but I haven't been able to find a good programmatic way to list the queues on a RabbitMQ server. This is important because I need to clean up my queues and exchanges when I'm done with them. I don't always have a good "done" event that can be used to trigger a cleanup, so I'd like to do it with more of a garbag...

Own params to PeriodicTask run() method in Celery

Hello to all! I am writing a small Django application and I should be able to create for each model object its periodical task which will be executed with a certain interval. I'm use for this a Celery application, but i can't understand one thing: class ProcessQueryTask(PeriodicTask): run_every = timedelta(minutes=1) def run(self...

What is an MQ and why do I want to use it?

Hi folks, On my team at work, we use the IBM MQ technology a lot for cross-application communication. I've seen lately on Hacker News and other places about other MQ technologies like RabbitMQ. I have a basic understanding of what it is (a commonly checked area to put and get messages), but what I want to know what exactly is it good at...

RabbitMQ as a proxy between a data store and a producer ?

I have some code that produces lots of data that should be stored in the database. The problem is that the database can't keep with the data that it gets produced. So I am wondering whether some kind of queuing mechanism would help in this situation - I am thinking in particular at RabiitMQ and whether is feasible to have the data stored...

MongoDB Schema Design - Real-time Chat

I'm starting a project which I think will be particularly suited to MongoDB due to the speed and scalability it affords. The module I'm currently interested in is to do with real-time chat. If I was to do this in a traditional RDBMS I'd split it out into: Channel (A channel has many users) User (A user has one channel but many messag...

Which one should I choose AMQP or XMPP for real-time browser-based game?

Hi, I'm choosing between AMQP (RabbitMQ) vs XMPP (eJabberd) for my browser-based flash-free javascript powered real-time turn-based game. I don't know much about AMQP and XMPP protocol. I would like to use PHP for user-authorization and some data store-retrieve with MySQL. As far as I found out, RabbitMQ has PHP clients but eJabberd not....

RabbitMQ - Not able to get sets of messages in the same order

I am using Rabbit MQ in C#. This is my scenario A separate process publishes messages to the queue Client has to read set of N messages from queue Process the N messages Acknowledge the N messages Under the same channel, I receive the messages and then process them and then acknowledge them. The server process keeps publishing messag...

Storing task state between multiple django processes

I am building a logging-bridge between rabbitmq messages and Django application to store background task state in the database for further investigation/review, also to make it possible to re-publish tasks via the Django admin interface. I guess it's nothing fancy, just a standard Producer-Consumer pattern. Web application publishes to...