rabbitmq

2열

1답변

봄, 나는 이렇게 RabbitMQ를 통해 다른 서비스에 서비스에서 개체를 보낼

나는 봄 부트 프레임 워크를 사용하고 RabbitMQ 리스너에서 들어오는 메시지의 유효성을 검사합니다 내가 @NotEmpty, @NotNull 등과 같은 몇 가지 검증 주석을 정의 @RabbitListener(queues = "queue") public void onAccountRequested(@Valid CreateAccountRequestMessag

1열

1답변

Easynetq : 개발자 대기열

최근에 게시 - 가입 및 요청 - 응답 방식 및 공통 대기열 연결/끝점에서 easynetq 대기열을 설정했습니다. 목표는 큐를 사용하는 로직을 개발하는 것이 개발자들간에 독립적이어야한다는 점에서 easynetq를 설정하는 것입니다. 현재 모든 개발자 머신이 자신의 접두어로 된 큐를 가져 오는 easynetq를 구성했습니다.하지만 개발자가 2 명 더 많으면

0열

1답변

메시지 지향 미들웨어 -이 개념을 구현하는 제품?

메시지 지향 미들웨어 (MOM)을 배우려고 노력 중이며 온라인 자료를 참조하고 있습니다. MOM은 메시지 전달을 통해 두 개의 이기종 시스템을 통신하는 데 사용되는 것으로 알고 있습니다. 개념의 구현이 제품은 ActiveMQ를 IBM MQ /는 IBM WebSphere MQ/IBM는 MQSeries RabbitMQ 아파치 : 는 또한 같은 다양한 제품으로

0열

1답변

RabbitMQ가 동일한 메시지에 응답하여 소비자를 닫습니다.

Delivery.Ack 메서드를 사용하여 동일한 메시지를 두 번 확인하면 소비자 채널이 닫힙니다. 이 예상되는 동작입니까? 아무도 이것을 경험 한 적이 있습니까? 동일한 메시지를 두 번인지하는 이유는 원본 메시지를 복사본으로 나누어 소비자에게 처리해야하는 특별한 경우입니다. 일단 소비자가 모든 것을 처리하면, 모든 것을 반복하고 받아들입니다. 엔티티의 사본

0열

2답변

RabbitMQ Management 플러그인에서 디스크 공간을 사용할 수 없음

클러스터에 2 RabbitMQ 개의 노드가 있습니다. 구성 파일의 디스크 여유 공간 제한을 하드 코딩 된 값과 반대되는 메모리 기준으로 변경하기로 결정했습니다. {disk_free_limit, {mem_relative, 2.0}} 내가 이해하는 것은 : (메시지가 게시에 대한 경보 및 블록 전) 디스크 무료 제한을 설정 내 경우에는, * RAM 메모리 2이

0열

1답변

셀러리 노동자도 나는 RabbitMQ 큐에 아무런 메시지가 없습니다

시나리오 : @app.task(bind=True, max_retries = 5, base=MyTask) def testing(self): try: raise smtplib.SMTPException except smtplib.SMTPException as exc: print 'This is it' self

0열

1답변

RabbitMQ는 사제를 사용하여 내 Mac에서 RabbitMQ를 설치 한 맥

에서 실행되고 있지 I 당신은 the homebrew repository에 문제를 열어야합니다 dyld: Library not loaded: @rpath/libtinfo.5.dylib Referenced from: /Users/hennie/anaconda3/lib/erlang/erts-7.3/bin/beam.smp Reason: image

0열

1답변

스프링 클라우드 버스, RenamingMQ 더 읽기 쉬운 방식으로

My Cleint가 2 개의 인스턴스를 가지고 있고 큐의 이름을 바꾸기 위해 스 니펫을 사용하고 있습니다. testExchange.testQueue가 생성되었습니다. 2 명의 고객, 즉 클라이언트 인스턴스를 볼 수 있지만 while/버스/새로 고침 하나의 인스턴스가 새로 고쳐지고있는 것을 볼 수 있습니다. /버스/새로 고침 모든 인스턴스가 새로 고쳐 져야하

0열

1답변

graylog에 rabbitmq 메시지 헤더를 기록합니다.

저는 교환기에 게시 된 모든 메시지를 # 라우팅 키로 대기열로 라우팅하여 graylog를 사용하여 rabbitMQ에 보낸 메시지를 로깅합니다. 그리고 그 큐를 graylog에 AMQP 입력 소스로 설정하십시오. 이 잘 작동하지만 헤더 및 메시지 만 기록 할 수 있습니다. 헤더를 추출하고 기록하는 방법이 있습니까?

0열

2답변

RabbitTemplate.send()는 RabbitMQ에 대한 메시지 전달을 보장합니까?

Spring AMQP를 사용하여 rabbitTemplate.send(message) 메소드를 호출하면 (org.springframework.amqp.rabbit.core.RabbitTemplate 클래스에서) 메시지가 전달되고 RabbitMQ 클러스터에 복제되었는지 확인할 수 있습니까?