org.huihoo.jfox.ms.jms.queue
Class QueueSenderImpl

java.lang.Object
  org.huihoo.jfox.ms.jms.base.MessageProducerImpl
      org.huihoo.jfox.ms.jms.queue.QueueSenderImpl

All Implemented Interfaces:

javax.jms.MessageProducer, javax.jms.QueueSender

public class QueueSenderImpl

extends MessageProducerImpl

implements javax.jms.QueueSender

This class implements the JMS queue sender. A client uses a QueueSender object to send messages to a queue.

Modifications:

• 2003-05-20 - Original code completed.
• 2003-06-14 - implement createQueue(String queueName) implement send(Message message) implement send(Message message, int deliveryMode, int priority, long timeToLive) implement send(Queue queue, Message message) implement send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive)

Since:

0.1 2003-05-20 21:37:30

Version:

0.1.1 2003-06-14 20:59:05

Author:

Yong.Cheng

Field Summary

Fields inherited from class org.huihoo.jfox.ms.jms.base.MessageProducerImpl

defaultDeliveryMode, defaultPriority, defaultTimeToLive, disableMessageID, disableMessageTimestamp

Constructor Summary

QueueSenderImpl(QueueSessionImpl queueSession, javax.jms.Queue queue)

Method Summary

void	close() Closes the queue sender.
javax.jms.Queue	getQueue() Retrieve a reference of queue destionation.
void	send(javax.jms.Message message) Send message to server.
void	send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) Send message to server.
void	send(javax.jms.Queue queue, javax.jms.Message message) Send message to server.
void	send(javax.jms.Queue queue, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) Send mesage to server.

Methods inherited from class org.huihoo.jfox.ms.jms.base.MessageProducerImpl

getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, isClosed, sendMessage, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.MessageProducer

getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Constructor Detail

QueueSenderImpl

public QueueSenderImpl(QueueSessionImpl queueSession,
                       javax.jms.Queue queue)

Parameters:

queueSession -

queue -

Method Detail

getQueue

public javax.jms.Queue getQueue()
                         throws javax.jms.JMSException

Retrieve a reference of queue destionation.

Specified by:

getQueue in interface javax.jms.QueueSender

Returns:

Queue

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Message message)
          throws javax.jms.JMSException

Send message to server.

Specified by:

send in interface javax.jms.QueueSender

Parameters:

message -

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException

Send message to server.

Specified by:

send in interface javax.jms.QueueSender

Parameters:

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Queue queue,
                 javax.jms.Message message)
          throws javax.jms.JMSException

Send message to server.

Specified by:

send in interface javax.jms.QueueSender

Parameters:

queue -

message -

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Queue queue,
                 javax.jms.Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws javax.jms.JMSException

Send mesage to server.

Specified by:

send in interface javax.jms.QueueSender

Parameters:

queue -

message -

deliveryMode -

priority -

timeToLive -

Throws:

javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

Closes the queue sender.

Since a provider may allocate some resources on behalf of a MessageProducer outside the Java virtual machine, clients should close them when they are not needed. Relying on garbage collection to eventually reclaim these resources may not be timely enough.

Specified by:

close in interface javax.jms.MessageProducer

Overrides:

close in class MessageProducerImpl

Throws:

javax.jms.JMSException