ActiveMQ 및 JMS를 사용 중입니다. 대기열에 ObjectMessage를 만들었습니다. 나는 그것을받을 수 없다. 대기열에서 이미 사용할 수있는 메시지를 확인하십시오. 메시지를 수신 내 코드는 더 이상 선명도 또는 코드가 필요한 경우, 요청하시기 바랍니다 public class RecieveObjectQueue {
public static
이것은 내포 된 브로커에 메시지를 보내는 구성입니다. 또한 첫 번째 bean 메소드는 브로커를 만들고 시작하는 데 사용됩니다. 인스턴스를 리턴하지 않습니다. 이 코드가 브로커를 시작합니까? JMS 템플리트의 send 메소드를 사용하여 아래에 언급 된 주제로 메시지를 보냈습니다. 브로커가 생성되고 실행되도록 createbrokerservice를 작성했습니다.
다음 코드를 사용하여 주제로 게시하고 있습니다. 그것은 public interface Event {
public boolean isEmpty();
public AcEventDatafileTransaction getDatafileTransaction();
public AcEventObjectTransaction getObjec
수신자 clientA, clientB, clientC 등으로 내구성 주제와 세 개의 클라이언트가 있다고 가정합니다. clientA는 2 시간 동안 작동하지 않습니다. clientA가 작동하면 clientA가 지난 2 시간 동안의 모든 메시지를받을 수 있습니다 (중단 시간에 놓친 메시지).
ActiveMQ 브로커의 문서를 Elasticsearch로 색인화해야합니다. JMS 입력 플러그인 (jriver-jms를 기반으로 빌드 됨)을 사용하여 logstash를 사용하고 있습니다. ActiveMQ 브로커의 주제에 저장된 모든 문서가 Elasticsearch에 저장되도록해야하므로 logstash를 사용하여 영구 가입을 설정하려고합니다. 어떻게해야합니
난 내가 내부에 아무것도 표시되지 않는 큐에 JMSToolBox을 통해 연결하는 경우 제이 보스 EAP 6. Right now I am see that I have 4 messages stuck in-flight inside JBoss 내부 기내 메시지 무엇인지에 대한 명확한 정의를 찾을 수 없어. jboss 서버를 다시 시작한 후에야 기내에서 사라졌습니다
소비자가 실패 할 때 JMS 메시지의 재전송을 보장해야하지만 여기에서 비슷한 질문에 허용되는 전략이 내 케이스에 적용되지 않을 수 있습니다. JMS 클라이언트 - 스프링 + activeMq - 손실되거나 복제 될 수없는 메시지를받는 경우를 고려하십시오. 메시지 처리에 비용이 많이 들기 때문에 클라이언트는이를 일괄 적으로 처리합니다. 이 시나리오는 다음과 같
JMS 대기열에 메시지를 넣는 응용 프로그램이 있습니다. 메시지 크기는 최대 150MB까지 가능합니다. JMS 메시지에는 xml과 같은 추가 메타 데이터가있는 바이트 배열 데이터가 들어 있습니다. 메시지가 대기열에 배치되면 낙타 경로 응용 프로그램은 메시지를 선택하고 message와 함께 외부 Java API를 호출합니다 .i는 낙타 jms를 사용하여 JM
activemq의 큐를 사용하여 가상 토픽의 메시지를 큐에서 제거하려고합니다. 일부 메시지를 보내려고했지만 "메시지 대기열에 포함"항목 아래에 나타나지만 소비 할 수는 없습니다. 내가 만든 가상 주제 이름은 VirtualTopic.AA이고 소비자의 이름은 Consumer.client1.VirtualTopic.AA입니다. consumer.client1.Vir