rabbitmq

    0

    2답변

    RabbitMQ를 메시징 백엔드로 사용하여 "longjobs"라는 대기열에서 작업을 처리하도록 Celery 4.1 작업자를 구성했습니다. My Celery 구성 및 작업자는 Django 1.11 프로젝트를 통해 관리됩니다. 아무 것도 오류를 발생시키지 않지만 Django 응용 프로그램에서 시작된 작업은 작업자에 의해 선택되지 않습니다. , celery wo

    0

    2답변

    그래서, 내가 2 큐, outboundEmailQueue 및 storeEmailQueue 있습니다 integrationExchange라는 팬 아웃 교환 바인더 제본 <rabbit:queue name="outboundEmailQueue"/> <rabbit:queue name="storeEmailQueue"/> : <rabbit:fanout-exchang

    0

    1답변

    셀러리, RabbitMQ 및 Flower로 분산 작업 메커니즘을 실행해야합니다. 보통 사람들은 내 서비스에 3 개의 광고 모음을 만드는 각 서비스마다 별도의 광고 모음을 만듭니다. 제 질문은 왜 3 포드를 만드는 겁니까? 3 개의 컨테이너로 하나의 광고 모음을 만들 수 있습니다. 서비스는 밀접하게 결합되어 있으며, 모두 작동중인 솔루션을 갖추기 위해 실행되

    1

    1답변

    rabbot을 사용하여 RabbitMQ에 연결하는 노드 서버가 있습니다. 이것은 잘 작동하고 있으며, 메시지를 게시하고, 메시지를 보낼 수 있습니다. 이제 RabbitMQ 서버에 특정 버전이 실행 중인지 묻는 메시지를 표시 할 수 있기를 바랍니다. 버전을 묻는 메시지를 게시하고 회신 큐를 통해 답변을 얻을 수 있기를 바랬습니다. 또는 HTTP를 통해 요청을

    0

    1답변

    RabbitMQ 브로커가있는 클러스터 된 tomcat 환경에서 스프링 웹 소켓을 사용하여 응용 프로그램을 빌드하고 있습니다. 내가 듣기 위해 끝점을 등록해야하는 API 모듈이 있습니다. 나는 보통의 예를 따라이 설정 해낸이 작동하는 동안 따라서 수없는 다른 레이어를 떠나 모든 API 모듈에 번들로 제공하는 웹 소켓 및 릴레이 설정을 나타나는 @Configu

    0

    2답변

    토끼 대기열, 처리 및 게시 메시지를 다른 토끼 대기열에서 수신하겠습니다. 나는 봄과 일하고 있지 않다. 메시지는이 구성에서 복제됩니다. 이 짧은 코드 :이 너무 시도 context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception {

    0

    1답변

    토끼 MQ에 메시지를 나타내는 POJO가 있습니다. 메시지의 유형에 대한 책임이 정수 (그래서 그것의 여부를 update, remove, add과)이 있습니다 : public class Message { private String field1; private String field2; private Integer type;

    0

    1답변

    RabbitMQ 로그에서 삭제 된 큐에 대한 정보를 찾을 수없는 이유는 무엇입니까?/vhost에서 queue가 제거되면 해당 정보가 기록되지 않습니다. 우리는 다른 RabbitMQ 클러스터로 삽 피하는 대기열에 문제가 있으므로이 정보를 로그에 기록 할 수 있습니까? 업데이트 됨 대기열이 임시 및 자동 삭제가 아니라 정상 및 내구성이라고 말하도록 추가하고 싶

    0

    2답변

    나는 pip install celery과 sudo apt-get install rabbitmq 명령으로 셀러리와 RabbitMQ를 설치했다. 셀러리가 작동하지 않습니다. 나는이 오류를 얻을 : 위의 예외 처리하는 동안 Traceback (most recent call last): File "/home/morilon/dj/shop/lib/python

    0

    1답변

    : @Configuration public class RabbitConfig implements RabbitListenerConfigurer { public static final String AMQP_EXCHANGE_NAME = "test-queue"; @Bean public Exchange accessExchange()