2020欧洲杯时间表

All Questions

Filter by
Sorted by
Tagged with
0
votes
1answer
32 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 ...
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
233 views

Add Custom Headers to Spring Cloud Stream (with Spring Reactor)

Being new to Spring Reactor, I am trying to stream the data using Spring cloud stream(using rabbitMQ). I need to add some custom headers before the message is sent to the queue. My spring-cloud-...
1
vote
1answer
115 views

RabbitMQ + Spring Integration: Message conversion from queue bound to a topic exchange

I have two components (let's call them producer and consumer) connected to the same RabbitMQ topic-based exchange. The producer can send two different message types; Foo and Bar(contents of each ...
0
votes
1answer
140 views

How to configure amqp-outbound adapter for ack/nack and return queues using DSL?

I want to repeat following example using DSL config from example: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www....
0
votes
1answer
125 views

How to send message to the rabbitmq queue using spring integration java DSL

I wrote simple sample to read text from console and send it to the rabbitMq server: @Configuration @EnableIntegration @IntegrationComponentScan public class Config { @Autowired private ...
0
votes
0answers
41 views

Trigger listener to consume messages only after a limit is reached in queue

I am consuming Collection of Order requests and each request has a identifier and list of order_ids (like abc123, def456, 789ghl..so on). Basically, collection could contains 4 types of orders and I ...
0
votes
1answer
283 views

Spring AMQP Outbound Adapter behavior when exchange not found

I have a spring integration code that connects a JMS listener (that listens to a mq series local queue) <int-jms:message-driven-channel-adapter> and forwards the message to a rabbitmq (...
0
votes
1answer
95 views

Automatically publish errors from errorChannel to the specific destination

This documentation says, that it is possible to automatically send error messages from global errorChannel to specific destination, the only thing needed is to set the following property: spring....
0
votes
0answers
30 views

Internal exception occurs in org.springframework.integration.dsl.filter(…) method

We observed DLQ messages are missing trace stack in RabbitMq when the runtime exception is originated in the execution scope of org.springframework.integration.dsl.IntegrationFlowDefinition.filter(...)...
1
vote
2answers
520 views

Spring integration - Publisher Confirms with timeout?

This is my current setup: queue1 and queue2 are marged together with integration flow to channel1: @Bean public IntegrationFlow q1f() { return IntegrationFlows .from(...
0
votes
1answer
24 views

Possible reasons for ConditionalRejectingErrorHandlerExecution

I'm getting the following error for the rabbitmq application. org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandlerExecution of Rabbit message listener failed. We are using ...
1
vote
1answer
1k views

Spring AMQP application configuration from XML to Java

I'm struggling with rewriting RabbitMQ application configuration from XML to Java. Sadly once the code is executed, quite general error appears: org.springframework.amqp.rabbit.listener.exception....
0
votes
1answer
661 views

Example of RabbitMQ with RPC in Spring Integration

After make a search about different ways to implement it, im stuck. What im looking for is to realize this example (http://www.rabbitmq.com/tutorials/tutorial-six-spring-amqp.html) with Spring ...

15 30 50 per page