2014-02-25 4 views
0

STOMP 가입에 선택기를 구현하기위한 클라이언트 측 설정.ActiveMQ - 선택자와 STOMP 가입이 실패 함

var headers = {hello: 'worldtest'}; 
console.log(event.get('header').data.eventType); 
var connectCallback = function(frame) { 
stompClient.subscribe("/topic/receipt", function(frame){console.log(frame);}, headers); 
stompClient.send("/app/" + url.join('/'), {"content-type": "text/plain"}, message); 
}; 

구독 반환 같은 프레임의 콘솔에 로그 메시지 :

body: ""<message>test</message>"" 
command: "MESSAGE" 
headers: Object 
content-length: "343" 
content-type: "application/json;charset=UTF-8" 
destination: "/topic/receipt" 
hello: "world" 
message-id: "4hw8wlab-1" 
subscription: "sub-0" 

가 메시지 인해 선택에 필터링되지 않았을 하는가? 내 선택기의 구문?

아래 구문을 변경해도 작동하지 않았습니다. 이 경우 메시지가 전혀 반환되지 않았습니다.

var headers = {'selector': "hello = 'world'"}; 

무엇이 누락 되었습니까?

+0

어떤 STOMP 클라이언트 라이브러리를 사용하고 있습니까? 왜 콜백 메소드에 가입하고 있습니까? 선택기를 제대로 제공하지 않는 것 같으므로 subscribe 메소드의 설명서를 읽으십시오. – Buchi

답변

0

나는 헤더 안에 선택기를 보낼 수있는 길을 게시 할 수 있습니다 ..보기 : 나는 STOMP 및 목표 - C를 사용하고

Headers:{ 
    "activemq.advisory" = true; 
    "activemq.prefetchSize" = 1; 
    selector = "switch = 'green'"; 
} 

...

나는 희망이 도움이

...