amqp

0열

1답변

RabbitMQ pub/sub tutorial을 아래의 더미 테스트로 변환했습니다. 어떻게 든 예상대로 작동하지 않습니다. amqpURL은 유효한 AMQP 서비스 (예 : RabbitMQ) URL입니다. 내가 대기열 예제와 함께 그것을 테스트하고 작동합니다. 어떻게 든 그것은 "교환"에 실패합니다 나는 TestDummy가 "[Hello World]"를 기록

0열

1답변

Spring AMQP는 RabbitMQ Java 클라이언트보다 어떤 이점이 있습니까?

작업 대기열에 RabbitMQ 클러스터를 사용하고 있습니다. Spring AMQP를 사용할 때 RabbitMQ 클러스터와의 상호 작용을 단순화 할 수있는 기능이 있는지 알고 싶습니다. 또는 공식 자바 클라이언트를 사용하는 것이 더 낫습니다.

2열

1답변

보내는 동안 rabbitmq에 메시지 헤더를 설정하십시오.

나는 토끼에게 메시지를 보내는 동안 메시지 헤더를 설정하고 싶습니다. 아래 코드를 사용하고 있지만 메시지 헤더를 설정하는 방법을 혼동합니다. public static <T> void sendMessage(String routingKey,final Object message,Class<T> type){ DefaultClassMapper typeMap

0열

1답변

rabbitmq ReturnCallback NO_ROUTE (312)

에 대기열을 선언하는 동안 걸렸습니다. 메시지가 다시 삭제되지 않도록 사용할 수있는 경로가없는 경우 게시자가 콜백을 사용하여 대기열 및 바인딩을 선언하려고합니다. 대기열이 자동 삭제되어 내 고객이 다운되면 삭제됩니다. 그러나 ReturnCallback 스레드는 admin.declareQueue (대기열)의 returnedMessage()에서 멈추게됩니다.

1열

1답변

봄에 메시지 리스너 어댑터를 사용하여 메시지 객체 받기

나는 POJO 주문을 받기 위해 사용하는 스프링 AMQP를 사용하여 메시지 리스너를 만들었습니다. 메시지 유형은 application/json이므로 jackson 메시지 변환기를 설정했습니다. 지금까지 일이 잘 작동하고 내 리스너에 자동으로 다시 주문 POJO 객체를 얻을 수 있어요. 그러나 나는이 예제를 확장 할 내 청취자의 일부 메시지 속성을 확인하고

0열

1답변

모든 큐의 소비율은 기껏해야 25 메시지/초입니다. 이것을 어떻게 늘릴 수 있습니까?

나는 아이디어가 없다. NodeJS Microservices와 함께 Seneca AMQP Transport 플러그인이있는 SenecaJS를 사용합니다. 나는 초당 25 개의 메시지를 가지고 있으며 이유를 찾을 수 없습니다. 나는 그것을 벤치 마크하기 위해 seneca amqp transport plugin의 예제를 사용했다. 데비안에서 실행중인 두 대의 서

1열

1답변

socket.error : 시간 초과되었습니다 (도커 컨테이너에서 실행중인 Celery & RabbitMQ)

Celery (RabbitMQ 포함) 공식 도커 컨테이너를 가져 오려고합니다. 호스트에서 나는 tasks.py를 사용하고, # docker logs some-celery [2016-10-20 11:05:50,357: WARNING/MainProcess] /usr/local/lib/python3.5/site-packages/celery/apps/worke

4열

2답변

스프링 부트와 스프링 클라우드 통합 amqp

스프링 클라우드와 스프링 부트 amqp (토끼) 게시자 및 구독자의 통합을 보여주는 예제를 찾고 있습니다. 내가 2016년 10월 21일 08 로그에 다음과 같은 메시지를 볼 수행 : 35 : 15.708 정보 [프로듀서, 9148f56490e5742f, 943ed050691842ab, 거짓] 30928 --- [NIO-8080-간부-1] abccontro

0열

1답변

RabbitMQ X-delayed plugin : 교환기에서 데이터 처리에 액세스하는 방법?

나는 RabbitMQ 교환에서 정보를 검색하는 방법에 대해 지금 몇 시간 동안 찾고 있습니다. 내 목표를 설명하게 : 내가 Gmail의 API를 굽기 방지하기 위해 시스템을 설계 내 응용 프로그램 (초당) 한계를 호출합니다. 이렇게하려면 한 시간 내에 전송을 조정하는 cron을 설정합니다. 기본적으로 cron에서 지연을 정의한 다음 지연된 대기열에 데이터를

0열

1답변

gearman은 재시작 후 똑같은 순서로 작업을 실행합니까?

저는 gearman을 C++ 앱과 PHP 앱 사이의 인터페이스로 사용합니다. 내 직업은 질서에 따라 다릅니다. 메모리 내 큐를 사용하여 추가 된 순서와 동일한 순서로 실행되었습니다 (1 명의 작업자가 certanly). 내 대기열을 유지하고 싶습니다. 기어맨이 충돌 또는 재시작 후에 추가 된 것과 동일한 순서로 영구 대기열에서 작업을 실행합니까?