ActiveMQ 를 사용 하여 수신 대기 열 (Queue) 메 시 지 를 보 냅 니 다.
그리고 시작 하면 windows 에서 bin 의 activemq. bat 를 직접 실행 할 수 있 습 니 다.
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
QueueConnection connection = factory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("queue");
QueueSender sender = session.createSender(queue);
TextMessage message = session.createTextMessage();
message.setText("Hello ActiveMQ");
sender.send(message);
connection.close();ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
QueueConnection queueConnection = factory.createQueueConnection();
QueueSession session = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue(txtKeyWord.getText());
QueueReceiver receiver = session.createReceiver(queue);
receiver.setMessageListener(new MessageListener() {
public void onMessage(Message message) {
if(message instanceof TextMessage){
TextMessage textMessage = (TextMessage)message;
try {
textArea.append(">>" + textMessage.getText() + "
");
textArea.setCaretPosition(textArea.getDocument().getLength());
textMessage.acknowledge();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
});
queueConnection.start();이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
자바 파일 압축 및 압축 풀기파일 의 간단 한 압축 과 압축 해 제 를 실현 하 였 다.주요 테스트 용 에는 급 하 게 쓸 수 있 는 부분 이 있 으 니 불편 한 점 이 있 으 면 아낌없이 가르쳐 주 십시오. 1. 중국어 문 제 를 해 결 했 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
