99 lines
2.9 KiB
Java
99 lines
2.9 KiB
Java
/**
|
|
* This software was developed and / or modified by Raytheon Company,
|
|
* pursuant to Contract DG133W-05-CQ-1067 with the US Government.
|
|
*
|
|
* U.S. EXPORT CONTROLLED TECHNICAL DATA
|
|
* This software product contains export-restricted data whose
|
|
* export/transfer/disclosure is restricted by U.S. law. Dissemination
|
|
* to non-U.S. persons whether in the United States or abroad requires
|
|
* an export license or other authorization.
|
|
*
|
|
* Contractor Name: Raytheon Company
|
|
* Contractor Address: 6825 Pine Street, Suite 340
|
|
* Mail Stop B8
|
|
* Omaha, NE 68106
|
|
* 402.291.0100
|
|
*
|
|
* See the AWIPS II Master Rights File ("Master Rights File.pdf") for
|
|
* further licensing information.
|
|
**/
|
|
package com.raytheron.viz.alerts;
|
|
|
|
import javax.jms.Connection;
|
|
import javax.jms.ConnectionFactory;
|
|
import javax.jms.MessageProducer;
|
|
import javax.jms.Session;
|
|
import javax.jms.TextMessage;
|
|
import javax.jms.Topic;
|
|
|
|
import com.raytheon.uf.viz.core.comm.JMSConnection;
|
|
|
|
/**
|
|
* TODO Add Description
|
|
*
|
|
* <pre>
|
|
* SOFTWARE HISTORY
|
|
* Date Ticket# Engineer Description
|
|
* ------------ ---------- ----------- --------------------------
|
|
* May 12, 2008 randerso Initial creation
|
|
*
|
|
* </pre>
|
|
*
|
|
* @author randerso
|
|
* @version 1.0
|
|
*/
|
|
|
|
public class NotificationTest {
|
|
|
|
private static final String ALERT_TOPIC = "edex.alerts";
|
|
|
|
public static void main(String[] args) {
|
|
String topic = ALERT_TOPIC;
|
|
String text = "Hello!";
|
|
|
|
if (args.length == 1) {
|
|
text = args[0];
|
|
} else if (args.length >= 2) {
|
|
topic = args[0];
|
|
text = args[1];
|
|
}
|
|
|
|
Connection connection = null;
|
|
try {
|
|
JMSConnection jms = new JMSConnection("tcp://localhost:61616");
|
|
ConnectionFactory connectionFactory = jms.getFactory();
|
|
|
|
connection = connectionFactory.createConnection();
|
|
Session session = connection.createSession(false,
|
|
Session.AUTO_ACKNOWLEDGE);
|
|
|
|
Topic t = session.createTopic(topic);
|
|
|
|
connection.start();
|
|
|
|
MessageProducer producer = session.createProducer(t);
|
|
|
|
TextMessage message = session.createTextMessage(text);
|
|
System.out.println("\nSending: \"" + message.getText() + "\" to "
|
|
+ topic);
|
|
|
|
producer.send(message);
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
} finally {
|
|
if (connection != null) {
|
|
try {
|
|
connection.close();
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
// ALWAYS close your connection in a finally block to avoid
|
|
// leaks.
|
|
// Closing connection also takes care of closing its related
|
|
// objects e.g. sessions.
|
|
}
|
|
}
|
|
|
|
}
|