1 29 30 package com.caucho.jms.amq; 31 32 import com.caucho.jms.session.MessageConsumerImpl; 33 import com.caucho.jms.session.SessionImpl; 34 import com.caucho.util.L10N; 35 36 import javax.jms.JMSException ; 37 import java.util.logging.Logger ; 38 39 42 public class AmqMessageConsumer extends MessageConsumerImpl 43 { 44 private static final Logger log 45 = Logger.getLogger(AmqMessageConsumer.class.getName()); 46 private static final L10N L = new L10N(AmqMessageConsumer.class); 47 48 private AmqQueue _queue; 49 50 public AmqMessageConsumer(SessionImpl session, String messageSelector, 51 AmqQueue queue, boolean isTopic) 52 throws JMSException 53 { 54 super(session, messageSelector, queue, isTopic); 55 56 _queue = queue; 57 } 58 59 62 public void close() 63 throws JMSException 64 { 65 } 66 67 70 public String toString() 71 { 72 return "AmqMessageConsumer[" + _queue + "]"; 73 } 74 } 75 76 | Popular Tags |