broker

    0

    1답변

    설치 : asp.net/c#에 양식이 있습니다. 제출시 XML이 개체 모델을 serialize하고 XML serialize 된 데이터를 유일한 매개 변수로 사용하여 저장 프로 시저를 호출합니다. . 저장 프로 시저가 해당 데이터를 SQL 브로커 큐로 보냅니다. 브로커 큐로 보낸 메시지는 큐에 설정된 메시지 계약을 준수하는 유효한 XML이어야합니다. 이 메시

    1

    1답변

    안녕하세요 저는 ActiveMQ에서 다른 검색 프로토콜을 평가 중이며 브로커 네트워크의 멀티 캐스트 검색에 문제가 있습니다. 나는 설정을 멀티 캐스트 그룹 <transportConnectors> <transportConnector name="default" uri="tcp://192.168.11.1:61616" discoveryUri="multicast:/

    4

    2답변

    메시지에 누락 된 타임 스탬프 헤더를 삽입하도록 브로커를 구성 할 수 있습니까? 따라서 게시 클라이언트가 타임 스탬프 헤더를 추가하지 않으면 브로커는 메시지를 교환기가받은 순간과 일치하는 타임 스탬프 값을 삽입 할 수 있습니까? 해당 구성을 어디에서 찾아야합니까? 아니면 나쁜 생각입니까?

    1

    1답변

    카프카 0.7.2를 사용하여 여러 중개인을 시작하려고합니다. Exception in thread "kafka-acceptor" java.net.BindException: Address already in use at sun.nio.ch.Net.bind0(Native Method) at sun.nio.ch.Net.bind(Net.java:444)

    1

    1답변

    Perspective Broker에서 간단한 서버 응답을 구현하려고합니다. 클라이언트는 서버 메소드를 실행하는 서버를 요청하는 서버는 다음 실행 (그의 유일한 목적 메시지 인쇄하는 것입니다 클라이언트 방법을 실행하여) 답장 : 을 가능한 구현은 (가능하면 다른 사람을 제안 해주십시오) [Client-side]: class ClientPrint(pb.Re

    -1

    1답변

    이 장애의 ActiveMQ 큐 케이스를 테스트하고 내 노새가 함께 흐르는하는 방법 "JMS : ActiveMQ를 커넥터"이 같은 : 이것은 내 activemq.xml입니다 <jms:activemq-connector name="Active_MQ" specification="1.1" brokerURL="failover://(tcp://localhost:6161

    1

    1답변

    ActiveMQ 중개자의 간단한 네트워크를 설정하려고합니다. 나는이 기계를 가지고 내가 URI가의 로그에서 기계 B. 지적이 그것 B.에 연결되어있는 것을 알 수있다 networkConnector를 뒀다 A의 activemq.xml 파일에서 A와 B 말 나는 ActiveMQ의 웹 콘솔에서 네트워크 탭에서 메시지를 대기열에 넣거나 대기열에서 빼는 것을 볼 수

    0

    1답변

    사용자 지정 브로커에 대한 질문이 있습니다. 블로그 기사 this의 예를 사용하여 맞춤 브로커를 사용해 보았습니다. "https://dl.dropbox.com/u/17922825/blog/cep-ext-broker.zip"에서 샘플 템플릿 Custom Broker를 다운로드했습니다. 을 CEP_HOME/repository/components/lib에 넣었습

    0

    2답변

    Windows 환경에서 WMB 및 WTX를 함께 사용하는 데 문제가 있습니다. 모든 설치가 성공적으로 설치 된 것 같습니다. 내가 메시지 흐름에서 WTX 노드를 추가 할 때 지금, 나는이 개 예외를 얻을 : com.ibm.websphere.dtx.WTXPlugIn.BrowseLocalCompiledMap.checkCompiledMap에서 java.lang.

    0

    1답변

    WS02 CEP에서 JMS를 사용하여 사용자 지정 브로커를 만들고 싶습니다. NewJMSBrokerType과 NewJMSBrokerTypeFactory의 두 클래스를 만들었습니다. 저는 NewJMSBrokerType에 JMSBrokerType을 확장하고 NewJMSBrokerTypeFactor에 JMSBrokerTypeFactory를 구현합니다. broke