spring-amqp

37열

7답변

봄 AMQP + RabbitMQ 3.3.5 ACCESS_REFUSED - 로그인 I 예외 아래에 무엇입니까

PLAIN 인증 메커니즘 org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For det

0열

1답변

amqp-appender가 메시지를받지 못합니다.

AmqpAppender를 사용하여 메시지를 기록하는 간단한 테스트 앱이 있습니다. 응용 프로그램을 실행할 때 콘솔 기반 메시지가 쓰여지지만 AMQP 메시지는 쓰이지 않는 것을 볼 수 있습니다. 필자가 appender에서 문제가있을 수 있음을 나타내는 결과물이 전혀 보이지 않는다는 점에 관해서는 더 많은 것이있다. 나는 유효하지 않은 교환 이름으로 테스트를했

1열

1답변

예외가 발생했을 때 메시지 헤더 변경

Inside MessageListener 예외가 발생합니다. 메시지 수신기 컨테이너의 기본 동작은 다시 시작 메시지입니다. 내 질문 - 메시지가 큐에 들어갔을 때 메시지 헤더를 변경할 수 있습니까?

0열

1답변

다른 Java 클라이언트 버전 번호가있는 토끼의 여러 연결 열기

AWS에서 rabbitmq 클러스터 설정이 있습니다. 2 대의 컴퓨터는 모두 대기 상태이며 미러링 대기 상태이며 ELB 뒤에 있습니다. 큐 이름 hips.preprod.queue에는 springamqp 소비자가 있습니다. springamqp 버전은 3.3.4입니다. 소비자는 호스트가 아닌 ELB에 직접 연결됩니다. 소비자가 토끼 클러스터에 연결하면 단일 연

3열

1답변

봄 AMQP는 : 주석 중심의 리스너 오류가

내가 간단한 봄 AMQP 시나리오를 설정하기 위해 노력하고있어,하지만 다음과 같은 오류가 무엇입니까 엔드 포인트 : Could not resolve method parameter at index 0 in method: public void handleMessage(HelloMessage), with 1 error(s): [Error in

0열

2답변

래빗 AMQPTemplate 메시지는 EJB 트랜잭션 관리자가 관리합니다.

저는 스프링 amqp를 사용하여 EJB (Stateless Session Bean) 내의 래빗 큐에 메시지를 배치하고 있습니다. 예외가 EJB 컨테이너 밖으로 던져지면 데이터 업데이트가 롤백됩니다. EJB 컨테이너가 메시지를 비슷한 방식으로 관리하는 방법이 있으므로 어쨌든 큐에 커밋 되기만하면됩니다. 예외가 발생하지 않고 EJB가 완료됩니까?

4열

1답변

Spring AMQP : 많은 수의 수동 선언을 피하는 방법?

기본 spring-amqp 설정을 만들었 으면, 나는 (메시지 POJO를 사용하여) 보내려하는 모든 유형의 메시지에 대해 스프링 구성에서 대기열을 선언해야한다는 것을 알았다. 다음의 모든 쌍 그래서 : <rabbit:queue name="queue1"/> 이 나에게 중복 보인다 amqpTemplate.convertAndSend("queue1", new

0열

2답변

큐 메커니즘 및 Elasticsearch 1.4.0

나는 RabbitMQ 브로커를 가지고 있는데, Elasticsearch에서 문서로 끝나는 다른 메시지를 게시합니다. 브로커의 여러 소비자가 있습니다. 실제로는 amqp 인바운드 게이트웨이에 할당 된 작업 실행자에서 서로 다른 스레드입니다 (여기서는 스프링 통합과 amqp를 사용). 다음과 같은 시나리오를 생각해보십시오 : 나는 구조 { "field

0열

2답변

spring amqp와 다시 연결

org.springframework.amqp.rabbit.connection.CachingConnectionFactory을 사용하여 RabbitMQ에 연결합니다. 그러나 네트워크 문제로 인해 내 응용 프로그램이 토끼 서버에 자동으로 다시 연결되지 않음 (네트워크 문제로 인해) CachingConnectionFactory 자동으로 다시 연결되도록 구성되어 있

0열

1답변

Grails, Grails RabbitMQ 플러그인, Java, Spring AMQP - 여러 클라이언트

Grails RabbitMQ 플러그인을 사용하는 간단한 Grails REST 웹 서비스를 개발하여 대기열로 보냈습니다. Grails에 - Config.groovy 파일 queues = { exchange name: 'my.topic', type: topic, durable: false, { foo durable: true, binding