消息推送系统

public class MessageProducer {

private final static String BROKER_URL = "tcp://localhost:61616";

private ActiveMQConnectionFactory connectionFactory;

public MessageProducer() {

connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

}

public void sendMessage(String destination, String message) throws JMSException {

Connection connection = connectionFactory.createConnection();

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

Destination dest = session.createQueue(destination);

MessageProducer producer = session.createProducer(dest);

TextMessage textMessage = session.createTextMessage(message);

走班排课软件

producer.send(textMessage);

System.out.println("Sent message: " + message);

connection.close();

}

}

]]>