Stack Overflow
Stack Overflow

Questions tagged [rabbitmq-shovel]

58 questions
53
votes
2 answers

When to use RabbitMQ shovels and when Federation plugin?

For the company I work for we would like to use RabbitMQ as our main message bus. The idea we have is that every single application uses their own vhost for internal communication and that via the shovel or federation plugin we would make it…
Michel Tol
  • 1,102
  • 1
  • 8
  • 15
14
votes
2 answers

RabbitMQ RPC across multiple rabbitMQ instances

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…
Jan Vladimir Mostert
  • 12,380
  • 15
  • 80
  • 137
4
votes
1 answer

Can I dynamically create RabbitMQ shovel from my NodeJS app?

RabbitMQ shovel plugin provides an HTTP API to create & configure shovels. Assuming that I have enabled shovel & shovel management plugin for my RabbitMQ server instance, can I dynamically create shovels from my NodeJS app? I currently use amqplib…
wraith
  • 391
  • 1
  • 14
4
votes
1 answer

How to configure RabbitMQ bidirectional shovel and avoid infinite loop?

I have 2 RabbitMQ clusters in separate datacenters. At the moment we are shovelling one of the exchanges from an one rabbit to the other but now we need to shovel in the other direction too. How can we achieve this without causing an infinite…
Tom
  • 2,416
  • 3
  • 31
  • 38
4
votes
1 answer

Proxying internal traffic to Azure Service Bus

What I'm trying to achieve is interoperability between RabbitMQ clients in an internal network, and Azure Service Bus consumers running in Azure. The RabbitMQ clients need to publish and subscribe, as do the Azure Service Bus consumers - so I need…
Cocowalla
  • 13,822
  • 6
  • 66
  • 112
4
votes
1 answer

How to make sure that my Application connection to RabbitMQ is healthy?

I am required to set up a keepalive endpoint to my web application (tomcat war). The endpoint will be sampled periodically by my WAF to make sure that the app is healthy. A healthy app means that the application is up and the communication to the…
Haim Raman
  • 11,508
  • 6
  • 44
  • 70
4
votes
1 answer

RabbitMQ shovel losing messages (try to emulate network problems)

I am building the cluster with RabbitQM servers . I use shovel plugin to deliver mesages from one rabbitmq to other (different machines) It works fine . But i want to test how it will behave when no network connection between servers. On each server…
Roman Gelembjuk
  • 1,797
  • 2
  • 25
  • 50
4
votes
2 answers

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

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…
kurco19
  • 43
  • 1
  • 3
4
votes
1 answer

how to use multiple configuration files for RabbitMQ / Erlang

I am trying to setup a Spring based Java application which uses a locally installed RabbitMQ server for delivering messages between nodes. As some of you already know, the rabbitmq.config file can be used to configure various parameters and is…
Itay
  • 144
  • 2
  • 8
3
votes
3 answers

RabbitMQ configuring dynamic shovel error - 'component shovel not found'

I'm trying to configure a dynamic shovel on RabbitMQ 3.2.3 after installing the Shovel plugin. However, when I run the following command: rabbitmqctl set_parameter shovel test-shovel '{"src-uri": "amqp://", "src-queue": "queueName", "dest-uri":…
user3891135
  • 69
  • 1
  • 5
2
votes
2 answers

How to configure RabbitMQ shovel?

I have 2 RabbitMQ clusters in separate datacenters. At this moment i need to shovel one of the exchanges from an one rabbit to the other. How can i achieve it?
sekhar
  • 47
  • 1
  • 5
2
votes
1 answer

RabbitMQ Messages not getting sent to dead letter after first time

We've got our queues configured to send dead letter messages (nack'ed messages specifically) to a dead letter exchange that routes them by their original topic to individual dead letter queues. This all works great and when messages are nack'ed…
Kenny Loveall
  • 519
  • 4
  • 16
2
votes
1 answer

RabbitMQ Shovel plugin in a cluster

We have a RabbitMQ cluster with three nodes configured. Each node has two virtual hosts (Vhost-A and Vhost-B). We need a possibility to move messages from Vhost-A to Vhost-B. To accomplish this, we setup a shovel directing messages from Exchange-1…
froeschli
  • 2,692
  • 2
  • 28
  • 55
2
votes
2 answers

How to delete rabbitmq shovels through commandline

I created shovels using , rabbitmqctl set_parameter shovel "MyShovel" ...... Now i want to delete it, Can you please tell me on how to achieve it using commandline.
vinod hy
  • 827
  • 2
  • 14
  • 26
1
vote
0 answers

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-plugin to also include headers with the shoveled…
Jan Mistarz
  • 11
  • 2
1
2 3 4