All Questions
Tagged with ruby-on-rails rabbitmq
112
questions
1
vote
0
answers
14
views
Ruby/Rails Bunny RabbitMQ Must be one of [:method, :headers, :body, :heartbeat]
I get an error when trying to connect to RabbitMQ.
Error backtrace:
.../amq-protocol-2.3.2/lib/amq/protocol/frame.rb:67:in `decode_header'
Error:
Must be one of [:method, :headers, :body, :heartbeat]
...
- 11
0
votes
0
answers
47
views
Ruby on Rails Jobs and MongoDB
I am challenged by some implementation and I would love to hear from some MongoDB experts on my problem.
I have an app on which profiles can follow each others. Now I would like my users to get some ...
- 983
0
votes
0
answers
78
views
How to receive Messages from RabbitMQ as a background job using Bunny gem in Rails
I'm using RabbitMQ and the following task to receive the messages from Consumer.
lib/task/rabbitmq.rake
require "rubygems"
require 'bunny'
connection = Bunny.new(user: "...
- 1
1
vote
0
answers
272
views
RabbitMQ - shovel plugin, accessing headers (properties) form Azure Service Bus
I need to implement rabbitMQ as sort of a middleware between Azure service bus and my rails app.
The message that is being sent uses headers which i also need to capture.
So, is there a way for shovel-...
- 11
0
votes
1
answer
134
views
How to sigInt rabbit MQ workers?
We are using Rabbit MQ as a message broker via Sneaker gem.
During the deployment time, we need to pause the connection. So no worker's work is picked up by the worker after completion of the current ...
- 2,441
0
votes
0
answers
228
views
Best practice for monolithic Rails app that provides multiple consumers for RabbitMQ round-robin queue?
I need multiple consumers in my Rails app to process messages from RabbitMQ that are delivered using the round-robin pattern.
All the consumers (C1, C2) have the same exact logic. How do people ...
- 1,733
0
votes
1
answer
750
views
Sidekiq throws Redis::CommandError
I have this redis container I use for Sidekiq/Rails and also set up rabbitmq a few days ago on the same docker host. Ever since I keep getting these errors:
UNBLOCKED force unblock from blocking ...
- 2,502
0
votes
1
answer
1k
views
How to solve issue "Could not establish TCP connection to any of the configured hosts"
I'm new in programming and I'm trying to set relationships between my rails apps. I'm using docker-compose and rabbitmq. Here is my code:
some code in controller in Rails app
def some_method
...
user12856224
1
vote
1
answer
2k
views
How to run rake sneakers:run
I am trying Rabbitmq and sneakers for the first time. And I am facing some issues when i try to run my workers.
I have added the following line in application.rb
config.active_job.queue_adapter = :...
- 58
0
votes
0
answers
207
views
Exception error="uninitialized constant V1" using Sneakers
I'm trying to implement Sneakers, but I'm having some issues. Below you can find the code which subscribers to my queue and the actual error.
require 'sneakers'
require 'jwt'
require 'redis'
require '...
- 21
0
votes
1
answer
193
views
Is it possible that we can run sneakers along with web server?
I can use rake sneakers:run it work perfect. but can I run sneakers along with web server without running separate command (rake sneakers:run)
1
vote
1
answer
255
views
Keep publishing data via publisher RabbitMQ (ruby bunny)
I have a RabbitMQ with bunny working using consumer.rb and publisher.rb. If I run
ruby consumer.rb
and then
publisher.rb
I get data being published (data coming from another class). Data ...
- 19
2
votes
1
answer
1k
views
Can not connect to Rails database from Sneakers worker (RabbitMQ RPC call)
TLDR;
Why Sneakers worker can't connect to the database or can't query it?
(General advices on "do's" and "dont's" are also welcome in comments)
Full question:
I am able to execute RPC call that ...
- 602
4
votes
2
answers
2k
views
Rails + Sneakers: could not obtain a connection from the pool
We're using Sneakers gem in production for a big application. And sometimes the load can be so huge that one specific queue may contain over 250_000 messages. And in such cases, the exception
...
- 1,368
2
votes
0
answers
521
views
How to get Rails app using Rabbit-MQ to trigger Airflow DAG
I have a rails application that is triggering a task by writing into a Rabbit-MQ queue.
In Airflow which is setup with Celery and Rabbit-MQ I want to trigger a DAG to run when a message hits the ...
- 21