최근 내가 메시징을 구현하는 데 필요한 실행 가능한 옵션은 프로젝트 작업을 시작 : 아파치 Qpid 또는 RabbitMq, 내 작업은 다음과 같이이다 : . + A + >> [수백만 장치 (생산자) - 연결됨 - 메시징 서버는 (클러스터 - Qpid 또는 RabbitMQ)] {LOAD 균형) 그리고 + B + >> [메시징 서버 (클러스터링 됨 - Qpid
다음과 같은 시나리오가 있습니다. 2 명의 사용자가 공유하는 큐로 100 개의 메시지를 푸시합니다. 두 구독자 모두 사전 획득 모드와 명시 적 모드에서 큐에 구독합니다. 각 메시지가 처리 된 후 각 구독자는 큐에서 메시지를 제거하기 위해 메시지를 수락합니다. 각 메시지는 한 번에 한 번 처리하고, OnMessageTransfer(message) :
누구나 QPID를 사용하는 방법에 대한 링크를 공유 할 수 있습니까? 나는 http://qpid.apache.org/을 체크 아웃했으며 Java QPID 중개인을 시작할 수 있었지만 여기서부터 어디로 가야할 지 모릅니다. 누군가가 브로커를 사용하고 Java 또는 C#으로 메시지를 보내고 브로커를 사용하려면 샘플 앱이 있거나 둘이 있으면 좋을 것입니다. 그렇
아파치 qpid-cpp 메시징 api가 ActiveMQ에서와 같이 메시지 배달을 지연시키는 것을 지원합니까? TextMessage message = session.createTextMessage("test msg");
long time = 60 * 1000;
message.setLongProperty(ScheduledMessage.AMQ_
나는 아파치 qpid 자바 클라이언트 (내가 아파치 낙타를 사용해야하기 때문에)와 함께 rabbitmq-server를 소비해야한다. 하지만 두 버전의 버전과 혼동 스럽습니다. 특히 각각이 지원하는 amqp 프로토콜 때문입니다. qpid가 사용할 수있는 버전은 rabbitmq-server의 마지막 안정 릴리스를 사용할 수 있습니까? 또는 가능한 최상의 쌍 버
문제점에 대한 간단한 POC가 있습니다. ObjectMessage를 읽고 Qpid 큐에 쓸 소비자와 소비자가 있습니다. Dummy 객체에있는 모든 것은 문자열입니다. Dummy 객체는 Serializable입니다. 생산자는 오류를 던지지 않고 객체를 대기열에 쓰고있는 것 같지만 대기열을 듣고있는 Consumer는 Dummy 객체를 직렬화 해제 할 수 없습니