/*     */ package javax.jms;
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ public class TopicRequestor
/*     */ {
/*     */   TopicSession session;
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   Topic topic;
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   TemporaryTopic tempTopic;
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   TopicPublisher publisher;
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   TopicSubscriber subscriber;
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   public TopicRequestor(TopicSession session, Topic topic)
/*     */     throws JMSException
/*     */   {
/*  85 */     this.session = session;
/*  86 */     this.topic = topic;
/*  87 */     this.tempTopic = session.createTemporaryTopic();
/*  88 */     this.publisher = session.createPublisher(topic);
/*  89 */     this.subscriber = session.createSubscriber(this.tempTopic);
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   public Message request(Message message)
/*     */     throws JMSException
/*     */   {
/* 107 */     message.setJMSReplyTo(this.tempTopic);
/* 108 */     this.publisher.publish(message);
/* 109 */     return this.subscriber.receive();
/*     */   }
/*     */   
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */ 
/*     */   public void close()
/*     */     throws JMSException
/*     */   {
/* 133 */     this.session.close();
/* 134 */     this.tempTopic.delete();
/*     */   }
/*     */ }


/* Location:              D:\git\basic_core_2\base-stable\core-log4j\lib\javax.jms.jar!\javax\jms\TopicRequestor.class
 * Java compiler version: 5 (49.0)
 * JD-Core Version:       0.7.1
 */