Java 호출 ActiveMQ 간단한 범례 코드
3514 단어 코드 사양
package jms;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
import org.apache.log4j.PropertyConfigurator;
public class PTP_sends {
public PTP_sends(){
}
private Connection connection;
private String subject = "TOOL.DEFAULT";
public void send(String msg){
try {
connection=connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination=session.createQueue(subject);
MessageProducer producer=session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
TextMessage message = session.createTextMessage(msg);
producer.send(message);
System.out.println(" 。。。。");
message.clearProperties();
session.close();
connection.stop();
connection.close();
System.out.println(" 。。。。");
} catch (JMSException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
PropertyConfigurator.configure("c:\log4j.properties");
PTP_sends ptpSends=new PTP_sends();
ptpSends.send("this is JMS .....");
}
}
package jms;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.log4j.PropertyConfigurator;
public class PTP_receive {
private Connection connection;
private String subject = "TOOL.DEFAULT";
public void receive(){
ActiveMQConnectionFactory connectionFactory =new ActiveMQConnectionFactory();
try {
connection=connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination=session.createQueue(subject);
MessageConsumer consumer=session.createConsumer(destination);
System.out.println(" :");
Message message=consumer.receive();
System.out.println("n message :"+((TextMessage)message).getText());
message.clearProperties();
consumer.close();
session.close();
connection.stop();
connection.close();
System.out.println(" 。。。。");
} catch (JMSException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
PropertyConfigurator.configure("c:\log4j.properties");
PTP_receive receive=new PTP_receive();
receive.receive();
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
하드코드 인코딩이란?설정 정보에 써야 할 정보를 프로그램 코드에 직접 써서 죽인다.2. 상황1, 예를 들어 우리는 메일을 발송하는 프로그램, 사용자 이름, 비밀번호, 서버 주소 등 설정 정보를 외부 설정으로 작성하고 프로그램 코드에서 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.