2012-07-13 2 views
1

tibco 랑데부에 수신기를 만들려고합니다. 나는 특정 주제를 듣고 싶다. 나는 그것과 같을하기로되어 있다고 알고 있어요 :TIBCO에서 수신기 만들기 Rendezvous

TibrvListener(
TibrvQueue queue, 
TibrvMsgCallback callback, 
TibrvTransport transport, 
java.lang.String subject, 
java.lang.Object closure) 
throws TibrvException 

이 코드가 있습니다. 그러나 나는 두 가지를 모릅니다. TibrvMsgCallback 개체는 어떻게 만듭니 까? 운송 수단을 어떻게 통과합니까? 저는 메시지를 별도의 프로그램으로 보내는 발행인을 보유하고 있습니다. 구독 프로그램에서 동일한 전송 항목을 다시 생성합니까?

queue = new TibrvQueue(); 
dispatcher = new TibrvDispatcher(queue); 
queue.setName(key); 
this.listener = new TibrvListener(queue, null, null, subject, null); 
TibrvTransport message = this.listener.getTransport(); 

답변

3

당신은 먼저 Tibrv Tibrv.open (Tibrv.IMPL_NATIVE)를 엽니 다;

전송 만들기 TibrvTransport transport = new TibrvRvdTransport (서비스, 네트워크, 데몬);

리스너 만들기 new TibrvListener (Tibrv.defaultQueue(), this, transport, subject, null);

리스너 인 경우

은 "이"당신의 클래스는 onMsg에 도착 처리 할 수 ​​TibrvMsgCallback

메시지를 구현하기 위해 (TibrvListener 리스너, TibrvMsg MSG) 방법을 필요로한다.

+0

대단히 감사합니다! 그것은 매우 도움이되었다! 내가 아직 이해할 수없는 유일한 것은 TibrvMsgCallback을 만드는 방법입니다. – Lemonio

+0

TibrvMsgCallback을 만들지 마십시오. tibrv msgs를 처리하려는 클래스는 클래스가 onMsg() 메소드를 구현할 수 있도록 해당 인터페이스를 구현해야합니다. Tibco 설치시 TIBRV \ src \ examples \ java와 같은 예가 있습니까? – aditya

+0

아 나는 implements를 추가 한 다음 onMsg 메서드를 추가합니다. 아니, 내가 어둠 속에서 기본적으로 프로그램을 작성하려고 노력하고있어 전혀 예제가 없다 : ( – Lemonio