一个weblogic的jms问题
各位大虾：
小弟使用weblogic作为中间件发送jms消息时遇到一个问题就是，当重新启动接收端容器的时候。容器会接收一些已经接收过的消息。所以小弟想请问一下各位大虾，怎样在收到jms消息加以处理以后，将这个消息清除。我的发送端代码和客户端代码如下：
下面是发送端代码：
public class JmsCommons {
private QueueConnectionFactory qconFactory;
private QueueConnection qcon;
private QueueSession qsession;
private QueueSender qsender;
private Queue queue;
//4个参数：
public JmsCommons(String paramString1, String paramString2,
String paramString3, String paramString4) {
try {
Hashtable localHashtable = new Hashtable();
localHashtable.put("java.naming.factory.initial", paramString2);
localHashtable.put("java.naming.provider.url", paramString1);
InitialContext localInitialContext = new InitialContext(
localHashtable);
this.qconFactory = ((QueueConnectionFactory) localInitialContext
.lookup(paramString3));
this.qcon = this.qconFactory.createQueueConnection();
this.qsession = this.qcon.createQueueSession(false, 1);
this.queue = ((Queue) localInitialContext.lookup(paramString4));
this.qsender = this.qsession.createSender(this.queue);
} catch (Exception localException) {
localException.printStackTrace();
}
}
public void sendMessage(String paramString) {
try {
this.qcon.start();
TextMessage localTextMessage = this.qsession
.createTextMessage(paramString);
this.qsender.send(localTextMessage);
this.qsender.close();
} catch (Exception localException) {
localException.printStackTrace();
}
}
下面是接收端的一个监听线程
public class ReceiveJmsMessage implements Runnable {
private String jndi_factory;
private String jms_factory;
private String jms_queue;
private String url;
private MessageConsumer comsumer;
private TSjjhDsrwDao rwDao;
private TSjjhXxrzDao xxDao;
public ReceiveJmsMessage(){}
public ReceiveJmsMessage(String jndi_factory, String jms_factory,
String jms_queue,String url,TSjjhDsrwDao rwDao,TSjjhXxrzDao xxDao) {
this.jndi_factory = jndi_factory;
this.jms_factory = jms_factory;
this.jms_queue = jms_queue;
this.url=url;
this.rwDao=rwDao;
this.xxDao=xxDao;
}
public void receive() {
Hashtable<String,String> env=new Hashtable<String, String>();
env.put(Context.INITIAL_CONTEXT_FACTORY,jndi_factory);
env.put(Context.PROVIDER_URL,url);
try {
Context context=new InitialContext(env);
Queue queue=null;
queue=(Queue) context.lookup(jms_queue);
QueueConnectionFactory factory=null;
factory=(QueueConnectionFactory) context.lookup(jms_factory);
if (factory!=null&&queue!=null) {
QueueConnection queueconnection = null;
queueconnection = factory.createQueueConnection();
if(queueconnection!=null){
queueconnection.start();
QueueSession queuesession = null;
queuesession = (WLQueueSession)queueconnection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
if (queuesession!=null) {
comsumer = queuesession.createConsumer(queue);
}else{
System.out.println("JMS 监听接收失败");
}
}else{
System.out.println("JMS 监听接收失败");
}
}else{
System.out.println("JMS 监听接收失败");
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void run() {
try {
receive();
while (true) {
Objectxmlmessage = comsumer.receive(1000);
if (xmlmessage!=null&&(xmlmessage instanceof TextMessage)) {
//相关处理逻辑
}
Thread.sleep(5000);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
[解决办法]
没弄过啊，帮你顶了。加油啊
