Package io.micronaut.jms.pool

Class PooledProducer

java.lang.Object

io.micronaut.jms.pool.PooledObject<javax.jms.MessageProducer>

io.micronaut.jms.pool.PooledProducer

All Implemented Interfaces:

AutoCloseable, javax.jms.MessageProducer

public class PooledProducer
extends PooledObject<javax.jms.MessageProducer>
implements javax.jms.MessageProducer

Pooled object for ensuring maximum reuse of MessageProducer objects.

Since:

1.0.0

Author:

Elliott Pope

See Also:

• MessageProducerPool
• MessageProducerPoolFactory
• SessionPool

Constructor Summary

Constructors

Constructor	Description
PooledProducer(AbstractPool<PooledObject<javax.jms.MessageProducer>> pool, javax.jms.MessageProducer object)

Method Summary

Modifier and Type	Method	Description
long	getDeliveryDelay()
int	getDeliveryMode()
javax.jms.Destination	getDestination()
boolean	getDisableMessageID()
boolean	getDisableMessageTimestamp()
int	getPriority()
long	getTimeToLive()
static PooledProducer	of(PooledObject<javax.jms.MessageProducer> object)
void	send(javax.jms.Destination destination, javax.jms.Message message)
void	send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
void	send(javax.jms.Destination destination, javax.jms.Message message, int deliveryMode, int priority, long timeToLive, javax.jms.CompletionListener completionListener)
void	send(javax.jms.Destination destination, javax.jms.Message message, javax.jms.CompletionListener completionListener)
void	send(javax.jms.Message message)
void	send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive)
void	send(javax.jms.Message message, int deliveryMode, int priority, long timeToLive, javax.jms.CompletionListener completionListener)
void	send(javax.jms.Message message, javax.jms.CompletionListener completionListener)
void	setDeliveryDelay(long deliveryDelay)
void	setDeliveryMode(int deliveryMode)
void	setDisableMessageID(boolean value)
void	setDisableMessageTimestamp(boolean value)
void	setPriority(int defaultPriority)
void	setTimeToLive(long timeToLive)
String	toString()

Methods inherited from class io.micronaut.jms.pool.PooledObject

close, get

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.MessageProducer

close

Constructor Details

PooledProducer

public PooledProducer(AbstractPool<PooledObject<javax.jms.MessageProducer>> pool,
 javax.jms.MessageProducer object)

Method Details

of

public static PooledProducer of(PooledObject<javax.jms.MessageProducer> object)

setDisableMessageID

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

Specified by:

setDisableMessageID in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDisableMessageID

public boolean getDisableMessageID()
                            throws javax.jms.JMSException

Specified by:

getDisableMessageID in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setDisableMessageTimestamp

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

Specified by:

setDisableMessageTimestamp in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDisableMessageTimestamp

public boolean getDisableMessageTimestamp()
                                   throws javax.jms.JMSException

Specified by:

getDisableMessageTimestamp 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

getDeliveryMode

public int getDeliveryMode()
                    throws javax.jms.JMSException

Specified by:

getDeliveryMode in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

setPriority

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

Specified by:

setPriority 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

setTimeToLive

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

Specified by:

setTimeToLive 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

setDeliveryDelay

public void setDeliveryDelay(long deliveryDelay)
                      throws javax.jms.JMSException

Specified by:

setDeliveryDelay in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

getDeliveryDelay

public long getDeliveryDelay()
                      throws javax.jms.JMSException

Specified by:

getDeliveryDelay 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

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.Message message,
 int deliveryMode,
 int priority,
 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 destination,
 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 destination,
 javax.jms.Message message,
 int deliveryMode,
 int priority,
 long timeToLive)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

public void send(javax.jms.Message message,
 javax.jms.CompletionListener completionListener)
          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 priority,
 long timeToLive,
 javax.jms.CompletionListener completionListener)
          throws javax.jms.JMSException

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

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

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

send

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

Specified by:

send in interface javax.jms.MessageProducer

Throws:

javax.jms.JMSException

toString

public String toString()

Overrides:

toString in class Object