Questions tagged [bunny]

Bunny is an easy to use RabbitMQ Ruby client.

Bunny is an easy to use RabbitMQ Ruby client.

RabbitMQ messaging enables cross-platform software applications to connect and scale. Applications can connect to each other, as components of a larger application, or to user devices and data. Messaging is asynchronous, decoupling applications by separating sending and receiving data.

Sources:

91 questions
21
votes
1 answer

RabbitMQ change queue parameters on a production system

I'm using RabbitMQ as a message queue in a service-oriented architecture, where many separate web services publish messages bound for RabbitMQ queues. Those queues are in turn subscribed to by various consumers, which perform background work; a…
DevinR
  • 383
  • 2
  • 3
  • 10
14
votes
1 answer

Setting a long timeout for RabbitMQ ack message

I was wondering if this is possible. I want to pull a task from a queue and have some work that could potentially take anywhere from 3 seconds or longer (possibly) minutes before an ack is sent back to RabbitMQ notifying that the work has been…
Wanged
  • 259
  • 1
  • 3
  • 8
11
votes
0 answers

Integration Testing with Bunny Gem and RabbitMQ

I'm using the Bunny Gem with RabbitMQ on a project so that multiple applications can do RPC calls. I'm struggling to figure out a way to do integration testing with these calls. Sure I can mock and object and stub a method to return some fake data,…
GreenEggs
  • 527
  • 6
  • 17
9
votes
0 answers

Rails + Puma + Bunny - Timeout error

When set rabbitmq connection in initializer #config/initializers/rabbitmq.rb $rabbitmq_connection = Bunni.new "amqp://#{user}:#{pass}@#{host}:#{port}#{vhost}" $rabbitmq_connection.start $rabbitmq_channel = $rabbitmq_connection.create_channel than…
Sergii Brytiuk
  • 345
  • 1
  • 12
6
votes
3 answers

Getting a queue without providing its all properties

I am trying to write a consumer for an existing queue. RabbbitMQ is running in a separate instance and queue named "org-queue" is already created and binded to an exchange. org-queue is a durable queue and it has some additional properties as…
sag
  • 5,333
  • 8
  • 54
  • 91
6
votes
1 answer

RabbitMq bunny gem vs sneakers

I am new to RabbitMq. We are evaluating it for production use with rails app, currently for background mailing system. RabbitMq tutorial presents bunny gem. On it's other gem list, there is also sneakers gem. It would be useful to know, what are…
elpdspec
  • 101
  • 5
6
votes
1 answer

Routing messages in RabbitMQ topic exchange that do NOT match a pattern

Two queues are bound to a topic exchange with the following routing keys: Queue A, bound with routing key pattern match *.foo Queue B, bound with routing key pattern match *.bar I'd like to add a third queue to this exchange that receives messages…
changingrainbows
  • 2,551
  • 1
  • 28
  • 35
6
votes
1 answer

How to start bunny thread in Rails and Thin

I'm integrating Bunny gem for RabbitMQ with Rails, should I start Bunny thread in an initializer that Rails starts with application start or do it in a separate rake task so I can start it in a separate process ? I think if I'm producing messages…
Moustafa Samir
  • 2,248
  • 1
  • 25
  • 32
5
votes
1 answer

RabbitMQ 3.5.6 Could not establish TCP connection to any of the configured hosts (Bunny::TCPConnectionFailedForAllHosts)

I'm trying to connect to RabbitMQ server but always got these errors: W, [2015-12-08T15:38:01.993251 #37405] WARN -- #: An empty frame was received…
BBaoBao
  • 51
  • 1
  • 4
5
votes
2 answers

How do I get old messages from RabbitMQ?

I'm publishing RabbitMQ messages using Bunny (Ruby) like this: x.publish("Message !"+n.to_s, :routing_key => 'mychannel') and subscribing like this: ch = conn.create_channel x = ch.topic('fling',durable: true) q = ch.queue("") q.bind(x,…
Louise
  • 1,063
  • 1
  • 9
  • 20
5
votes
0 answers

heartbeat timeout error running rabbitmq

Running a Rails App in Mac. I start rabbit mq server in other terminal tab: $ rabbitmq-server The I do staff within my Web App, and when the mail is supossed to be sent, I got this in /usr/local/var/log/rabbitmq/rabbit@localhost-sasl.log =INFO…
Emba Moussa
  • 662
  • 8
  • 18
5
votes
1 answer

How to publish messages with priority using Bunny gem to RabbitMQ

RabbitMQ offers a Priority Queue, where messages may have a priority and are delivered to consumers in reverse priority. Using the Bunny gem, I create a prioritized queue. Then, I publish 5 messages with no priority, and 2 messages with priority 1,…
François Beausoleil
  • 16,265
  • 11
  • 67
  • 90
4
votes
1 answer

sneaker is not receiving messages on heroku - RabbitMQ Bigwig

I am trying to run message queues on heroku. For this I am using RabbitMQ Bigwig plugin. I am publishing messages using bunny gem and trying to receive messages with sneakers gem. This whole setup works smoothly on local machine. I take following…
dnsh
  • 3,516
  • 2
  • 22
  • 47
4
votes
1 answer

Monitor multiple RabbitMq subscriptions using single application

I have an application that I wrote in .NET that can monitor multiple RabbitMq queues using a single consumer. For example: using (IConnection connection = factory.CreateConnection()) { using (IModel channel = connection.CreateModel()) { …
Alex B.
  • 590
  • 4
  • 17
4
votes
1 answer

RabbitMQ status of a message

I'm currently using RabbitMQ (bunny) at VersionEye to import meta information about GitHub repos via the GitHub API. Depending on the number of the GitHub repos a task can take a view seconds up to a couple minutes. I create a new message/task like…
Robert Reiz
  • 4,243
  • 2
  • 30
  • 43
1
2 3 4 5 6 7