Package io.micronaut.jms.pool

Class PooledProducer

java.lang.Object
io.micronaut.jms.pool.PooledObject<jakarta.jms.MessageProducer>
io.micronaut.jms.pool.PooledProducer
All Implemented Interfaces:
jakarta.jms.MessageProducer, AutoCloseable
public class PooledProducer extends PooledObject<jakarta.jms.MessageProducer> implements jakarta.jms.MessageProducer
Pooled object for ensuring maximum reuse of MessageProducer objects.
Since:
1.0.0
Author:
Elliott Pope
See Also:

  • Constructor Details

    • PooledProducer

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

  • Method Details

    • of

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

    • setDisableMessageID

      public void setDisableMessageID(boolean value) throws jakarta.jms.JMSException
      Specified by:
      setDisableMessageID in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getDisableMessageID

      public boolean getDisableMessageID() throws jakarta.jms.JMSException
      Specified by:
      getDisableMessageID in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • setDisableMessageTimestamp

      public void setDisableMessageTimestamp(boolean value) throws jakarta.jms.JMSException
      Specified by:
      setDisableMessageTimestamp in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getDisableMessageTimestamp

      public boolean getDisableMessageTimestamp() throws jakarta.jms.JMSException
      Specified by:
      getDisableMessageTimestamp in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • setDeliveryMode

      public void setDeliveryMode(int deliveryMode) throws jakarta.jms.JMSException
      Specified by:
      setDeliveryMode in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getDeliveryMode

      public int getDeliveryMode() throws jakarta.jms.JMSException
      Specified by:
      getDeliveryMode in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • setPriority

      public void setPriority(int defaultPriority) throws jakarta.jms.JMSException
      Specified by:
      setPriority in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getPriority

      public int getPriority() throws jakarta.jms.JMSException
      Specified by:
      getPriority in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • setTimeToLive

      public void setTimeToLive(long timeToLive) throws jakarta.jms.JMSException
      Specified by:
      setTimeToLive in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getTimeToLive

      public long getTimeToLive() throws jakarta.jms.JMSException
      Specified by:
      getTimeToLive in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • setDeliveryDelay

      public void setDeliveryDelay(long deliveryDelay) throws jakarta.jms.JMSException
      Specified by:
      setDeliveryDelay in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getDeliveryDelay

      public long getDeliveryDelay() throws jakarta.jms.JMSException
      Specified by:
      getDeliveryDelay in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • getDestination

      public jakarta.jms.Destination getDestination() throws jakarta.jms.JMSException
      Specified by:
      getDestination in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Message message) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Destination destination, jakarta.jms.Message message) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Destination destination, jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Message message, jakarta.jms.CompletionListener completionListener) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive, jakarta.jms.CompletionListener completionListener) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Destination destination, jakarta.jms.Message message, jakarta.jms.CompletionListener completionListener) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Destination destination, jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive, jakarta.jms.CompletionListener completionListener) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException

    • toString

      public String toString()
      Overrides:
      toString in class Object