KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > com > sun > j2ee > blueprints > opc > webservice > invoicercvr > TopicHelper


1 /*
2  * Copyright 2002 Sun Microsystems, Inc. All rights reserved.
3  *
4  * Redistribution and use in source and binary forms, with or without
5  * modification, are permitted provided that the following conditions
6  * are met:
7  *
8  * - Redistributions of source code must retain the above copyright
9  * notice, this list of conditions and the following disclaimer.
10  *
11  * - Redistribution in binary form must reproduce the above copyright
12  * notice, this list of conditions and the following disclaimer in
13  * the documentation and/or other materials provided with the
14  * distribution.
15  *
16  * Neither the name of Sun Microsystems, Inc. or the names of
17  * contributors may be used to endorse or promote products derived
18  * from this software without specific prior written permission.
19  *
20  * This software is provided "AS IS," without a warranty of any
21  * kind. ALL EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND
22  * WARRANTIES, INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY,
23  * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY
24  * EXCLUDED. SUN AND ITS LICENSORS SHALL NOT BE LIABLE FOR ANY DAMAGES
25  * SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING OR
26  * DISTRIBUTING THE SOFTWARE OR ITS DERIVATIVES. IN NO EVENT WILL SUN
27  * OR ITS LICENSORS BE LIABLE FOR ANY LOST REVENUE, PROFIT OR DATA, OR
28  * FOR DIRECT, INDIRECT, SPECIAL, CONSEQUENTIAL, INCIDENTAL OR
29  * PUNITIVE DAMAGES, HOWEVER CAUSED AND REGARDLESS OF THE THEORY OF
30  * LIABILITY, ARISING OUT OF THE USE OF OR INABILITY TO USE SOFTWARE,
31  * EVEN IF SUN HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
32  *
33  * You acknowledge that Software is not designed, licensed or intended
34  * for use in the design, construction, operation or maintenance of
35  * any nuclear facility.
36  */
37
38 package com.sun.j2ee.blueprints.opc.webservice.invoicercvr;
39
40 import javax.jms.*;
41
42 /**
43  * A helper class which takes care of sending a JMS message to a topic
44  */
45 public class TopicHelper {
46
47   private Topic topic;
48   private TopicConnectionFactory topicFactory;
49
50
51   /**
52    *
53    * @param qFactory is the connection factory used to get a connection
54    * @param q is the Queue to send the message to
55    */
56   public TopicHelper(TopicConnectionFactory topicFactory, Topic topic) {
57     this.topicFactory = topicFactory;
58     this.topic = topic;
59     return;
60   }
61
62   /**
63    * Helper method that can be uses to send string message to the topic
64    * @param xmlMessage the text message to be sent
65    * @throws <Code>JMSException</Code> on failure to send
66    */
67   public void sendMessage(String xmlMessage) throws JMSException {
68     TopicConnection connection = null;
69     TopicSession session = null;
70     try {
71       connection = topicFactory.createTopicConnection();
72       session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
73       TopicPublisher publisher = session.createPublisher(topic);
74       connection.start();
75       TextMessage message = session.createTextMessage();
76       message.setText(xmlMessage);
77       publisher.publish(message);
78     } finally {
79       try {
80         if(session != null) {
81             session.close();
82         }
83         if(connection != null) {
84             connection.close();
85         }
86       } catch(Exception exception) {
87             exception.printStackTrace(System.err);
88       }
89     }
90     return;
91   }
92 }
93
Popular Tags