KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > org > apache > activemq > tool > MemProducer


1 /**
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one or more
4  * contributor license agreements. See the NOTICE file distributed with
5  * this work for additional information regarding copyright ownership.
6  * The ASF licenses this file to You under the Apache License, Version 2.0
7  * (the "License"); you may not use this file except in compliance with
8  * the License. You may obtain a copy of the License at
9  *
10  * http://www.apache.org/licenses/LICENSE-2.0
11  *
12  * Unless required by applicable law or agreed to in writing, software
13  * distributed under the License is distributed on an "AS IS" BASIS,
14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15  * See the License for the specific language governing permissions and
16  * limitations under the License.
17  */
18 package org.apache.activemq.tool;
19
20 import javax.jms.Connection JavaDoc;
21 import javax.jms.ConnectionFactory JavaDoc;
22 import javax.jms.DeliveryMode JavaDoc;
23 import javax.jms.Destination JavaDoc;
24 import javax.jms.JMSException JavaDoc;
25 import javax.jms.Message JavaDoc;
26 import javax.jms.MessageProducer JavaDoc;
27 import javax.jms.Session JavaDoc;
28
29 /**
30  * @version $Revision: 1.3 $
31  */
32 public class MemProducer {
33     protected Connection JavaDoc connection;
34     protected MessageProducer JavaDoc producer;
35
36     public MemProducer(ConnectionFactory JavaDoc fac, Destination JavaDoc dest) throws JMSException JavaDoc {
37         connection = fac.createConnection();
38         Session JavaDoc s = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
39         producer = s.createProducer(dest);
40     }
41
42     public void setDeliveryMode(int mode) throws JMSException JavaDoc {
43         producer.setDeliveryMode(mode);
44     }
45
46     public void start() throws JMSException JavaDoc {
47         connection.start();
48     }
49
50     public void stop() throws JMSException JavaDoc {
51         connection.stop();
52     }
53
54     public void shutDown() throws JMSException JavaDoc {
55         connection.close();
56     }
57
58     public void sendMessage(Message JavaDoc msg) throws JMSException JavaDoc {
59         sendMessage(msg, null, 0);
60     }
61
62     /*
63     * allow producer to attach message counter on its header. This will be used to verify message order
64     *
65     */
66     public void sendMessage(Message JavaDoc msg, String JavaDoc headerName, long headerValue) throws JMSException JavaDoc {
67         if (headerName != null) {
68             msg.setLongProperty(headerName, headerValue);
69         }
70
71         producer.send(msg);
72
73     }
74
75 }
76
Popular Tags