如何在Activemq中回滚消息 [英] How to rollback messages in Activemq
问题描述
当变量 x
值等于 1时,我想向
。如果它不等于 Activemq
发送确认 1
,我想将消息重新发送到 Activemq
。然后只有 Activemq
再次向订阅者传递消息。为此,我编写了以下程序。
I want to send acknowledgement to Activemq
when variable x
value is equals to 1
.If it not equals to 1
,I want to redeliver messages to Activemq
. Then only Activemq
delivers that messages again to subscribers.For this I written the following programs.
MessageConsumer.java:
MessageConsumer.java :
public class Consumer extends HttpServlet {
@Override
protected void service(HttpServletRequest arg0, HttpServletResponse arg1)
throws ServletException, IOException {
try {
ActiveMQConnectionFactory connectionFactory=new ActiveMQConnectionFactory("admin","admin","tcp://localhost:61617");
RedeliveryPolicy policy = new RedeliveryPolicy();
policy.setInitialRedeliveryDelay(1000L);
policy.setMaximumRedeliveries(RedeliveryPolicy.NO_MAXIMUM_REDELIVERIES);
connectionFactory.setRedeliveryPolicy(policy);
connectionFactory.setUseRetroactiveConsumer(true);
Connection connection=connectionFactory.createConnection();
final Session session=connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
Topic queue=session.createTopic("MessageTesting");
javax.jms.MessageConsumer consumer=session.createConsumer(queue);
//anonymous class
MessageListener listener = new MessageListener() {
@Override
public void onMessage(Message msg) {
TextMessage msg1=(TextMessage)msg;
try {
String messageBody=msg1.getText();
if (x==1) {
//Process was completely done,so I am sending acknowledge
session.commit();
}
else {
//Process is not done sucessfully, So I want to redeliver messages, For this
session.rollback();
}
}
catch (Exception e) {
e.printStackTrace();
}
}
};
consumer.setMessageListener(listener);
connection.start();
}
}
这是正确的做法。你建议我有没有办法。
Is this correct way to do this.can you suggest me,Is there any efficient way.
谢谢。
推荐答案
理想情况下,您必须:
为您的绑定地址创建 ActiveMQConnectionFactory ,
创建 RedeliveryPolicy 并将其设置为 ActiveMQConnectionFactory 。
创建会话并使用 session.commit()(如果为true)和 session.rollback()(如果失败)。
Create a ActiveMQConnectionFactory to your binding address, Create a RedeliveryPolicy and set it to ActiveMQConnectionFactory. Create a Session and use session.commit() if true and session.rollback() if it failed.
这两个链接可能对您有所帮助:
These two links might help you:
http://activemq.apache.org/message-redelivery-and-dlq-handling.html
http://activemq.apache.org/redelivery-policy.html
public class Consumer extends HttpServlet {
@Override
protected void service(HttpServletRequest arg0, HttpServletResponse arg1)
throws ServletException, IOException {
try {
...
MessageListener listener = new MessageListener() {
public void onMessage(Message msg) {
....
}
};
....
}
}
这篇关于如何在Activemq中回滚消息的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!