Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /*    */ package javax.jms;
 /*    */ 
 /*    */ public class QueueRequestor
 /*    */ {
 /* 33 */   private QueueSession queueSession = null;
 /*    */ 
 /* 35 */   private QueueSender requestSender = null;
 /*    */ 
 /* 37 */   private QueueReceiver replyReceiver = null;
/*    */ 
/* 39 */   private TemporaryQueue replyQueue = null;
/*    */ 
/*    */   public QueueRequestor(QueueSession sessionQueue queuethrows JMSException
/*    */   {
/* 43 */     this. = session;
/*    */ 
/* 45 */     this. = this..createSender(queue);
/* 46 */     this. = this..createTemporaryQueue();
/* 47 */     this. = this..createReceiver(this.);
/*    */   }
/*    */ 
/*    */   public Message request(Message messagethrows JMSException
/*    */   {
/* 52 */     message.setJMSReplyTo(this.);
/* 53 */     message.setJMSDeliveryMode(1);
/* 54 */     this..send(message);
/* 55 */     return this..receive();
/*    */   }
/*    */ 
/*    */   public void close() throws JMSException
/*    */   {
/*    */     try
/*    */     {
/* 62 */       this..close();
/*    */     }
/*    */     catch (JMSException ignored)
/*    */     {
/*    */     }
/*    */     try
/*    */     {
/* 69 */       this..delete();
/*    */     }
/*    */     catch (JMSException ignored)
/*    */     {
/*    */     }
/* 74 */     this..close();
/*    */   }
/*    */ }
/* Location:           /home/mnovotny/projects/EMBEDDED_JBOSS_BETA3_COMMUNITY/embedded/output/lib/embedded-jboss/lib/jboss-embedded-all.jar
 * Qualified Name:     javax.jms.QueueRequestor
 * JD-Core Version:    0.6.0
 */
New to GrepCode? Check out our FAQ X