org.xmlBlaster.jms
Class XBMessageProducer

java.lang.Object
  org.xmlBlaster.jms.XBMessageProducer

All Implemented Interfaces:

javax.jms.MessageProducer

Direct Known Subclasses:

XBQueueSender, XBTopicPublisher

public class XBMessageProducer
extends java.lang.Object
implements javax.jms.MessageProducer

XBMessageProducer

Author:

Michele Laghi

Field Summary

protected I_XmlBlasterAccess	access
protected int	deliveryMode
protected javax.jms.Destination	destination
protected javax.jms.ExceptionListener	exceptionListener
private static java.lang.String	ME
protected int	priority
protected PublishReturnQos	publishReturnQos
protected XBSession	session
protected long	timeToLive

Constructor Summary

XBMessageProducer(XBSession session, javax.jms.Destination destination)

Method Summary

void	close()
int	getDeliveryMode()
javax.jms.Destination	getDestination()
boolean	getDisableMessageID() xmlBlaster always creates a unique message id (the unique timestamp)
boolean	getDisableMessageTimestamp() Ignored here since we always send the timestamp
int	getPriority()
long	getTimeToLive()
void	send(javax.jms.Destination dest, javax.jms.Message message)
void	send(javax.jms.Destination dest, javax.jms.Message msg, int deliveryMode, int priority, long timeToLive)
void	send(javax.jms.Message message)
void	send(javax.jms.Message message, int deliveryMode, int prio, long timeToLive)
void	setDeliveryMode(int deliveryMode)
void	setDisableMessageID(boolean arg0)
void	setDisableMessageTimestamp(boolean arg0)
void	setPriority(int priority)
void	setTimeToLive(long timeToLive)

Methods inherited from class java.lang.Object

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

Field Detail

ME

private static final java.lang.String ME

See Also:

Constant Field Values

access

protected I_XmlBlasterAccess access

destination

protected javax.jms.Destination destination

deliveryMode

protected int deliveryMode

priority

protected int priority

timeToLive

protected long timeToLive

publishReturnQos

protected PublishReturnQos publishReturnQos

exceptionListener

protected javax.jms.ExceptionListener exceptionListener

session

protected XBSession session

Constructor Detail

XBMessageProducer

public XBMessageProducer(XBSession session,
                         javax.jms.Destination destination)

Method Detail

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDeliveryMode

public int getDeliveryMode()
                    throws javax.jms.JMSException

Specified by:

getDeliveryMode in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDisableMessageID

public boolean getDisableMessageID()
                            throws javax.jms.JMSException

xmlBlaster always creates a unique message id (the unique timestamp)

Specified by:

getDisableMessageID in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws javax.jms.JMSException

Ignored here since we always send the timestamp

Specified by:

getDisableMessageTimestamp in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getPriority

public int getPriority()
                throws javax.jms.JMSException

Specified by:

getPriority in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getTimeToLive

public long getTimeToLive()
                   throws javax.jms.JMSException

Specified by:

getTimeToLive in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setDeliveryMode

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

Specified by:

setDeliveryMode in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setDisableMessageID

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

Specified by:

setDisableMessageID in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setDisableMessageTimestamp

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

Specified by:

setDisableMessageTimestamp in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setPriority

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

Specified by:

setPriority in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setTimeToLive

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

Specified by:

setTimeToLive in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

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

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

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

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

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

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

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

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDestination

public javax.jms.Destination getDestination()
                                     throws javax.jms.JMSException

Specified by:

getDestination in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException