amqp

1열

1답변

Ruby로 작성된 응용 프로그램을 가지고 있는데, 각각의 스레드는 원격 AMQP 끝점에 요청을 보냅니다. 이러한 스레드는 새로운 작업을 실행해야 할 때가끔 생성됩니다. 요청에 대한 응답을 보내기 위해 스레드 당 임시 대기열을 사용하면이 Ruby 서비스에서 들어오는 메시지를 처리하는 코드를 작성하기가 쉽습니다. 대기열은 연관된 채널이 닫히 자마자 삭제되어 목

0열

1답변

RabbitMQ를 사용하여 연결을 재설정했습니다.

Helo, 저는 rabbitmq에서 정말 새로 왔습니다. 나는 rabbitmq 라우터를 구축하고 pika를 사용하여 Python으로 HelloWorld를 보내려고했다. 터미널에서 나는 sudo rabbitmq-server start를한다. 나는 localhost : 15672를 입력 할 수있다. 하지만 localhost에 연결하려고하면 5672가 1 초 동

1열

1답변

.Net MQQM 클라이언트

내 .Net 응용 프로그램에서 AMQP 1.0 채널을 사용하여 IBM MQ 9.0에 연결하려고합니다. MQ Light 포털은 현재 Nodejs, ruby, java 및 python 클라이언트 만 지원합니다. .Net 용 MQ Light AMQP 클라이언트가 있습니까? 내가 Amqpnetlite 클라이언트 namespace AMQPNetLiteSample

0열

1답변

RabbitMQ : 여러 대기열에서 한 번에 하나의 메시지 만 사용

RabbitMQ에서 여러 대기열에 계속 연결하려고합니다. 이 대기열 중 하나에서 새 메시지가 나올 때마다 외부 프로세스를 생성하고 싶습니다. 이 프로세스는 메시지 처리에 다소 시간이 걸릴 수 있으며 이전에 팝업 한 메시지가 완료 될 때까지 특정 큐의 다른 메시지 처리를 시작하지 않으려합니다. 가능한 경우, 외부 프로세스에서 서버를 완료하고 기다리기 위해 프

0열

1답변

"준비"상태로 누적되지 않는 RabbitMq 직접 대기열?

"준비"상태로 누적되지 않는 대기열이 필요합니다. 즉, 대기열에 가입자가있는 경우 교환기의 메시지를 직접 전달하고 구독자가없는 경우 메시지를 낭비하면 "준비"상태가되지 않습니다. 유형 교환 fanout을 알고 있지만 라우팅 키를 사용할 수 있기를 원하며 fanout 교환기가 라우팅 키를 무시합니다. 내가 만든 시나리오가 방송이 아닌 경우 게시자 1 명과 구

0열

1답변

rabbitmq 클라우드 서비스에 연결할 수 없습니다.

갑자기 wascally/rabbot이 내 끝점에 연결할 수 없을 때까지 cloudamqp로 잘 작업하고있었습니다. 로컬에 RabbitMQ를 설치했는데 시스템이 정상적으로 작동합니다. 그 이후로 bigwig를 통해 Heroku에서 RabbitMq 인스턴스를 설정하려고했지만 아무 소용이 없었습니다. 내가 사용하고있는 엔드 포인트는 잘되어야하고 아마 rabbot

0열

1답변

내장 QPid 브로커 - 웹 관리 콘솔로드 중

아래 QPid 아티팩트를 사용하여 브로커를 시작할 때 관리 콘솔을 실행할 수 없습니다. 아래 설정에서 종속성 또는 구성이 누락 되었습니까? 의 pom.xml <dependencies> <dependency> <groupId>org.apache.qpid</groupId> <artifactId>qpid-broker</artifac

1열

1답변

새 소비자가 RabbitMQ에서 과거에 생성 된 메시지를 얼마나 소비합니까?

나는 RabbitMQ를 실행하려고하는 Apache Kafka의 사용자입니다. Kafka는 소비자가 이전에 생성 된 모든 메시지를 소비하도록 지원합니다. (카프카의 로그에서 '오프셋'을 다시 넓혀서) RabbitMQ가 동일한 기능을 갖고 있는지 여부를 알고 싶습니다. 는 (새로운 소비자 와서 특정 시점 이후 모든 메시지를 요청합니다.)

1열

2답변

RabbitMQ 일괄 처리 ACK

rabbitmq가 일괄 처리 승인과 함께 작동하는 방법에 대한 질문이있었습니다. Prefetch 값은 제한에 도달하기 전에 대기열에 들어갈 메시지의 최대 수임을 이해합니다. 그러나 나는 ack이 스스로를 관리하는지 또는 코드에서이를 관리해야하는지 확실하지 않았다. 올바른 방법은 무엇입니까? 가 여러 세트로 각 basicAck 보내기 진정한 또는 대기 (10

0열

1답변

Qpid Proton AMQP 1.0 클라이언트 라이브러리에서 연결의`max_frame_size` 설정하기

Apache Qpid Proton client library을 사용하여 특정 max_frame_size으로 AMQP 1.0 연결을 열고 싶습니다. 이것은 실제 응용 프로그램이 아닌 테스트 스위트 내에 있습니다. Java 라이브러리는 C 라이브러리 및 다른 언어에 대한 다양한 바인딩보다 고급 버전 인 것 같습니다. 따라서 Java 버전을 사용하기 시작했습니다