jms-topic

    0

    1답변

    두 개의 토픽 사이에 브릿지를 설정하려고합니다. 아이디어는 이것이다 : 알림이 이 통지는 HornetQ 서버 B에 대한 주제로 전송됩니다 HornetQ 서버의 주제에 게시됩니다 클라이언트 응용 프로그램은 도착 (A 다리?) 서버 B로부터의 통보. 내가 이것을 할 필요가있는 이유는, 서버 B가 다운 된 경우에, 우리는 여전히 주제를 올려서 결국 구독 서버에

    1

    1답변

    누군가가 Network of Brokers의 컨텍스트에서 activemq 가상 주제의 동작을 명확히 할 수 있습니까? 가입 전파에 혼란이 있습니다. 예를 들어 다른 브로커와 네트워크 커넥터가있는 브로커가 있습니다. 그런 다음 <networkConnectors> <networkConnector name="connectorToRemoteBroker

    0

    1답변

    여러 주제의 소비자 메시지를 작성하고 메시지를 변형 한 다음 여러 주제로 게시 할 수있는 애플리케이션을 구축 중입니다. ConnectionFactory에 객체를 검토 한 결과,이 코드 Connection con = cf.createConnection(); String clientId = "APP"+ con.hashCode(); con.setClientI

    0

    1답변

    메시지를 수신하기 위해 많은 MQ 클라이언트가 연결된 주제가 있다고 가정 해보십시오. 제 질문은 MQ 서버가 언제 주제에서 메시지를 제거합니까? 첫째 : MQ 큐 관리자가 해당 주제에 등록 된 모든 가입자에게 출판물을 제공합니다

    4

    1답변

    ActiveMQ JMS 주제의 메시지를 모니터하고 가장 중요한 메시지를 삭제하는 방법이 있습니까? 한 달 이전의 메시지를 삭제하십시오. Apache Camel을 사용하여 ActiveMQ Connection 및 JMS 항목을 작성하고 있습니다.

    1

    2답변

    JMS 대기열과 관련하여 질문이 있습니다. 공유 대기열을 사용하는 jms 발신자/수신자를 나에게 알리는 유일한 대기열로 사용할 수있는 유일한 대기열로 구현했습니다. 내가 지금 직면하고있는 문제는 내가 처음으로 온 것처럼 나는 내 생산자로부터 보내는 메시지가 내 고객에 의해 소비 될 것이고 다른 큐로는이 큐를 공유하지 않을 것임을 확신 할 수 없다는 것입니다

    0

    3답변

    지식을 얻고 JMS (activemq)를 사용하기 시작했습니다. 의사 코드는 다음과 같습니다. // 1. TopicConnectionFactory tcf = (TopicConnectionFactory) ctx.lookup ("XXConnFactory"); // 2. TopicConnection connection = tcf.createTopicConnect

    1

    1답변

    기본 프리 페치를 사용하여 여러 구독 클라이언트가 실행중인 주제가 있습니다. 클라이언트 중 하나가 느리면 다른 가입 클라이언트의 속도가 느려집니다. 나는 느린 소비자를 위해 프리 페치 (prefetch)를 동적으로 낮추고 싶지만 클라이언트는 무작위로 느려지므로 동적으로 수행해야 할 필요가있다. 다음 솔루션을 프로토 타입 화하고 싶습니다. 각 구독자에 대한

    0

    1답변

    OpenEJB에서 메시지 구동 Bean과 함께 Topic을 사용하려고합니다. 에 그래서 내가 편집 한 conf의/openejb.xml는 : <?xml version="1.0" encoding="UTF-8"?> <openejb> <Resource id="TrueUpdate" type="javax.jms.Topic"> destination

    0

    1답변

    Jboss를 사용하여 JMS 용 샘플 프로그램을 작성하려고합니다. 나는 JMS http://docs.jboss.org/jbossmessaging/docs/usermanual-2.0.0.beta1/html/using-jms.html 내가 ConnectionFactory를 즉 "iniCtx.lookup ("ConnectionFactory에 ")" javax.n