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

test case for: https://issues.apache.org/activemq/browse/AMQ-2383 - works on trunk 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@813734 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2009-09-11 09:17:43 +00:00
parent 0e8eadb8fb
commit 28443226b6
1 changed files with 49 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2383Test.java Normal file
View File

@ -0,0 +1,49 @@
package org.apache.activemq.bugs;
import static org.junit.Assert.*;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
import org.junit.Test;
public class AMQ2383Test {
@Test
public void activeMQTest() throws Exception {
Destination dest = ActiveMQQueue.createDestination("testQueue", ActiveMQQueue.QUEUE_TYPE);
ConnectionFactory factory = new ActiveMQConnectionFactory(
"vm://localhost?broker.useJmx=false&broker.persistent=false");
Connection producerConnection = factory.createConnection();
producerConnection.start();
Connection consumerConnection = factory.createConnection();
consumerConnection.start();
Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = producerSession.createProducer(dest);
TextMessage sentMsg = producerSession.createTextMessage("test...");
producer.send(sentMsg);
producerSession.close();
Session consumerSession = consumerConnection.createSession(true, Session.SESSION_TRANSACTED);
MessageConsumer consumer = consumerSession.createConsumer(dest);
TextMessage receivedMsg = (TextMessage)consumer.receive();
consumerSession.rollback();
consumerSession.close();
assertEquals(sentMsg, receivedMsg);
Thread.sleep(10000);
producerConnection.close();
consumerConnection.close();
}
}