/** * Create a new local queue */ protected void createQueue(MQeQueueManager localQM, String qMgrName, String queueName, String description, String queueStore ) throws Exception { /* * Create an empty queue admin message and parameters field */ MQeQueueAdminMsg msg = new MQeQueueAdminMsg(); MQeFields parms = new MQeFields(); /* * Prime message with who to reply to and a unique identifier */ MQeFields msgTest = primeAdminMsg( msg ); /* * Set name of queue to manage */ msg.setName( qMgrName, queueName ); /* * Add any characteristics of queue here, otherwise * charateristics will be left to default values. / if ( description != null ) // set the description ? parms.putUnicode( MQeQueueAdminMsg.Queue_Description, description); if ( queueStore != null ) // Set the queue store ? // If queue store includes directory and file info then it // must be set to the correct style for the system that the // queue will reside on e.g \ or / parms.putAscii(MQeQueueAdminMsg.Queue_FileDesc, queueStore ); /* * Other queue characteristics like queue depth, message expiry * can be set here … */ /* * Set the admin action to create a new queue */ msg.create( parms ); /* * Put the admin message to the admin queue (not assured delivery) */ localQM.putMessage( qMgrName, MQe.Admin_Queue_Name, msg, null, 0); }
Parent topic: Local queue