/* Copyright 1999-2011 (c) My-Channels Copyright (c) 2012-2015 Software AG, Darmstadt, Germany and/or Software AG USA Inc., Reston, VA, USA, and/or its subsidiaries and/or its affiliates and/or their licensors. Use, reproduction, transfer, publication or disclosure is prohibited except as specifically provided for in your License Agreement with Software AG. */ package com.pcbsys.nirvana.nJMSApps; import com.pcbsys.foundation.utils.fEnvironment; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.StreamMessage; public class StreamMessageSubscriber extends Subscriber { static public String sClassVersion = "$Name: not supported by cvs2svn $ - $Revision: 1.13 $"; public StreamMessageSubscriber(String factoryName, String destinationName) { super(factoryName, destinationName); } public static void main(String[] args) { //Check to see if args were specified if ((args.length == 1) && args[0].equals("-?")) { UsageEnv(); } if (args.length < 2) { Usage(); System.exit(1); } //Process Environment Variables processEnvironmentVariable("RNAME"); processEnvironmentVariable("PRINCIPAL"); processEnvironmentVariable("PASSWORD"); processEnvironmentVariable("CONTEXT_FACTORY"); processEnvironmentVariable("PROVIDER_URL"); processEnvironmentVariable("LOGLEVEL"); processEnvironmentVariable("HPROXY"); processEnvironmentVariable("HAUTH"); processEnvironmentVariable("CKEYSTORE"); processEnvironmentVariable("CKEYSTOREPASSWD"); processEnvironmentVariable("CAKEYSTORE"); processEnvironmentVariable("CAKEYSTOREPASSWD"); // Install any proxy server settings fEnvironment.setProxyEnvironments(); // Install any ssl settings fEnvironment.setSSLEnvironments(); //Create an instance for this class StreamMessageSubscriber subscriber = new StreamMessageSubscriber(args[0], args[1]); boolean transacted = false; String selector = null; if (args.length > 2) { transacted = new Boolean(args[2]).booleanValue(); } if (args.length > 3) { selector = args[3]; } //Subscribe to the destination specified subscriber.doIt(args[0], args[1], transacted, selector); } /** * A callback is received by the API to this method each time a message is received from * the destination. * * @param msg A JMS Message object */ public void onMessage(Message msg) { try { if (msg instanceof StreamMessage) { StreamMessage smsg = (StreamMessage) msg; System.out.println("JMS MSG ID : " + smsg.getJMSMessageID()); System.out.println("JMS DELIVERY MODE : " + smsg.getJMSDeliveryMode()); System.out.println("JMS TIME STAMP : " + smsg.getJMSTimestamp()); System.out.println("Data : " + smsg.readString()); System.out.println("Count : " + smsg.readInt()); System.out.println("Transacted : " + smsg.readBoolean()); } else { super.onMessage(msg); } if (transacted) { s.commit(); } } catch (JMSException e) { e.printStackTrace(); } count++; } /** * Prints the usage message for this class */ protected static void Usage() { System.out.println("Usage ...\n\n"); System.out.println("jmsstreamsub \n"); System.out.println(" \n"); JMSClient.printFactoryNameUsage(); JMSClient.printDestinationNameUsage(); System.out.println(" - Whether the session is transacted"); System.out.println(" - An optional message selector"); System.out.println("\n\nNote: -? provides help on environment variables \n"); } } // End of StreamMessageSubscriber Class