2020欧洲杯时间表

All Questions

Filter by
Sorted by
Tagged with
1
vote
1answer
24 views

Spring cloud stream + spring retry, How to add recovery callback and disable logic that send to DLQ?

I'm using spring cloud stream + rabbit mq binder. In my @StreaListener I want to apply retry logic on specific exceptions using RetryTemplate. After retries are exhausted or not retriable error is ...
0
votes
0answers
14 views

Spring Cloud Stream Rabbit closes/recreates Source connection when Sink binder is down

When one of publisher binder is down, SCS is closing existing connection to rabbit1 server, is it expected? Our processor application connects to two binder's [rabbit1 and rabbit2] rabbit1 is our ...
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
45 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 ...
0
votes
1answer
35 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
1answer
63 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....
1
vote
1answer
46 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: @...
0
votes
1answer
32 views

Spring Cloud Stream - Consume Data on Demand manually?

Using Spring Data Stream, How can I start reading from a queue and stop reading on demand? I want to so something like this: @EnableBinding(Sink.class) public class SomeConsumer { @StreamListener(...
0
votes
1answer
36 views

Spring Cloud Stream vs Spring AMQP

I'm developing an application that consumes messages from an exchange and it can publish to one of the multiple exchanges based on the input message transformation result. I am trying to decide ...
0
votes
1answer
45 views

Spring Reactive Stream - Unexpected Shutdown

We are using Spring Cloud Reactive Streams with RabbitMQ. Spring Reactive Stream appears to acknowledge the message as soon as it pulls it off the queue. So any errors unhandled exceptions that ...
0
votes
1answer
47 views

How to set property 'x-message-ttl' for queue in java

How to set 'x-message-ttl' properties to this queue? rabbit: bindings: TEST_RESPONSE: consumer: bindingRoutingKey: "'${routing}'" ...
0
votes
0answers
59 views

Spring cloud stream rabbitmq - consumer retries 3 times for all exception

I am trying to stop the retires for my spring boot cloud application completely or retry for only specific exceptions I have tried several ways to completely stop it from retrying 3 times I set the ...
0
votes
1answer
55 views

Spring Cloud Stream topic per message for different consumers (in one Comsumer app)

This question is similar to Spring Cloud Stream topic per message for different consumers but the difference is that I want multiple Sinks in one consumer springboot application and I want to do this ...
3
votes
1answer
75 views

Spring cloud stream rabbitmq binder - spring cloud function error handling

i am using spring cloud stream rabbit binder with spring cloud function and defining listeners like: public Function<Flux<SomeObject>, Flux<OtherObject>> foo() { //some code } I ...

15 30 50 per page
1
2 3 4 5