jms 傳送 **:
public static void main(string args) throws exception
session.commit();
session.close();
connection.close();
} 原始碼
copy to clipboard列印?
public static void main(string args) throws exception
session.commit();
session.close();
connection.close();
}
public static void main(string args) throws exception
session.commit();
session.close();
connection.close();
}
jms 接收**:
public static void main(string args) throws exception
});
thread.sleep(30000);
*/
int i=0;
while(i<3)
session.close();
connection.close();
} 原始碼
copy to clipboard列印?
public static void main(string args) throws exception
});
thread.sleep(30000);
*/
int i=0;
while(i<3)
session.close();
connection.close();
}
public static void main(string args) throws exception
});thread.sleep(30000);
*/ int i=0;
while(i<3)
session.close();
connection.close();
}
啟動 jmsreceiver 和 jmssender 可以在看輸出三條時間資訊。當然 jms 還指定有其它格式的資料,如 textmessage
結合 spring 的 jmstemplate 方便用:
} 原始碼
copy to clipboard列印?
public static void main(string args)
});
}
public static void main(string args)
});}
receiver:
public static void main(string args)
} 原始碼
copy to clipboard列印?
public static void main(string args)
}
public static void main(string args)
}
注意:直接用 jms 介面時接收了訊息後要提交一下,否則下次啟動接收者時還可以收到舊資料。有了 jmstemplate 就不用自己提交 session.commit() 了。如果使用了 pooledconnectionfactory 要把 apache-activemq-5.3.0/lib/optional/activemq-pool-5.3.0.jar 加到 classpath
摘自:http://my.oschina.net/liusoft/blog/2907
Active MQ技術文章 JMS
將已經有的mq的demo 傳送到部落格上 如何部署自己部署mq jml理論 wsad環境下jms非同步通訊全攻略 1 學習其對jms說明部分 使用 apache geronimo 和 jms 構建事件驅動的框架 jms 基本可靠性機制 和 事務機制 jms簡介與activemq實戰 總結的挺好的 配...
ActiveMQ的JMS訊息可靠機制
activemq訊息簽收機制 客戶端成功接收一條訊息的標誌是一條訊息被簽收,成功應答。訊息的簽收情形分兩種 1 帶事務的session 如果session帶有事務,並且事務成功提交,則訊息被自動簽收。如果事務回滾,則訊息會被再次傳送。2 不帶事務的session 不帶事務的session的簽收方式,...
JMS學習五(ActiveMQ的本地事務)
1 activemq的本地事務 在乙個jms客戶端,可以使用本地事務來組合訊息的傳送和接收。jms session介面提供了commit和rollback方法。事務提交意味著生產的所有訊息被傳送,消費的所有訊息被確認 事務回滾意味著生產的所有訊息被銷毀,消費的所有訊息被恢復並重新提交,除非它們已經過...