关于activeMQ的消息监听

Question

你的我没看  我前几天刚做了 一个activeMQ 的程序  
等会 我给你发!

Answer 1

我现在正在研究IBM MQ的你有没?

Answer 2

public void run() {
Connection connection = null;
try {
System.out.println("Connecting to URL: " + url);
System.out.println("Publishing a Message with size " + messageSize
+ " to " + (topic ? "topic" : "queue" + ": " + subject));
System.out.println("Using "
+ (persistent ? "persistent" : "non-persistent"
+ " messages"));
System.out.println("Sleeping between publish " + sleepTime + " ms");
if (timeToLive != 0) {
System.out.println("Messages time to live " + timeToLive
+ " ms");
} // Create the connection.
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
user, password, url);
//---------------------------------------
//-----------------------------------------

connection = connectionFactory.createConnection();
connection.start(); // Create the session
Session session = connection.createSession(transacted,
Session.AUTO_ACKNOWLEDGE);
//队列取数据========================================
//=================================================
if (topic) {
destination = session.createTopic(subject);
} else {
destination = session.createQueue(subject);
}         //QueueSession sessionQ =(QueueSession)connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
        //QueueReceiver receiver=sessionQ.createReceiver((Queue) destination);
// Create the producer.
MessageProducer producer = session.createProducer(destination);
/*
try{
            TextMessage tm = (TextMessage) receiver.receive();
            System.out.println("receive successful!");
            String messageContent = tm.getText();
            System.out.println("The content of the receiving message is:" + messageContent); }catch(Exception ex){
ex.getStackTrace();
ex.getMessage();
}finally{
receiver.close();
}
*/
if (persistent) {
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
} else {
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
}
if (timeToLive != 0)
producer.setTimeToLive(timeToLive); // Start sending messages
sendLoop(session, producer); System.out.println("Done."); // Use the ActiveMQConnection interface to dump the connection stats.
ActiveMQConnection c = (ActiveMQConnection) connection;
c.getConnectionStats().dump(new IndentPrinter()); } catch (Exception e) {
System.out.println("Caught: " + e);
e.printStackTrace();
} finally {
try {
connection.close();
} catch (Throwable ignore) {
}
}
}

Answer 3

有没有大侠出来说一下啊..~~activeMQ 能不能用于即时通讯?~

Answer 4

求一高人给个activemq基于web例子,分不够可以加啊..万分感谢~真的很急啊`email [email protected]