message-queue

1열

1답변

차라리 것 별도의 CommandBus 및 EventBus 또한 ICommandHandler<TCommand> 및 IEventHandler<TCommand> 그래서 같은 OrderEventHandler 클래스는 보이는 것을 : 가능한 솔루션은 Masstransit 인프라와 내 CQRS (같은 ConsumerToHandlerAdopter<T> 사이의 채택을 제

0열

1답변

RabbitMQ 내의 데이터베이스간에 데이터 변경 사항을 게시하는 방법은 무엇입니까?

각각 다른 데이터베이스 A1 (MySQL)과 B1 (Postgres)을 가진 두 개의 응용 프로그램 A과 B이 있다고 가정합니다. 응용 프로그램 A에서 엔티티 X과 Y이 서로 연결되어 있습니다. Y은 X에 속합니다. A1 (커밋 후) 데이터베이스에 삽입 할 때마다 RabbitMQ에 메시지를 게시하여 B 응용 프로그램을 새로운 엔티티에 알립니다. 엔티티 당

1열

1답변

데드 - 레터 (dead-letter) 메시지가있을 때 건너 뛴 대기열을 만들지 마십시오.

요청/응답 시나리오에서 _skipped 대기열을 만들지 않도록 선택할 수 있습니까? 우리는 이런 식으로 우리의 응용 프로그램을 구축하기로 결정했습니다 (이유는 묻지 않습니다). 우리는 여러 소비자에게 PublishRequest를하고 있으며 단 한 명의 소비자 만 응답합니다. 다른 모든 것들은 건너 뛴 대기열을 생성합니다 (시간 초과 오류). 나는이 구조를

1열

1답변

rabbitmq을 잠금 서비스로 사용할 수 없다면 무엇을 할 수 있습니까?

두 가지 주요 문제는 다음과 같습니다 네트워크 장애에 탄력하지 네트워크 파티션에 탄력하지 가 잠금 서비스로 사용할 수있는 이유는이 문서가 말한다 : https://www.rabbitmq.com/blog/2014/02/19/distributed-semaphores-with-rabbitmq/ 이 기사에서는 위에 나열된 문제로 인해 왜이 문서를 사용할 수 없는지

0열

1답변

동일한 트랜잭션에서 대기열에서 큐를 제거하고 큐에 넣을 수 있습니까?

큐에서 큐에 넣고 자하는 메시지가 대기열에서 제거 된 직후에 다른 큐에 다른 큐를 큐에 넣고 싶습니다. 나는이 모든 것을 같은 거래에서하고 싶다. rabbitmq 또는 다른 대기열 서비스에서 이것이 가능합니까?

0열

1답변

ActiveMQ와의 Spring 통합 : 큐에 보류중인 메시지가 더 이상 없을 때 알림 가져 오기

ActiveMQ와의 스프링 통합으로 작업하고 있습니다. 내 대기열이 비어있을 때 (보류중인 메시지가 없을 때) 몇 가지 프로세스를 수행해야한다는 요구 사항이 있습니다. 나는 <bean id="my.jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <propert

3열

1답변

재정은 다음과

가 TFrame 하위 클래스가 CM_ENABLEDCHANGED) 사용할 수 없습니다. 첫 번째 아이디어는 가상 메서드 TControl.SetEnabled을 재정의하는 것이 었습니다. 그 구현을 살펴보면 실제로 값이 다를 때 제어 메시지 CM_ENABLEDCHANGED을 수행하는 것을 보았습니다. 올바른 방법으로 프레임의 Enabled 상태를 툴바에 적용하는

0열

1답변

메시지가 비어 있는지 확인하는 방법

그래서 하루 종일이 작업을 해오 고 그것을 파악하지 못했습니다. 비어있는 메시지가 수신자 또는 서버로 전달되었는지 확인한 다음 큐를 연결 해제해야하는지 확인해야합니다. 이것은 내가 무엇을 가지고 : mq_receive 매뉴얼에서 while((c=getopt(argc, argv, ":q:"))!=-1){ switch(c){ case 'q'

1열

2답변

Azure 서비스 버스 주제 구독자 수신 주문

내 솔루션의 메시지 브로커로 하늘색 서비스 버스 주제가 사용됩니다. 각 구독에 대한 나의 이해에 따라 Azure Message Bus는 가상 큐을 유지하므로 메시지의 수신 최종 주문이 방해받지 않아야합니다. 그러나 실제로는 내 시나리오에서는 약간 다릅니다 내가 언젠가의 수신기를 분리하면 입력은 대략 매 2 초 후, (타임 스탬프가 올바른지 나는 그것을 확인

0열

1답변

각 SQS 메시지에는 어떤 종류의 데이터가 포함될 수 있습니까?

타사 API 호출을 통해 사용자를 업데이트하는 작업이 있다고 가정합니다. 실제 사용자 데이터를 메시지 안에 넣어도 괜찮습니까? 또는 작업자가 로컬 데이터베이스에서 업데이트 된 레코드를 검색 할 수 있도록 메시지에 ID 만 제공해야합니까?