Clover coverage report -

Coverage timestamp: Sat Jul 7 2007 16:41:13 CEST

FRAMES NO FRAMES

file stats:	LOC:	88		Methods:	4
	NCLOC:	58		Classes:	1

Source file

Conditionals

Statements

Methods

TOTAL

MDBTest.java

50%

96.2%

75%

88.2%

1		/*
2		* MDBTest.java
3		*
4		* Created on September 16, 2006, 10:40 AM
5		*
6		* To change this template, choose Tools \| Template Manager
7		* and open the template in the editor.
8		*/
9
10		package jtr.test.jee.client;
11
12		import javax.jms.DeliveryMode;
13		import javax.jms.JMSException;
14		import javax.jms.Message;
15		import javax.jms.Queue;
16		import javax.jms.QueueConnection;
17		import javax.jms.QueueConnectionFactory;
18		import javax.jms.QueueReceiver;
19		import javax.jms.QueueSender;
20		import javax.jms.QueueSession;
21		import javax.jms.TemporaryQueue;
22		import javax.jms.TextMessage;
23		import jtr.runners.AbstractJMSRunner;
24		import jtr.test.IOutcome;
25
26		/**
27		*
28		* @author Francesco Russo (frusso@dev.java.net)
29		*/
30		public class MDBTest extends AbstractJMSRunner /implements MessageListener/ {
31
32	4894	public void test() throws Throwable {
33		// let's prepare receiving the response message
34	4894	TemporaryQueue rplQueue = queueSess.createTemporaryQueue();
35	4884	qRcvr = queueSess.createReceiver(rplQueue);
36		//qRcvr.setMessageListener(this);
37	4895	queueConn.start();
38
39		// let's send the message
40	4899	QueueSender sender = queueSess.createSender(queue);
41	4899	logger.info("Created a sender");
42
43	4899	TextMessage msg = queueSess.createTextMessage(msgPayload+this.getName());
44	4900	msg.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
45	4895	msg.setJMSExpiration(1200000);
46	4899	msg.setJMSReplyTo(rplQueue);
47	4896	logger.info("Created a txt msg");
48
49	4896	sender.send(msg);
50
51	4898	queueSess.commit();
52	4890	logger.info("Message sent");
53	4896	sender.close();
54
55	4895	Message m = qRcvr.receive();
56	4838	System.out.println("Received a response message: "+((TextMessage)m).getText());
57	4900	queueSess.commit();
58	4889	qRcvr.close();
59	4894	rplQueue.delete();
60		}
61
62	4900	public void enrichOutcome(IOutcome outcome) {
63	4900	outcome.setUserObject("Using enterprise "+getEnterprise().getUniqueName()+
64		"\nUsing jms "+getJmsConfig().getUniqueName());
65		}
66
67	0	public void receiveFailureNotification(Throwable throwable, String string) {
68		}
69
70	14	public void cleanupResources() {
71	14	try {
72	14	if(queueSess!=null)
73	14	queueSess.close();
74	14	if(queueConn!=null)
75	14	queueConn.stop();
76		} catch(JMSException e) {
77	0	logger.error("Error cleaning-up resources held by runner "+getName(),e);
78		}
79		}
80
81		private QueueConnectionFactory queueConnFactory;
82		private QueueConnection queueConn;
83		private QueueSession queueSess;
84		private Queue queue;
85		private String msgPayload;
86
87		private QueueReceiver qRcvr;
88		}