public RemoteReceiveQueue createRemoteReceiveQueue ( String strQueueName , String strQueueType ) throws RemoteException { MessageManager messageManager = this . getEnvironment ( ) . getMessageManager ( this . getApplication ( ) , true ) ; BaseMessageReceiver receiver = ( BaseMessageReceiver ) messageManager . getMessageQueue ( strQueueName , strQueueType ) . getMessageReceiver ( ) ; ReceiveQueueSession remoteQueue = new ReceiveQueueSession ( this , receiver ) ; return remoteQueue ; }
Create the remote receive queue .