jrun.jms.core.client
Class JmsMessageProducer

jrun.jms.core.client.JmsMessageProducer

public abstract class JmsMessageProducer

A client uses this class to deliver messages to a destination. This base class defines some methods which can be used to hold some default values including defualt time to live and default priority. A MessageProducer must always be created with a non-null session and destination. The session identifies the controlling entity.

Version:

$Revision: 1.7 $ $Date: 2001/10/12 07:55:31 $

Author:

Jim Alateras

Field Summary

protected JmsSession

_session This is the session_ that created this producer.

Constructor Summary

JmsMessageProducer(JmsSession session)
The constructor is used to associated a session with this producer.

Method Summary

void	close()
void	destroy() Release all resources used by this consumer
int	getDeliveryMode()
boolean	getDisableMessageID()
boolean	getDisableMessageTimestamp()
protected Logger	getLogger() Return a reference to the logger.
int	getPriority()
long	getTimeToLive()
boolean	isClosed()
protected void	sendMessage(javax.jms.Message message) Send the following message to the server.
void	setDeliveryMode(int deliveryMode)
void	setDisableMessageID(boolean value)
void	setDisableMessageTimestamp(boolean value)
void	setPriority(int defaultPriority)
void	setTimeToLive(long timeToLive)

Field Detail

_session

protected JmsSession _session

This is the session_ that created this producer.

Constructor Detail

JmsMessageProducer

public JmsMessageProducer(JmsSession session)
                   throws javax.jms.JMSException

The constructor is used to associated a session with this producer.

If the construction fails either because the session or the destination are null then throw JMSException

Parameters:

session - session responsible for this producer

Throws:

JMSException -

Method Detail

isClosed

public boolean isClosed()

setDisableMessageID

public void setDisableMessageID(boolean value)
                         throws javax.jms.JMSException

getDisableMessageID

public boolean getDisableMessageID()
                            throws javax.jms.JMSException

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean value)
                                throws javax.jms.JMSException

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws javax.jms.JMSException

setDeliveryMode

public void setDeliveryMode(int deliveryMode)
                     throws javax.jms.JMSException

getDeliveryMode

public int getDeliveryMode()
                    throws javax.jms.JMSException

setPriority

public void setPriority(int defaultPriority)
                 throws javax.jms.JMSException

getPriority

public int getPriority()
                throws javax.jms.JMSException

setTimeToLive

public void setTimeToLive(long timeToLive)
                   throws javax.jms.JMSException

getTimeToLive

public long getTimeToLive()
                   throws javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

destroy

public void destroy()
             throws javax.jms.JMSException

Release all resources used by this consumer

Throws:

JMSException -

sendMessage

protected void sendMessage(javax.jms.Message message)
                    throws javax.jms.JMSException

Send the following message to the server. If we are in a trnasacted session then cache the message and send it on commit. If the message is non-null or the message cannot be sent to the server a JMSException is raised.

Parameters:

message - message to send

Throws:

JMSException -

getLogger

protected Logger getLogger()

Return a reference to the logger.

Returns:

Logger