/* 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.apps; import com.pcbsys.nirvana.client.*; /** * Deletes a nirvana queue */ public class deleteQueue extends nSampleApp { private static deleteQueue mySelf=null; /** * This method demonstrates the Nirvana API calls necessary to delete * a queue. * It is called after all command line arguments have been received and * validated * * @param realmDetails a String[] containing the possible RNAME values * @param queueName the queue name to delete */ private void doit(String[] realmDetails, String queueName ) { mySelf.constructSession(realmDetails); //Deletes the specified queue try{ //Create a channel attributes object nChannelAttributes nca = new nChannelAttributes(); nca.setName( queueName ); //Delete the queue mySession.deleteQueue( nca ); } //Handle errors catch(nChannelNotFoundException cnfe){ System.out.println("The queue specified could not be found."); System.out.println("Please ensure that the queue exists in the REALM you connect to."); cnfe.printStackTrace(); System.exit(1); } catch (nSecurityException se) { System.out.println("Insufficient permissions for the requested operation."); System.out.println("Please check the ACL settings on the server."); se.printStackTrace(); System.exit(1); } catch (nSessionNotConnectedException snce) { System.out.println("The session object used is not physically connected to the Nirvana realm."); System.out.println("Please ensure the realm is up and check your RNAME value."); snce.printStackTrace(); System.exit(1); } catch (nUnexpectedResponseException ure) { System.out.println("The Nirvana REALM has returned an unexpected response."); System.out.println("Please ensure the Nirvana REALM and client API used are compatible."); ure.printStackTrace(); System.exit(1); } catch (nUnknownRemoteRealmException urre) { System.out.println("The queue specified resided in a remote realm which could not be found."); System.out.println("Please ensure the queue name specified is correct."); urre.printStackTrace(); System.exit(1); } catch (nRequestTimedOutException rtoe) { System.out.println("The requested operation has timed out waiting for a response from the REALM."); System.out.println("If this is a very busy REALM ask your administrator to increase the client timeout values."); rtoe.printStackTrace(); System.exit(1); } catch (nBaseClientException nbce) { System.out.println("An error occured while creating the Channel Attributes object."); nbce.printStackTrace(); System.exit(1); } //Close the session we opened try{ nSessionFactory.close ( mySession ); } catch(Exception ex){} //Close any other sessions within this JVM so that we can exit nSessionFactory.shutdown ( ); } protected void processArgs(String[] args){ switch (args.length){ case 1: if (args[0].equals("-?")) { Usage(); UsageEnv(); } System.getProperties().put("QUEUENAME",args[0]); break; } } public static void main( String[] args ) { //Create an instance for this class mySelf = new deleteQueue(); //Process command line arguments mySelf.processArgs(args); //Process Environment Variables nSampleApp.processEnvironmentVariables(); //Check the queue name specified String queueName=null; if ( System.getProperty( "QUEUENAME" ) != null ) queueName= System.getProperty( "QUEUENAME" ) ; else{ Usage(); System.exit( 1 ); } //Check the local realm details int idx = 0; String RNAME=null; if ( System.getProperty( "RNAME" ) != null ) RNAME= System.getProperty( "RNAME" ) ; else{ Usage(); System.exit( 1 ); } //Process the local REALM RNAME details String[] rproperties = new String[4]; rproperties=parseRealmProperties(RNAME); //delete the queue specified mySelf.doit(rproperties, queueName); } /** * Prints the usage message for this class */ private static void Usage() { System.out.println( "Usage ...\n" ); System.out.println("ndelq \n"); System.out.println( " \n"); System.out.println( " - Queue name parameter for the channel to delete" ); System.out.println( "\n\nNote: -? provides help on environment variables \n"); } } // End of deleteQueue Class