package org.jboss.jms.serverless;
import org.jboss.logging.Logger;
import javax.jms.Queue;
import javax.jms.QueueReceiver;
import javax.jms.JMSException;
import javax.jms.Destination;
class QueueReceiverImpl extends MessageConsumerImpl implements QueueReceiver {
private static final Logger log = Logger.getLogger(TopicSubscriberImpl.class);
private String id;
QueueReceiverImpl(SessionImpl session, String id, Queue queue) {
super(session, queue);
this.id = id;
}
public String getID() {
return id;
}
public void close() throws JMSException {
setMessageListener(null);
session.removeConsumer(this);
}
public Queue getQueue() throws JMSException {
return (Queue)getDestination();
}
}