1 24 package com.scalagent.kjoram; 25 26 import com.scalagent.kjoram.excepts.IllegalStateException; 27 import com.scalagent.kjoram.excepts.JMSException; 28 29 30 public class QueueReceiver extends MessageConsumer 31 { 32 42 QueueReceiver(QueueSession sess, Queue queue, 43 String selector) throws JMSException 44 { 45 super(sess, queue, selector); 46 } 47 48 49 public String toString() 50 { 51 return "QueueRec:" + sess.ident; 52 } 53 54 59 public Queue getQueue() throws JMSException 60 { 61 if (closed) 62 throw new IllegalStateException ("Forbidden call on a closed receiver."); 63 64 return (Queue) dest; 65 } 66 } 67 | Popular Tags |