2020欧洲杯时间表

Questions tagged [spring-rabbitmq]

Spring components for AMQP-based messaging.

Filter by
Sorted by
Tagged with
-1
votes
1answer
46 views

is there any setting to go back to the first cluster CachingConnectionFactory setAddresses

I am using CachingConnectionFactory the setAddresses method for multiple clusters. connection = new CachingConnectionFactory(); connection.setAddresses("rabbit1:5672,rabbit2:5672"); when i turn off ...
0
votes
1answer
12 views

Spring AMQP Get Existing Queue Names and Argument

We have a queue in production where message TTL was set via application. Now we want to change message TTL and attach policy via rabbit CTL than setting within application. Snippet: Map<String,...
0
votes
0answers
15 views

Sending two different object with the same binder spring cloud

I have two different RESTfull API that returns different objects, I want to send those objects to a message broker in spring cloud stream, I am familiar with The Processor class but what are my ...
0
votes
1answer
14 views

What is the simplest way to pause spring boot rabbit mq consumer?

Is there a simple a simple way to pause the spirng boot AMPQ and resume is after some time?? i'm using spring boot verison 2.6
0
votes
0answers
13 views

RabbitMQ-Unacked message count in a queue increases as listener starts and unacked messages are processed by listener

Im trying to process the messages in dead letter queue with a dedicated rabbitMQ listener configured with customised container factory with prefetch count >1. I'm able to consume messages from dead ...
0
votes
1answer
41 views

While implementing dead-letter queue (DLQ), a channel error is throw

channel error; protocol method: #method(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-dead-letter-exchange' for queue 'ecpauditchannel.ecpqueue' in vhost 'ecp-audit': received ...
-1
votes
0answers
22 views

Reactor handle connection error gracefully

I have a problem with error handling in reactor. My spring boot app, listen to RabbitMQ messages and upon a message receipt, I store that in MongoDB. My usecase suits a flux pipeline and there is a ...
0
votes
0answers
24 views

Do dead letter queues create new threads?

I have following RabbitMQ listener: class TestClass { private ThreadLocal<Integer> myThreadLocal = new ThreadLocal<Integer>() { @Override public Integer initialValue() { ...
0
votes
1answer
30 views

Spring Integration with consumer and Nifi as dispatcher

we are developing a service that listens or consume message from RabbitMQ queue. The message is dispatch from Apache Nifi to the message queue (e.g. queue name is "workitems"). Now, I would like to ...
0
votes
1answer
31 views

Spring AMQP - How to confirm that a message is delivered and Routed successfully?

I am looking for a way to delivery a message, and once the message is delivered (and routed) successfully, i need to perform some operations. I have enabled publisher confirms and returns by: spring....
0
votes
0answers
27 views

RabbitMQ exchange with spring cloud stream doesn't seem to update [duplicate]

I have a simple Spring-Cloud-Stream project that I connect with RabbitMQ, the problem is that I don't see any results in the RabbitMQ dashboard. No connection, No Exchange, nothing. I think my ...
0
votes
0answers
24 views

EntityManager is null in DAO class, SpringAMPQ and RabbitMQ [duplicate]

I am trying to execute some selects in my DAO class but I got no success after reading a lot of similar questions but with different setups. I keep getting EntityManager null which throws java.lang....
0
votes
1answer
56 views

Caused by: java.lang.ClassNotFoundException: org.springframework.integration.dsl.IntegrationFlowBuilder

I'm working on Spring Cloud Stream using RabbitMQ using Spring Boot v2.2.6.RELEASE. Error: java.lang.IllegalStateException: Error processing condition on org.springframework.cloud.stream.config....
0
votes
0answers
21 views

Problem(MissedHeartBeatException) with Spring Boot Rabbit MQ Consumer which connect to a Queue on some condition

I want to connect to a Spring Boot Rabbit MQ to consume message on some condition. I have seen example(https://spring.io/guides/gs/messaging-rabbitmq/) like this but the problem of using this approach ...
1
vote
1answer
40 views

Spring Cloud Stream - Functions - How to manually acknowledge rabbitmq message?

I'm using a spring cloud stream with rabbitbinder. Using a @StreamListener, I could manually acknowledge rabbitmq messages by having Channel and deliveryTag injected into the method as follows: @...

15 30 50 per page
1
2
3 4 5
45