activemq持久化消息支持发送离线消息,当消费者不在线或者服务器宕机了,也能保证消息的可靠性。
通过生产持久性消息可以实现问题:activemq发送的消息未被消费能在数据库看到,如何才能获取到这条已发送的消息;另外当这条已发送的消息
被消费之后就从数据库中删除了,怎么样设置activemq 才能使这条消息永久保存在数据库,怎么样获取到这条记录??activemq可以支持点对点模式和发布/订阅模式,如果想要给一个组的所有成员发布消息,希望得到这个消息被打开后的通知,即知道组里面的几个人
已打开该消息,这个组可能是固定的组,也可能是临时组,这样的功能该如何实现??急!!!请高手帮忙!!!
通过生产持久性消息可以实现问题:activemq发送的消息未被消费能在数据库看到,如何才能获取到这条已发送的消息;另外当这条已发送的消息
被消费之后就从数据库中删除了,怎么样设置activemq 才能使这条消息永久保存在数据库,怎么样获取到这条记录??activemq可以支持点对点模式和发布/订阅模式,如果想要给一个组的所有成员发布消息,希望得到这个消息被打开后的通知,即知道组里面的几个人
已打开该消息,这个组可能是固定的组,也可能是临时组,这样的功能该如何实现??急!!!请高手帮忙!!!
怎么样配置可以让数据永久保存的!!!另外,哪位大侠举个activemq + ajax 的应用,我在官网上看半天,没看明白,跑不通简单的例子,
会的大侠帮帮忙啊,急!!! 应该配置些什么东西 我引用下别人的帖子: 没跑通,不知道哪里少配置了还是出了问题!首先建立一个java web工程,修改web.xml<context-param>
<description>The URL of the Message Broker to connect to</description>
<param-name>org.apache.activemq.brokerURL</param-name>
<param-value>tcp://localhost:61616</param-value>
</context-param>
<servlet>
<servlet-name>AjaxServlet</servlet-name>
<servlet-class>org.apache.activemq.web.AjaxServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>AjaxServlet</servlet-name>
<url-pattern>/amq/*</url-pattern>
</servlet-mapping>
建立一个测试JSP页面,我的页面主要代码如下:<%@ page language="java" pageEncoding="gbk"%>
<html>
<head>
<script type="text/javascript" src="amq/amq.js"></script>
<script type="text/javascript">amq.uri='/activemq/amq';</script>
<script>var des = "topic://mqtest"; //<span style="color: rgb(255, 0, 0);">设置一个topic</span>var myHandler =
{
rcvMessage: function(message)
{
var type=message.getAttribute('type');
var from=message.getAttribute('from');
//alert(from);
document.getElementById("distext").value += type+":"+from;
document.getElementById("distext").value += "\r\n";
}
};
amq.addListener("anyID",des,myHandler.rcvMessage); //<span style="color: rgb(255, 0, 0);">添加监听</span>
var go = function(){
var myMessage = document.getElementById("cctext").value;
var uid = document.getElementById("uid").value;
amq.sendMessage(des,"<message type='"+ uid +"' from='" + myMessage + "'/>"); //<span style="color: rgb(255, 0, 0);">发送消息</span>};
</script>
</head>
<body>
<textarea rows="10" cols="50" id="distext"></textarea>
<br>
昵称:<input type="TEXT" id="uid"/><br>
信息:<input type="TEXT" id="cctext"/><br>
<input type="button" value="开始" onclick="go()"/>
</body>
</html>