spring-amqp

0열

1답변

SimpleMessageListenerContainer : 소비자가 예외를 발생 시켰습니다. 처리가 지원되면 처리가 다시 시작될 수 있습니다.

스프링 부트 응용 프로그램과 시작을 잘 관리하는 rabbitmq 브로커가 연결되어 있지만 거기에 관계없이 메시지 소비자의 끊임없는 시작/종료가 발생합니다. 대기열에있는 메시지 2016년 10월 19일 11 : 40 : 25,909이 t 경고 : 다음은 내 응용 프로그램 로그 및 클라이언트 클래스의 사본은 [SimpleAsyncTaskExecutor-106]

rabbitmq spring-integration spring-amqp spring-rabbit 2016-10-19

---

1열

1답변

Interceptor를 Spring AMQP와 함께 사용하는 방법

메시지가 RabbitMQ에 전달되기 전에 template.convertAndSend가 호출되면 메시지를 가로채는 방법이 있습니까? 또한 핸들러에 도달하기 전에 메시지를 차단하는 방법은 무엇입니까? 게시자 용 PostProcessor를 사용하여 메시지를 처리 ​​할 수 ​​있지만 요격기를 사용하는 것이 좋습니다. public class TestPostProc

spring spring-boot rabbitmq spring-amqp 2016-10-21

---

1열

2답변

MessageConversionException : 메시지 내용을 변환하지 못했습니다.

저는 Spring AMQP를 사용하는 SpringBoot Application을 가지고 있습니다. 지금은 공식적인 Spring 문서 예제에서 지시 한대로 JavaConfig 클래스를 사용하여 수신 측을 구현하고 있습니다. 그러나 MessageConversionException을 받고 있는데 메시지가 내 ClientHandler 클래스에 도달하여 메시지를 처

rabbitmq spring-integration spring-amqp spring-rabbitmq 2016-10-25

---

0열

1답변

어디에 멀티 스레드 환경에서 수신 rabbitListener 구성 요소 내에 스레드 종속 데이터를 저장해야합니까?

다중 스레드 환경에서 스프링 amqp의 주석 기반 접근 방식을 사용하고 있습니다 (여러 소비자 => 여러 개의 토끼 수신기 컨테이너가 있음). @RabbitListener(queues = "tasks") public void receiveMessage(@Payload Task task) { // usage of httpClient here wit

spring-boot spring-amqp spring-rabbit spring-rabbitmq 2016-10-25

---

0열

1답변

스프링 배치 AmqpItemReader, AmqpItemWriter 예

스프링 배치를 사용하여 큐 (RabbitMq)에서 데이터를 읽으려고합니다. 그러나 나는 인터넷상에서 어떤 지침도 찾을 수 없다. AmqpItemReader 및 AmqpItemWriter를 사용하여 예제 스프링 배치 판독기 및 작성기를 사용하여 도움을주십시오. XML 구성이 바람직합니다.

java spring-batch spring-amqp 2016-10-27

---

1열

1답변

spring amqp 사용자 지정 TTL 및 재시도 횟수

우리는 클라이언트 예외에 대한 재시도 메커니즘을 구현하려고합니다. 우리는 각 메시지의 내용에 따라 다른 라우팅 키, ttl 및 재시도 횟수를 설정할 수 있기를 원합니다. 핸들러를 간단하게 유지하려고합니다. handleMessage가 예외를 throw합니다. 이 예외를 어떻게 처리하고 적절한 매개 변수를 사용하여 메시지를 DLX로 보냅니다. 다시 실패 할 경

rabbitmq spring-amqp 2016-11-02

---

0열

1답변

지정된 속도로 rabbitmq에서 메시지 처리

우리는 특정 속도 1ms/2 초로 청취자가 rabbitmq에서 메시지를 읽으려고했습니다. 우리는 지금까지 토끼 mq로 그러한 유틸리티를 찾지 못했습니다. 그래서 DB와 함께 이것을 수행하는 생각, 즉 리스너는 메시지를 읽고이를 DB에 저장하고 나중에 스케줄러가 DB로부터 원하는 비율로 처리합니다. 이 작업을 수행하는 더 좋은 방법이 있다면 제안하십시오. 우

rabbitmq spring-amqp throttling spring-rabbitmq 2016-11-06

---

2열

1답변

rabbitmq의 레코드 목록을 소비하는 잭슨 구성

나는 대기열에서 Employee 객체의 목록을 소비하는 스프링 부트 amqp를 사용하고 있습니다. 내 리스너 방법은 다음과 같습니다 @RabbitListener(queues = "emp_queue") public void processAndPortEmployeeData(List<Employee> empList) { empList.forEach(e

spring jackson rabbitmq spring-amqp jackson2 2016-11-08

---

0열

1답변

봄 토끼와 JDBC 트랜잭션 문제

나는이 개 봄 토끼 소비자가 A와 B 소비자 A : protected void process(Message amqpMessage, Channel channel) throws Exception { Session mysession=sessionRepository.findOne(5); mysession.setMyField("bla"

java spring-data spring-amqp spring-rabbit 2016-11-09

---

1열

1답변

비동기 및 공유 토끼 템플릿

나는 아래 @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory = new CachingConnectionFactory(hostName); connectionFactory.setUsername(mqUsernam

spring-boot rabbitmq spring-amqp spring-async 2016-11-10

---