I need to achieve pub/sub messaging where one publisher publishes an event to a single consistent hashing exchange and other subscribers use routing key (event name) to indicate interest in a specific event. When using consistent hashing plugin routing key is used as weight value when queue binds to exchange. Is there any way to use routing keys while still using consistent hashing exchange? or my topology of exchange/queue needs to be changed somehow?
Can I use routing key for binding to exchange when using RabbitMQ consistent hashing?
127 Views Asked by gtest gtest At
0
There are 0 best solutions below
Related Questions in RABBITMQ
- When sending message getting Exception: org.springframework.amqp.AmqpIOException: java.io.IOException
- How to publish messages to RabbitMQ by using Multi threading?
- How should it be handled if the number of messages is less than the number of threads?
- Apply a dynamic group value in Spring Cloud Stream
- Two rabbitmq queues with exactly same configuration one of them is not created automatically (Spring Boot 3 RabbitMQ)
- Does Spring AMQP 3.13 support quorum queues?
- IServiceCollectionConfigurator' does not contain a definition for 'UsingRabbitMq'
- Troubleshooting topic exchanges in php-amqplib
- How to Use AWS Systems Manager (SSM) for Accessing a RabbitMQ Broker in an AWS VPC Private Subnet
- Rabbitmq on azure container app error 405 on trying to create queue on web management
- Cannot connect to RabbitMQ from Flower/Celery
- How to Extract Queue Name, Priority, and Message ID from RabbitMQ Inbound Endpoint Messages in WSO2 MI 4.2?
- Spring Boot RabbitMQ consumer application can not fetch an object sent by producer application in Java 17
- Is it possible to implement an event-driven architecture using Redis Streams?
- Scaling Nuclio With KEDA Based on Queue Length: Error ScaledObject Name is Not Specified
Related Questions in MICROSERVICES
- HTTP Requests from SSL Secured(HTTPS) Domain Failing
- Separation of Students and Users in NestJS Microservice architecture
- How to choose port number for various microservices? whatever port number I use is already used-blocked or I'm not able to use them
- Handling feign exception in Spring boot using RestControllerAdvice
- Javers in microservice architecture
- Kafka integration between two micro service which can respond back to the same function initiated the request
- HTTP 401 unauthorized ASP.NET Core Web API microservices
- Minikube tunnel - Ingress not working on windows
- importing class in microservice 1 from another microservice 2
- Eureka Discovery client is not register under API-GATEWAY\host.docker.internal
- Unable to PUT JSON using ADF Dataflow, the error is "the JSON value could not be converted to System.Collections.Generic.List"
- Using Django as API gateway & authorizations service in Microservice
- How to fix HTTPS on express-gateway
- Websocket duplicate on headers
- migrate from django migrations to fastapi alembic
Related Questions in PUBLISH-SUBSCRIBE
- How to avoid duplicates with the pull-based subscribe model?
- What's the right ZMQ architecture for my scenario?
- App didn't recieved a gcp pubsub message for a minute
- bun runtime doesnt work with SKD ably javascript starting v2.0.0
- How would the Broker pattern look like in Rust?
- akka PubSub not working across distributed system
- Google PubSub Lite one subscriber with multiple partitions
- I have a question about the Pub/Sub structure of Redis
- RabbitMQ. Client cannot publish message to queue
- Pull PubSub Message through Proxy server - Python
- Android server notification implementation in app purchase
- FastDDS Publisher and Subscriber won't match in demo code
- How to subscribe/consume multiple topics from multiple subscriptions declaratively with Dapr pub/sub component?
- How to subscribe/consume multiple topics from multiple subscriptions programmatically with Dapr pub/sub component?
- Enforce Unique Publisher/Producer on a Azure Service Bus Topic
Related Questions in MESSAGING
- What's the right ZMQ architecture for my scenario?
- Is Apache Camel typically deployed as a single application?
- AMQ Message move from one server to another us failing with a-1.6.0-jar-with-dependencies.jar
- Salesforce MIAW: User message not sent from Community
- Null request id when subscribe to the topic
- How to get all the messages that the current user is sent
- Handling RequestFailedException(800220) when sending file in flutter chat sdk of sendbird
- how to use push notification for send notification from one user to another user. Using Migrate from legacy FCM APIs to HTTP v1 - Firebase
- Wolverine IMessageBus.InvokeAsync<T> not returning result in a TimeoutException
- Problem configuring messaging-activemq in bootable wildfly 25
- Multiple message queues or one per application?
- Insert SMS with multiple recipients into the Android system SMS provider
- How to use a NodeJS app as a Native Messaging Host for a Firefox AddOn on Windows?
- Rabbit Mq for maintaining connections with a lot of users simultaneously
- Mobile app push authentication/authorisation
Related Questions in CONSISTENT-HASHING
- How to use consistent hashing across publishers, queues, and consumers
- Is there a design pattern to handle the scaling up/down of an RMQ consumer app consuming messages from queues bound to a consistent hash exchange
- Applying modulo function on MD5 hash
- How cassandra guarantees that a key goes to different nodes when building the different ring nodes?
- What is the lookup time complexity of Consistent Hashing Design?
- Why consistent hashing is better in handing hotspots than simple hashing?
- How to combine sharding and consistent hashing within a distributed system?
- DynamoDB What are coordinator nodes in context of replication?
- Akka Consistent-hashing routing
- consistent hashing where you want a key mapped to multiple servers
- Does a Cassandra node get assigned a new token every time it restarts?
- Using custom hash function with HAProxy LoadBalancer
- Can Rendezvous hashing add a node efficiently?
- How to use consistent hashing to allocate multiple servers for the same key?
- Can I use routing key for binding to exchange when using RabbitMQ consistent hashing?
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?