1 29 30 package com.caucho.jms.amq; 31 32 import com.caucho.jms.message.MessageImpl; 33 import com.caucho.jms.session.SessionImpl; 34 import com.caucho.util.L10N; 35 36 import javax.jms.JMSException ; 37 import javax.jms.Queue ; 38 import javax.jms.QueueReceiver ; 39 import java.util.logging.Level ; 40 import java.util.logging.Logger ; 41 42 45 public class AmqQueueConsumer extends AmqMessageConsumer 46 implements QueueReceiver 47 { 48 private static final Logger log 49 = Logger.getLogger(AmqQueueConsumer.class.getName()); 50 private static final L10N L = new L10N(AmqQueueConsumer.class); 51 52 private AmqQueue _queue; 53 54 public AmqQueueConsumer(SessionImpl session, String messageSelector, 55 AmqQueue queue) 56 throws JMSException 57 { 58 super(session, messageSelector, queue, false); 59 60 _queue = queue; 61 62 if (log.isLoggable(Level.FINE)) 63 log.fine("AmqQueueConsumer[" + queue + "] created"); 64 } 65 66 69 public Queue getQueue() 70 { 71 return _queue; 72 } 73 74 77 protected MessageImpl receiveImpl() 78 throws JMSException 79 { 80 return null; 81 } 82 83 86 public void acknowledge() 87 throws JMSException 88 { 89 } 90 91 94 public void rollback() 95 throws JMSException 96 { 97 } 98 99 102 public void close() 103 throws JMSException 104 { 105 } 106 107 110 public String toString() 111 { 112 return "AmqQueueConsumer[" + _queue + "]"; 113 } 114 } 115 116 | Popular Tags |