spring-rabbit

0열

1답변

RabbitMQ 바인더가있는 Spring Cloud Stream을 사용하고 있습니다. Spring Cloud Stream을 사용하지 않는 외부 서비스를 호출해야합니다. 이 서비스는 type 및 correlation_id 메시지 속성을 사용하고 있습니다. 나가는 메시지에서 헤더를 설정하려고했지만 기술적으로 헤더가있는 경우에도 특수한 방법으로 처리됩니다. 따라

0열

1답변

다시 대기 내가 업데이트 속성 메시지를 다시 큐가 나는 유스 케이스가

업데이트 된 특성을 가진 봄 AMQP 메시지는 메시지가지고 다시는 대기하지만 메시지 속성은 public class TestListener implements MessageListener{ @Override public void onMessage(Message arg0) { MessageProperties properties = arg0.g

2열

1답변

보낸 사람으로부터 메시지로 상관 ID를 보내고 수신에서 메시지 헤더로 Java에서 토끼 MQ로

나는 Rabbit MQ를 사용하여 JSON 메시지를 보내고 받았다. 제가 아래 교환 메시지를 보낼 인 convertAndSend 방법으로 RabbitTemplate 인스턴스를 사용하여 프로그램을 시행하고있다 : 메시지 측면 수신기를 검색하는 rabbitTemplate.convertAndSend(exchangeNameOut, message.getString(

-2열

3답변

Kafka 대 토끼의 장점과 단점 MQ

Kafka와 RabbitMQ는 잘 알려진 메시지 중개인입니다. 스프링 부트로 마이크로 서비스를 만들고 싶습니다. 스프링 클라우드는이를위한 기본 솔루션을 제공합니다. 나는 많은 지원을 한 RabbitMQ의 기갑 문을 조금 알고있다. 카프카는 아파치에 속해 있으므로 좋을 것 같습니다. 그래서 RabbitMQ와 카프카의 주요 목표 차이점은 무엇입니까? 스프링 클

0열

2답변

@StreamListener와 RabbitMQ를 어떻게 (통합하여) 테스트합니까?

테스트에서 응용 프로그램을 시작한 다음 청취자 봄 부팅 응용 프로그램에 대한 통합 테스트를 작성하려고합니다. 그런 다음 메시지를 생성하고 출력 채널에 드롭 한 다음 메시지를 선택하여 처리 할 때까지 기다립니다. 여기 내가 시험이 무엇을 : 더를 거기로 package com.example; import com.netflix.discovery.convert

0열

1답변

봄 토끼와 JDBC 트랜잭션 문제

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

0열

1답변

"Spring Cloud Stream"대신 "Spring Rabbit"을 사용해야합니까?

메시징 기반 프레임 워크를 채택하려고하는 프로젝트에서 작업하고 있습니다. (메시지 브로커가 라우팅하는 메시지와 다른 독립 구성 요소가 통신 함) RabbitMQ이 브로커로 최종 선택되었습니다. 프레임 워크에 대한 는, 처음에 우리는 봄 클라우드 스트림을 사용하려고하지만, 우리가 같은 토끼의 특성, 활용하려고하면 교환, 라우팅 키, 대체 교환을 ... 우리는

0열

1답변

내 스프링 부팅 응용 프로그램이 시간이 지남에 따라 메모리를 늘리는 이유는 무엇입니까?

스프링 통합을 사용하는 스프링 부팅 응용 프로그램이 있습니다. 응용 프로그램은 RabbitMQ 대기열에서 메시지를 가져 와서 해당 메시지의 데이터를 변환하고 50 개의 변환 된 메시지를 집계하여 배열에 저장 한 다음이를 JSON으로 RESTful 끝점으로 보냅니다. 응용 프로그램이 충돌 할 때까지 메모리가 천천히 움직이는 것을보고 있습니다. 우리 애플리케이

2열

1답변

Spring AMQP를 사용하여 청취자에게 보낼 지연 메시지

특정 지속 기간 후 MessageListener에 메시지를 보내야한다는 요구가 있습니다. 따라서 Spring AMQP를 사용하여 달성 할 수있는 방법이 있습니다. 예 : 메시지가 리스너가 바로 그 질문을 듣고 접수됩니다, 프로듀서는 메시지를 생성하고 메시지가 RabbitMQ Q 간다, 나는 몇 가지 구성 매개 변수가 1000MS

0열

1답변

응용 프로그램 인스턴스 간의 비 호환성 : rabbitmq가 특정 헤더가있는 메시지를 사용하지 못하도록하십시오.

나는 spring과 rabbitmq를 사용하는 동일한 Java 응용 프로그램 인스턴스가 두 개 있습니다. 인스턴스가 대기열로 메시지를 보내지 만 예상대로 인스턴스를 소비 할 것으로 예측할 수 없습니다. Java 응용 프로그램을 업데이트했습니다. 몇 가지 이유로 이전 버전과 새 버전 간에는 호환성이 없습니다. 새 버전은 이전 버전의 메시지를 사용할 수 없으며