Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

basic test case for https://issues.apache.org/activemq/browse/AMQ-1763 - but does not show the problem atm 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@790087 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2009-07-01 09:28:56 +00:00
parent 0f1907138b
commit b97dbff52a
1 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
activemq-core/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java
View File

@ -17,10 +17,14 @@
package org.apache.activemq.broker.virtual;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import junit.framework.Test;
import org.apache.activemq.EmbeddedBrokerTestSupport;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
@ -33,6 +37,15 @@ import org.apache.activemq.spring.ConsumerBean;
public class VirtualTopicPubSubTest extends EmbeddedBrokerTestSupport {
private Connection connection;
public int ackMode = Session.AUTO_ACKNOWLEDGE;
public static Test suite() {
return suite(VirtualTopicPubSubTest.class);
}
public void initCombosForTestVirtualTopicCreation() {
addCombinationValues("ackMode", new Object[] {new Integer(Session.AUTO_ACKNOWLEDGE), new Integer(Session.CLIENT_ACKNOWLEDGE) });
}
public void testVirtualTopicCreation() throws Exception {
if (connection == null) {
@ -40,7 +53,19 @@ public class VirtualTopicPubSubTest extends EmbeddedBrokerTestSupport {
}
connection.start();
ConsumerBean messageList = new ConsumerBean();
ConsumerBean messageList = new ConsumerBean() {
public synchronized void onMessage(Message message) {
super.onMessage(message);
if (ackMode == Session.CLIENT_ACKNOWLEDGE) {
try {
message.acknowledge();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
};
messageList.setVerbose(true);
String queueAName = getVirtualTopicConsumerName();
@ -48,7 +73,7 @@ public class VirtualTopicPubSubTest extends EmbeddedBrokerTestSupport {
ActiveMQQueue queue1 = new ActiveMQQueue(queueAName);
ActiveMQQueue queue2 = new ActiveMQQueue(queueAName);
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Session session = connection.createSession(false, ackMode);
MessageConsumer c1 = session.createConsumer(queue1);
MessageConsumer c2 = session.createConsumer(queue2);