Package org.objectweb.joram.client.connector

Class OutboundProducer

java.lang.Object

org.objectweb.joram.client.connector.OutboundProducer

All Implemented Interfaces:

AutoCloseable, MessageProducer

Direct Known Subclasses:

OutboundPublisher, OutboundSender

public class OutboundProducer
extends Object
implements MessageProducer

An OutboundProducer instance wraps a JMS producer for a component involved in outbound messaging.

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger
protected MessageProducer	producer	The wrapped JMS producer.
protected OutboundSession	session	The OutboundSession this producer belongs to.
(package private) boolean	valid	false if producer is no more valid.

Constructor Summary

Constructors

Constructor	Description
OutboundProducer(MessageProducer producer, OutboundSession session)	Constructs an OutboundProducer instance.

Method Summary

Modifier and Type	Method	Description
protected void	checkValidity()	Checks the validity of the subscriber instance.
void	close()	Delegates the call to the wrapped producer.
long	getDeliveryDelay()	Delegates the call to the wrapped producer.
int	getDeliveryMode()	Delegates the call to the wrapped producer.
Destination	getDestination()	Delegates the call to the wrapped producer.
boolean	getDisableMessageID()	Delegates the call to the wrapped producer.
boolean	getDisableMessageTimestamp()	Delegates the call to the wrapped producer.
int	getPriority()	Delegates the call to the wrapped producer.
long	getTimeToLive()	Delegates the call to the wrapped producer.
void	send(Destination dest, Message message)	Delegates the call to the wrapped producer.
void	send(Destination dest, Message message, int deliveryMode, int priority, long timeToLive)	Delegates the call to the wrapped producer.
void	send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, CompletionListener completionListener)	Delegates the call to the wrapped producer.
void	send(Destination destination, Message message, CompletionListener completionListener)	Delegates the call to the wrapped producer.
void	send(Message message)	Delegates the call to the wrapped producer.
void	send(Message message, int deliveryMode, int priority, long timeToLive)	Delegates the call to the wrapped producer.
void	send(Message message, int deliveryMode, int priority, long timeToLive, CompletionListener completionListener)	Delegates the call to the wrapped producer.
void	send(Message message, CompletionListener completionListener)	Delegates the call to the wrapped producer.
void	setDeliveryDelay(long deliveryDelay)	Delegates the call to the wrapped producer.
void	setDeliveryMode(int deliveryMode)	Delegates the call to the wrapped producer.
void	setDisableMessageID(boolean value)	Delegates the call to the wrapped producer.
void	setDisableMessageTimestamp(boolean value)	Delegates the call to the wrapped producer.
void	setPriority(int priority)	Delegates the call to the wrapped producer.
void	setTimeToLive(long timeToLive)	Delegates the call to the wrapped producer.

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

session

protected OutboundSession session

The OutboundSession this producer belongs to.

producer

protected MessageProducer producer

The wrapped JMS producer.

valid

boolean valid

false if producer is no more valid.

Constructor Detail

OutboundProducer

OutboundProducer(MessageProducer producer,
                 OutboundSession session)

Constructs an OutboundProducer instance.

Parameters:

producer - The JMS producer to wrap.

session - The OutboundSession this producer belongs to.

Method Detail

checkValidity

protected void checkValidity()
                      throws IllegalStateException

Checks the validity of the subscriber instance.

Throws:

IllegalStateException

setDisableMessageID

public void setDisableMessageID(boolean value)
                         throws JMSException

Delegates the call to the wrapped producer.

Specified by:

setDisableMessageID in interface MessageProducer

Throws:

JMSException

setDeliveryMode

public void setDeliveryMode(int deliveryMode)
                     throws JMSException

Delegates the call to the wrapped producer.

Specified by:

setDeliveryMode in interface MessageProducer

Throws:

JMSException

setPriority

public void setPriority(int priority)
                 throws JMSException

Delegates the call to the wrapped producer.

Specified by:

setPriority in interface MessageProducer

Throws:

JMSException

setTimeToLive

public void setTimeToLive(long timeToLive)
                   throws JMSException

Delegates the call to the wrapped producer.

Specified by:

setTimeToLive in interface MessageProducer

Throws:

JMSException

setDisableMessageTimestamp

public void setDisableMessageTimestamp(boolean value)
                                throws JMSException

Delegates the call to the wrapped producer.

Specified by:

setDisableMessageTimestamp in interface MessageProducer

Throws:

JMSException

getDestination

public Destination getDestination()
                           throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getDestination in interface MessageProducer

Throws:

JMSException

getDisableMessageID

public boolean getDisableMessageID()
                            throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getDisableMessageID in interface MessageProducer

Throws:

JMSException

getDeliveryMode

public int getDeliveryMode()
                    throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getDeliveryMode in interface MessageProducer

Throws:

JMSException

getPriority

public int getPriority()
                throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getPriority in interface MessageProducer

Throws:

JMSException

getTimeToLive

public long getTimeToLive()
                   throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getTimeToLive in interface MessageProducer

Throws:

JMSException

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getDisableMessageTimestamp in interface MessageProducer

Throws:

JMSException

send

public void send(Message message)
          throws JMSException

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

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

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

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

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

public void send(Destination dest,
                 Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive)
          throws JMSException

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

close

public void close()
           throws JMSException

Delegates the call to the wrapped producer.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface MessageProducer

Throws:

JMSException

setDeliveryDelay

public void setDeliveryDelay(long deliveryDelay)
                      throws JMSException

Delegates the call to the wrapped producer.

Specified by:

setDeliveryDelay in interface MessageProducer

Throws:

JMSException

getDeliveryDelay

public long getDeliveryDelay()
                      throws JMSException

Delegates the call to the wrapped producer.

Specified by:

getDeliveryDelay in interface MessageProducer

Throws:

JMSException

send

public void send(Message message,
                 CompletionListener completionListener)
          throws JMSException

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

public void send(Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive,
                 CompletionListener completionListener)
          throws JMSException

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

public void send(Destination destination,
                 Message message,
                 CompletionListener completionListener)
          throws JMSException

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException

send

public void send(Destination destination,
                 Message message,
                 int deliveryMode,
                 int priority,
                 long timeToLive,
                 CompletionListener completionListener)
          throws JMSException

Delegates the call to the wrapped producer.

Specified by:

send in interface MessageProducer

Throws:

JMSException