Package org.apache.activemq.ra

Class InboundMessageProducerProxy

java.lang.Object
org.apache.activemq.ra.InboundMessageProducerProxy
All Implemented Interfaces:
jakarta.jms.MessageProducer, jakarta.jms.QueueSender, jakarta.jms.TopicPublisher, AutoCloseable
public class InboundMessageProducerProxy extends Object implements jakarta.jms.MessageProducer, jakarta.jms.QueueSender, jakarta.jms.TopicPublisher
An implementation of MessageProducer which uses the ActiveMQ JCA ResourceAdapter's current thread's JMS Session to send messages.

  • Constructor Summary

    Constructors
    Constructor
    Description
    InboundMessageProducerProxy(jakarta.jms.MessageProducer messageProducer, jakarta.jms.Destination destination)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    long
    getDeliveryDelay()
    Gets the delivery delay value for this MessageProducer.
    int
    getDeliveryMode()
     
    jakarta.jms.Destination
    getDestination()
     
    boolean
    getDisableMessageID()
     
    boolean
    getDisableMessageTimestamp()
     
    int
    getPriority()
     
    jakarta.jms.Queue
    getQueue()
     
    long
    getTimeToLive()
     
    jakarta.jms.Topic
    getTopic()
     
    void
    publish(jakarta.jms.Message arg0)
     
    void
    publish(jakarta.jms.Message arg0, int arg1, int arg2, long arg3)
     
    void
    publish(jakarta.jms.Topic arg0, jakarta.jms.Message arg1)
     
    void
    publish(jakarta.jms.Topic arg0, jakarta.jms.Message arg1, int arg2, int arg3, long arg4)
     
    void
    send(jakarta.jms.Destination destination, jakarta.jms.Message message)
     
    void
    send(jakarta.jms.Destination destination, jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive)
     
    void
    send(jakarta.jms.Destination destination, jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive, jakarta.jms.CompletionListener completionListener)
     
    void
    send(jakarta.jms.Destination destination, jakarta.jms.Message message, jakarta.jms.CompletionListener completionListener)
     
    void
    send(jakarta.jms.Message message)
     
    void
    send(jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive)
     
    void
    send(jakarta.jms.Message message, int deliveryMode, int priority, long timeToLive, jakarta.jms.CompletionListener completionListener)
     
    void
    send(jakarta.jms.Message message, jakarta.jms.CompletionListener completionListener)
     
    void
    send(jakarta.jms.Queue arg0, jakarta.jms.Message arg1)
     
    void
    send(jakarta.jms.Queue arg0, jakarta.jms.Message arg1, int arg2, int arg3, long arg4)
     
    void
    setDeliveryDelay(long deliveryDelay)
    Gets the delivery delay associated with this MessageProducer.
    void
    setDeliveryMode(int i)
     
    void
    setDisableMessageID(boolean b)
     
    void
    setDisableMessageTimestamp(boolean b)
     
    void
    setPriority(int i)
     
    void
    setTimeToLive(long l)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • InboundMessageProducerProxy

      public InboundMessageProducerProxy(jakarta.jms.MessageProducer messageProducer, jakarta.jms.Destination destination) throws jakarta.jms.JMSException
      Throws:
      jakarta.jms.JMSException

  • Method Details

    • close

      public void close() throws jakarta.jms.JMSException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close 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

    • getDeliveryMode

      public int getDeliveryMode() throws jakarta.jms.JMSException
      Specified by:
      getDeliveryMode 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

    • getDisableMessageTimestamp

      public boolean getDisableMessageTimestamp() throws jakarta.jms.JMSException
      Specified by:
      getDisableMessageTimestamp 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

    • getTimeToLive

      public long getTimeToLive() throws jakarta.jms.JMSException
      Specified by:
      getTimeToLive 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) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.MessageProducer
      Specified by:
      send in interface jakarta.jms.QueueSender
      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
      Specified by:
      send in interface jakarta.jms.QueueSender
      Throws:
      jakarta.jms.JMSException

    • setDeliveryMode

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

    • setDisableMessageID

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

    • setDisableMessageTimestamp

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

    • setPriority

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

    • setTimeToLive

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

    • getQueue

      public jakarta.jms.Queue getQueue() throws jakarta.jms.JMSException
      Specified by:
      getQueue in interface jakarta.jms.QueueSender
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Queue arg0, jakarta.jms.Message arg1) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.QueueSender
      Throws:
      jakarta.jms.JMSException

    • send

      public void send(jakarta.jms.Queue arg0, jakarta.jms.Message arg1, int arg2, int arg3, long arg4) throws jakarta.jms.JMSException
      Specified by:
      send in interface jakarta.jms.QueueSender
      Throws:
      jakarta.jms.JMSException

    • getTopic

      public jakarta.jms.Topic getTopic() throws jakarta.jms.JMSException
      Specified by:
      getTopic in interface jakarta.jms.TopicPublisher
      Throws:
      jakarta.jms.JMSException

    • publish

      public void publish(jakarta.jms.Message arg0) throws jakarta.jms.JMSException
      Specified by:
      publish in interface jakarta.jms.TopicPublisher
      Throws:
      jakarta.jms.JMSException

    • publish

      public void publish(jakarta.jms.Message arg0, int arg1, int arg2, long arg3) throws jakarta.jms.JMSException
      Specified by:
      publish in interface jakarta.jms.TopicPublisher
      Throws:
      jakarta.jms.JMSException

    • publish

      public void publish(jakarta.jms.Topic arg0, jakarta.jms.Message arg1) throws jakarta.jms.JMSException
      Specified by:
      publish in interface jakarta.jms.TopicPublisher
      Throws:
      jakarta.jms.JMSException

    • publish

      public void publish(jakarta.jms.Topic arg0, jakarta.jms.Message arg1, int arg2, int arg3, long arg4) throws jakarta.jms.JMSException
      Specified by:
      publish in interface jakarta.jms.TopicPublisher
      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
      Parameters:
      message - the message to send
      CompletionListener - to callback
      Throws:
      jakarta.jms.JMSException - if the JMS provider fails to send the message due to some internal error.
      UnsupportedOperationException - if an invalid destination is specified.
      jakarta.jms.InvalidDestinationException - if a client uses this method with an invalid destination.
      Since:
      2.0
      See Also:
      • Session.createProducer(jakarta.jms.Destination)

    • 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

    • setDeliveryDelay

      public void setDeliveryDelay(long deliveryDelay) throws jakarta.jms.JMSException
      Gets the delivery delay associated with this MessageProducer.
      Specified by:
      setDeliveryDelay in interface jakarta.jms.MessageProducer
      Throws:
      jakarta.jms.JMSException - if the JMS provider fails to close the producer due to some internal error.
      Since:
      2.0

    • getDeliveryDelay

      public long getDeliveryDelay() throws jakarta.jms.JMSException
      Gets the delivery delay value for this MessageProducer.
      Specified by:
      getDeliveryDelay in interface jakarta.jms.MessageProducer
      Returns:
      the delivery delay for this messageProducer
      Throws:
      jakarta.jms.JMSException - if the JMS provider fails to determine if deliver delay is disabled due to some internal error.