ActiveMQ - stomp 프로토콜 수신 메시지
1774 단어 activemq
/**
* stomp JMS
* @param args
*/
@SuppressWarnings("unchecked")
public static void main(String[] args) throws Exception
{
StompConnection conn = new StompConnection();
conn.open("127.0.0.1", 61613);
conn.connect("user1", "password1");
HashMap<String, String> headers = new HashMap<String,String>();
headers.put(Stomp.Headers.TRANSFORMATION, "jms-stomp-map-json");
conn.subscribe(JMSInfo.STOMP_QUEUE_NAME, Subscribe.AckModeValues.AUTO, headers);
// conn.subscribe(JMSInfo.STOMP_TOPIC_NAME, Subscribe.AckModeValues.AUTO, headers);
while (true) {
try {
StompFrame msg = conn.receive(60000);
String dataType = msg.getHeaders().get("dataType");
String className = msg.getHeaders().get("className");
String text = msg.getBody();
if ("json".equals(dataType) && "java.util.Map".equals(className)) {
Map<String, Object> map = JsonUtils.toJavaObject(text, Map.class);
System.out.println("received map: " + map);
} else {
System.out.println("received text: " + text);
}
// 0.5
Thread.sleep(500);
} catch (Exception e) {
e.printStackTrace();
break;
}
}
conn.unsubscribe(JMSInfo.STOMP_QUEUE_NAME);
// conn.unsubscribe(JMSInfo.STOMP_TOPIC_NAME);
conn.disconnect();
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
activeMQ의 질문오늘은 mule로 activeMQ와 통합할 때, mule를 시작할 때 항상 activeMQ의 시작에 머물러 있습니다.원본 코드를 보니 active MQ에 사순환이 생겼습니다. 위의 코드에서dolock은 시종일관fal...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.