Source code: org/objectweb/jtests/jms/conform/session/QueueSessionTest.java
1 /*
2 * JORAM: Java(TM) Open Reliable Asynchronous Messaging
3 * Copyright (C) 2002 INRIA
4 * Contact: joram-team@objectweb.org
5 *
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or any later version.
10 *
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
15 *
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
19 * USA
20 *
21 * Initial developer(s): Jeff Mesnil (jmesnil@inrialpes.fr)
22 * Contributor(s): ______________________________________.
23 */
24
25 package org.objectweb.jtests.jms.conform.session;
26
27 import org.objectweb.jtests.jms.framework.*;
28 import junit.framework.*;
29
30 import javax.jms.*;
31
32 /**
33 * Test queue sessions
34 * <br />
35 * See JMS specifications, §4.4 Session
36 *
37 * @author Jeff Mesnil (jmesnil@inrialpes.fr)
38 * @version $Id: QueueSessionTest.java,v 1.1 2002/04/21 21:15:19 chirino Exp $
39 */
40 public class QueueSessionTest extends PTPTestCase {
41
42 /**
43 * Test that if we rollback a transaction which has consumed a message,
44 * the message is effectively redelivered.
45 */
46 public void testRollbackRececeivedMessage() {
47 try {
48 senderConnection.stop();
49 // senderSession has been created as non transacted
50 // we create it again but as a transacted session
51 senderSession = senderConnection.createQueueSession(true, 0);
52 assertEquals(true, senderSession.getTransacted());
53 // we create again the sender
54 sender = senderSession.createSender(senderQueue);
55 senderConnection.start();
56
57 receiverConnection.stop();
58 // receiverSession has been created as non transacted
59 // we create it again but as a transacted session
60 receiverSession = receiverConnection.createQueueSession(true,0);
61 assertEquals(true, receiverSession.getTransacted());
62 // we create again the receiver
63 receiver = receiverSession.createReceiver(receiverQueue);
64 receiverConnection.start();
65
66 // we send a message...
67 TextMessage message = senderSession.createTextMessage();
68 message.setText("testRollbackRececeivedMessage");
69 sender.send(message);
70 // ... and commit the *producer* transaction
71 senderSession.commit();
72
73 // we receive a message...
74 Message m = receiver.receiveNoWait();
75 assertTrue(m != null);
76 assertTrue(m instanceof TextMessage);
77 TextMessage msg = (TextMessage)m;
78 // ... which is the one which was sent...
79 assertEquals("testRollbackRececeivedMessage", msg.getText());
80 // ...and has not been redelivered
81 assertEquals(false, msg.getJMSRedelivered());
82
83 // we rollback the *consumer* transaction
84 receiverSession.rollback();
85
86 // we receive again a message
87 m = receiver.receiveNoWait();
88 assertTrue(m != null);
89 assertTrue(m instanceof TextMessage);
90 msg = (TextMessage)m;
91 // ... which is still the one which was sent...
92 assertEquals("testRollbackRececeivedMessage", msg.getText());
93 // .. but this time, it has been redelivered
94 assertEquals(true, msg.getJMSRedelivered());
95
96 } catch (Exception e) {
97 fail(e);
98 }
99 }
100
101 /**
102 * Test that a call to the <code>createBrowser()</code> method with an invalid
103 * messaeg session throws a <code>javax.jms.InvalidSelectorException</code>.
104 */
105 public void testCreateBrowser_2() {
106 try {
107 QueueBrowser browser = senderSession.createBrowser(senderQueue,
108 "definitely not a message selector!");
109 fail("Should throw a javax.jms.InvalidSelectorException.\n");
110 } catch (InvalidSelectorException e) {
111 } catch (JMSException e) {
112 fail("Should throw a javax.jms.InvalidSelectorException, not a "+ e);
113 }
114 }
115
116 /**
117 * Test that a call to the <code>createBrowser()</code> method with an invalid
118 * <code>Queue</code> throws a <code>javax.jms.InvalidDestinationException</code>.
119 */
120 public void testCreateBrowser_1() {
121 try {
122 QueueBrowser browser = senderSession.createBrowser((Queue)null);
123 fail("Should throw a javax.jms.InvalidDestinationException.\n");
124 } catch (InvalidDestinationException e) {
125 } catch (JMSException e) {
126 fail("Should throw a javax.jms.InvalidDestinationException, not a "+ e);
127 }
128 }
129
130 /**
131 * Test that a call to the <code>createReceiver()</code> method with an invalid
132 * message selector throws a <code>javax.jms.InvalidSelectorException</code>.
133 */
134 public void testCreateReceiver_2() {
135 try {
136 receiver = senderSession.createReceiver(senderQueue,
137 "definitely not a message selector!");
138 fail("Should throw a javax.jms.InvalidSelectorException.\n");
139 } catch (InvalidSelectorException e) {
140 } catch (JMSException e) {
141 fail("Should throw a javax.jms.InvalidSelectorException, not a "+ e);
142 }
143 }
144
145 /**
146 * Test that a call to the <code>createReceiver()</code> method with an invalid
147 * <code>Queue</code> throws a <code>javax.jms.InvalidDestinationException</code>>
148 */
149 public void testCreateReceiver_1() {
150 try {
151 receiver = senderSession.createReceiver((Queue)null);
152 fail("Should throw a javax.jms.InvalidDestinationException.\n");
153 } catch (InvalidDestinationException e) {
154 } catch (JMSException e) {
155 fail("Should throw a javax.jms.InvalidDestinationException, not a "+ e);
156 }
157 }
158
159 /**
160 * Method to use this class in a Test suite
161 */
162 public static Test suite() {
163 return new TestSuite(QueueSessionTest.class);
164 }
165
166 public QueueSessionTest(String name) {
167 super(name);
168 }
169 }