message-queue

0열

1답변

인 경우 MQTT가 재시도 함 SOAP 엔드 포인트를 통해 수신 된 메시지의 데이터 일부를 전달하는 MQTT 콜백을 가지고 있지만 SOAP 엔드 포인트에 오류가 발생하면 해당 메시지는 손실되어 최종 소비자에게 도달하지 않습니다. 다른 QOS 및 배달 토큰을 알고 있지만 예외를 트리거 한 후 해당 메시지를 실제로 다시 시도하는 데 실제로 도움이되는지 확실하지

1열

1답변

일괄 처리 된 메시지 사용 - RabbitMQ

위의 코드를 사용하여 다른 라우팅 키를 사용하여 여러 생성자가 동일한 교환기로 보낸 여러 메시지를 사용할 수 있었으며 각 메시지를 데이터베이스에 삽입 할 수있었습니다. 그러나 메시지가 DB에 차례로 삽입되므로 너무 많은 리소스가 소모됩니다. 그래서 일괄 삽입을하기로 결정했고 설정할 수 있음을 발견했습니다. BasicQos에서 메시지 제한을 10으로 설정 한

1열

1답변

윈도우 로컬 컴퓨터

내 로컬 Windows 노트북에 RabbitMQ 서비스를 시작하려고하지만이 오류가 계속에 RabbitMQ 서비스를 시작할 수 없습니다 비트 이진 파일) 여기에서 : http://www.erlang.org/downloads. 그런 다음 여기에서 RabbitMQ를 다운로드했습니다 : https://www.rabbitmq.com/install-windows.ht

2열

1답변

RabbitMQ - 라우팅 키당 하나의 동시 작업자

RabbitMQ에 처음 접했고, 내가 필요한 것을 얻을 수 있는지 알아보기 위해 노력하고 있습니다. Worker Queues 패턴을 찾고 있지만 경고가 하나 있습니다. 라우팅 키당 하나의 작업자 만 동시에 실행하고 싶습니다. 내가 명령에 의해 라우팅 키를 사용하여 다음과 같은 메시지를 보내는 경우 가 : a, a, b, c, 나는 동시에 실행에만 3 노동자

0열

1답변

NetMQ 확장 요청 - C# 및 Python을 사용하여 응답

간단한 요청 - 응답을 사용하여 C# (클라이언트)와 python (서버)간에 대화 할 수 있습니다. 그러나 C# asp.net을 기반으로하는 웹 응용 프로그램을 안정적으로 만들고 더 많은 클라이언트와 서버가 필요하므로 확장 REQ-REP 연결을 사용하여 C# 및 Python 연결을 시도했습니다. 그러나 아래 코드를 실행하면 브로커로 작업하지 않고 아무 것

0열

1답변

JMS에 연결하는 SOAP 프로젝트를 가져올 때 자바 프로젝트에서 Hermes 세션을 수동으로 만드는 방법

메시지 대기열에 연결하여 JMS 메시지를 보내주는 SoapUI 프로젝트를 만들었습니다. MQ와 연결하기 위해 SoapUI가 제공하는 HERMES 도구를 사용했습니다. 현재 Hermes v1.14를 사용하고 있습니다. 나는 헤르메스 '끝에 필요한 세션과 해당 대기열을 생성하고 다음과 같이 단계를 수행 한 후 JMS 메시지를 보냈습니다 : https://www

0열

2답변

대기열에있는 메시지 대기열

대기열에있는 메시지가 있지만 메시지가 성공적으로 전송되면 대기열에서 메시지를 삭제하고 싶지 않습니다. 다른 시간에 다시 트리거하기 위해 메시지를 보관하고 싶습니다. 누구도 rabbitMQ를 구성하는 방법에 대한 아이디어가 있습니까?

-4열

1답변

Websphere mq 대기열 관리자가 구성된 서버 세부 정보를 찾는 데 도움이 필요합니다.

Websphere mq 대기열 관리자가 구성된 서버 세부 정보를 찾는 데 도움이 필요합니다. WAS 콘솔에서 연결 속성에서 큐 관리자 이름을 볼 수 있지만 큐 관리자가 구성되어있는 서버를 알지 못한다면 세부 정보를 찾는 방법이 있습니까?

0열

1답변

카프카 : 소비자 충돌 내가 다른 프로젝트로 구현하고있어 일부 카프카 코드를 상속 ... 소비자가 생산자에서 3995 메시지를 수신 한 후, 충돌 및 다음과 같은 오류주는 문제를 건너 왔어요

: ERROR Error while accepting connection (kafka.network.Acceptor) java.io.IOException: Too many open files Information about data being sent: Very bursty around the time of crash Always crashes a

0열

1답변

Kafka 대기열에 쓰고 읽는 사이에 지연이있는 이유는 무엇입니까?

나는 Kafka 대기열의 메시지를 소비하는 작업자 서비스를 작성했으며 몇 초마다 대기열에 메시지를 추가하는 테스트 스크립트도 작성했습니다. 내가 눈치 채지 못한 사실은 메시지가 대기열에 추가되는 동안 소비자가 한 번에 몇 분 동안 유휴 상태로 앉아있는 경우가 많다는 것입니다. 그런 다음 갑자기 소비자가 첫 번째 메시지를 받아 처리하고 나머지 메시지로 빠르게