| SpyQueueSender.java |
/*
* JBossMQ, the OpenSource JMS implementation
*
* Distributable under LGPL license. See terms of license at gnu.org.
*/
package org.jboss.mq;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueSender;
/**
* This class implements javax.jms.QueueSender
*
* A sender created with a null Queue will now be interpreted as created as an
* unidentifyed sender and follows the spec in throwing
* UnsupportedOperationException at the correct places.
*
* @author Norbert Lataille (Norbert.Lataille@m4x.org)
* @author Hiram Chirino (Cojonudo14@hotmail.com)
* @author <a href="pra@tim.se">Peter Antman</a>
* @author <a href="mailto:adrian@jboss.org">Adrian Brock</a>
* @version $Revision: 1.9 $
*/
public class SpyQueueSender extends SpyMessageProducer implements QueueSender
{
// Constants -----------------------------------------------------
// Attributes ----------------------------------------------------
// Static --------------------------------------------------------
// Constructors --------------------------------------------------
/**
* Create a new SpyQueueSender
*
* @param session the session
* @param queue the queue
*/
SpyQueueSender(SpySession session, Queue queue)
{
super(session, queue);
}
// Public --------------------------------------------------------
// QueueSender implementation ------------------------------------
public Queue getQueue() throws JMSException
{
return (Queue) getDestination();
}
public void send(Queue queue, Message message) throws JMSException
{
send((Destination) queue, message);
}
public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
{
send((Destination) queue, message, deliveryMode, priority, timeToLive);
}
// Package protected ---------------------------------------------
// Protected -----------------------------------------------------
// Private -------------------------------------------------------
// Inner classes -------------------------------------------------
}| SpyQueueSender.java |