1 /**
2 *
3 * Copyright 2003-2004 The Apache Software Foundation
4 *
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
8 *
9 * http://www.apache.org/licenses/LICENSE-2.0
10 *
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 */
17
18 //
19 // This source code implements specifications defined by the Java
20 // Community Process. In order to remain compliant with the specification
21 // DO NOT add / change / or delete method signatures!
22 //
23
24 package javax.jms;
25
26 import com.mockobjects.jms.MockMessage;
27 import com.mockobjects.jms.MockQueue;
28 import com.mockobjects.jms.MockQueueReceiver;
29 import com.mockobjects.jms.MockQueueSender;
30 import com.mockobjects.jms.MockQueueSession;
31 import com.mockobjects.jms.MockTemporaryQueue;
32 import com.mockobjects.jms.MockTextMessage;
33
34 import junit.framework.TestCase;
35
36
37 /**
38 * @version $Rev: 46019 $ $Date: 2004-09-14 02:56:06 -0700 (Tue, 14 Sep 2004) $
39 */
40 public class QueueRequestorTest extends TestCase {
41 public void testConstructorNullQueue() {
42 MockQueue queue = new MockQueue();
43
44 try {
45 new QueueRequestor(null, queue);
46 fail();
47 } catch (JMSException ex) {
48 fail("JMSException should not have been thrown.");
49 } catch (NullPointerException ex) {
50 // success.
51 }
52
53 queue.verify();
54 }
55
56 public void testConstructorSessionNull() {
57 MockQueueSession session = new MockQueueSession();
58
59 try {
60 new QueueRequestor(session, null);
61 fail();
62 } catch (JMSException ex) {
63 // success
64 }
65
66 session.verify();
67 }
68
69 public void testConstructorSessionQueue() {
70 MockQueue queue = new MockQueue();
71 MockQueueReceiver receiver = new MockQueueReceiver();
72 MockQueueSender sender = new MockQueueSender();
73 MockQueueSession session = new MockQueueSession();
74 MockTemporaryQueue tempQueue = new MockTemporaryQueue();
75
76 session.setupReceiver(receiver);
77 session.setupSender(sender);
78 session.setupTemporaryQueue(tempQueue);
79
80 try {
81 new QueueRequestor(session, queue);
82 // success
83 } catch (JMSException ex) {
84 fail();
85 }
86
87 queue.verify();
88 receiver.verify();
89 sender.verify();
90 session.verify();
91 tempQueue.verify();
92 }
93
94 public void testRequestNull() {
95 MockQueue queue = new MockQueue();
96 MockQueueReceiver receiver = new MockQueueReceiver();
97 MockQueueSender sender = new MockQueueSender();
98 MockQueueSession session = new MockQueueSession();
99 MockTemporaryQueue tempQueue = new MockTemporaryQueue();
100
101 session.setupReceiver(receiver);
102 session.setupSender(sender);
103 session.setupTemporaryQueue(tempQueue);
104
105 try {
106 QueueRequestor requestor = new QueueRequestor(session, queue);
107 requestor.request(null);
108 fail();
109 } catch (JMSException ex) {
110 fail("JMSException should not have been thrown.");
111 } catch (NullPointerException ex) {
112 // success
113 }
114
115 queue.verify();
116 receiver.verify();
117 sender.verify();
118 session.verify();
119 tempQueue.verify();
120 }
121
122 public void testRequestMessage() {
123 MockMessage reply = new MockTextMessage();
124 MockMessage request = new MockTextMessage();
125 MockQueue queue = new MockQueue();
126 MockQueueReceiver receiver = new MockQueueReceiver();
127 MockQueueSender sender = new MockQueueSender();
128 MockQueueSession session = new MockQueueSession();
129 MockTemporaryQueue tempQueue = new MockTemporaryQueue();
130
131 request.setExpectedJMSReplyTo(tempQueue);
132
133 receiver.setExpectedReceiveCalls(1);
134 receiver.setupReceivedMessage(reply);
135
136 sender.setExpectedSendCalls(1);
137
138 session.setupReceiver(receiver);
139 session.setupSender(sender);
140 session.setupTemporaryQueue(tempQueue);
141
142 try {
143 QueueRequestor requestor = new QueueRequestor(session, queue);
144 Message jmsReply = requestor.request(request);
145 assertEquals(jmsReply, reply);
146 } catch (JMSException ex) {
147 fail("JMSException should not have been thrown.");
148 }
149
150 reply.verify();
151 request.verify();
152 queue.verify();
153 receiver.verify();
154 sender.verify();
155 session.verify();
156 tempQueue.verify();
157 }
158
159 public void testClose() {
160 MockQueue queue = new MockQueue();
161 MockQueueReceiver receiver = new MockQueueReceiver();
162 MockQueueSender sender = new MockQueueSender();
163 MockQueueSession session = new MockQueueSession();
164 MockTemporaryQueue tempQueue = new MockTemporaryQueue();
165
166 session.setExpectedCloseCalls(1);
167 session.setupReceiver(receiver);
168 session.setupSender(sender);
169 session.setupTemporaryQueue(tempQueue);
170
171 tempQueue.setExpectedDeleteCalls(1);
172
173 try {
174 QueueRequestor requestor = new QueueRequestor(session, queue);
175 requestor.close();
176 } catch (JMSException ex) {
177 fail();
178 }
179
180 queue.verify();
181 receiver.verify();
182 sender.verify();
183 session.verify();
184 tempQueue.verify();
185 }
186 }
Save This Page