Package org.ow2.joram.jakarta.jms

Class JMSProducer

  • All Implemented Interfaces:
    jakarta.jms.JMSProducer
    public class JMSProducer
extends Object
implements jakarta.jms.JMSProducer

    • Field Detail

      • logger

        private static final Logger logger

      • completionListener

        private jakarta.jms.CompletionListener completionListener

      • jmsCorrelationID

        String jmsCorrelationID

      • jmsType

        private String jmsType

      • replyTo

        private jakarta.jms.Destination replyTo

    • Constructor Detail

      • JMSProducer

        public JMSProducer​(Session session)
            throws jakarta.jms.JMSException
        Throws:
        jakarta.jms.JMSException

    • Method Detail

      • setAsync

        public jakarta.jms.JMSProducer setAsync​(jakarta.jms.CompletionListener completionListener)
        Specified by:
        setAsync in interface jakarta.jms.JMSProducer

      • getAsync

        public jakarta.jms.CompletionListener getAsync()
        Specified by:
        getAsync in interface jakarta.jms.JMSProducer

      • doSend

        private void doSend​(jakarta.jms.Destination destination,
                    jakarta.jms.Message message)
        Send message to destination
        Parameters:
        destination -
        message - message to send
        Throws:
        jakarta.jms.JMSException - if error occurs

      • getDeliveryDelay

        public long getDeliveryDelay()
        API method
        Specified by:
        getDeliveryDelay in interface jakarta.jms.JMSProducer

      • getDeliveryMode

        public int getDeliveryMode()
        API method
        Specified by:
        getDeliveryMode in interface jakarta.jms.JMSProducer

      • getDisableMessageID

        public boolean getDisableMessageID()
        API method
        Specified by:
        getDisableMessageID in interface jakarta.jms.JMSProducer

      • getDisableMessageTimestamp

        public boolean getDisableMessageTimestamp()
        API method
        Specified by:
        getDisableMessageTimestamp in interface jakarta.jms.JMSProducer

      • getJMSCorrelationID

        public String getJMSCorrelationID()
        Specified by:
        getJMSCorrelationID in interface jakarta.jms.JMSProducer

      • setJMSCorrelationID

        public jakarta.jms.JMSProducer setJMSCorrelationID​(String correlationID)
        Specified by:
        setJMSCorrelationID in interface jakarta.jms.JMSProducer

      • getJMSCorrelationIDAsBytes

        public byte[] getJMSCorrelationIDAsBytes()
        Specified by:
        getJMSCorrelationIDAsBytes in interface jakarta.jms.JMSProducer

      • setJMSCorrelationIDAsBytes

        public jakarta.jms.JMSProducer setJMSCorrelationIDAsBytes​(byte[] correlationID)
        Specified by:
        setJMSCorrelationIDAsBytes in interface jakarta.jms.JMSProducer

      • getJMSReplyTo

        public jakarta.jms.Destination getJMSReplyTo()
        Specified by:
        getJMSReplyTo in interface jakarta.jms.JMSProducer

      • getJMSType

        public String getJMSType()
        Specified by:
        getJMSType in interface jakarta.jms.JMSProducer

      • getPriority

        public int getPriority()
        Specified by:
        getPriority in interface jakarta.jms.JMSProducer

      • getPropertyNames

        public Set<String> getPropertyNames()
        Specified by:
        getPropertyNames in interface jakarta.jms.JMSProducer

      • getTimeToLive

        public long getTimeToLive()
        Specified by:
        getTimeToLive in interface jakarta.jms.JMSProducer

      • propertyExists

        public boolean propertyExists​(String name)
        Specified by:
        propertyExists in interface jakarta.jms.JMSProducer

      • send

        public jakarta.jms.JMSProducer send​(jakarta.jms.Destination destination,
                                    byte[] body)
        JMS 2.0 API method.
        Specified by:
        send in interface jakarta.jms.JMSProducer

      • send

        public jakarta.jms.JMSProducer send​(jakarta.jms.Destination destination,
                                    Map<String,​Object> body)
        JMS 2.0 API method.
        Specified by:
        send in interface jakarta.jms.JMSProducer

      • send

        public jakarta.jms.JMSProducer send​(jakarta.jms.Destination destination,
                                    jakarta.jms.Message message)
        JMS 2.0 API method.
        Specified by:
        send in interface jakarta.jms.JMSProducer

      • send

        public jakarta.jms.JMSProducer send​(jakarta.jms.Destination destination,
                                    Serializable body)
        JMS 2.0 API method.
        Specified by:
        send in interface jakarta.jms.JMSProducer

      • send

        public jakarta.jms.JMSProducer send​(jakarta.jms.Destination destination,
                                    String body)
        JMS 2.0 API method.
        Specified by:
        send in interface jakarta.jms.JMSProducer

      • setDeliveryDelay

        public jakarta.jms.JMSProducer setDeliveryDelay​(long deliveryDelay)
        Specified by:
        setDeliveryDelay in interface jakarta.jms.JMSProducer

      • setDeliveryMode

        public jakarta.jms.JMSProducer setDeliveryMode​(int deliveryMode)
        Specified by:
        setDeliveryMode in interface jakarta.jms.JMSProducer

      • setDisableMessageID

        public jakarta.jms.JMSProducer setDisableMessageID​(boolean value)
        API method
        Specified by:
        setDisableMessageID in interface jakarta.jms.JMSProducer

      • setDisableMessageTimestamp

        public jakarta.jms.JMSProducer setDisableMessageTimestamp​(boolean value)
        API method
        Specified by:
        setDisableMessageTimestamp in interface jakarta.jms.JMSProducer

      • setJMSReplyTo

        public jakarta.jms.JMSProducer setJMSReplyTo​(jakarta.jms.Destination replyTo)
        Specified by:
        setJMSReplyTo in interface jakarta.jms.JMSProducer

      • setJMSType

        public jakarta.jms.JMSProducer setJMSType​(String type)
        Specified by:
        setJMSType in interface jakarta.jms.JMSProducer

      • setPriority

        public jakarta.jms.JMSProducer setPriority​(int priority)
        Specified by:
        setPriority in interface jakarta.jms.JMSProducer

      • setTimeToLive

        public jakarta.jms.JMSProducer setTimeToLive​(long timeToLive)
        Specified by:
        setTimeToLive in interface jakarta.jms.JMSProducer

      • writeCurrentProperties

        private jakarta.jms.Message writeCurrentProperties​(jakarta.jms.Message message)
                                            throws jakarta.jms.JMSException
        Writes properties previously stored, in message and sets reply destination
        Parameters:
        Message - message
        Throws:
        jakarta.jms.JMSException - when property is not assignable to message

      • doGetProperty

        private final Object doGetProperty​(String name)

      • getString2Property

        public final String getString2Property​(String name)
                                throws jakarta.jms.JMSException
        Throws:
        jakarta.jms.JMSException

      • clearProperties

        public jakarta.jms.JMSProducer clearProperties()
        Specified by:
        clearProperties in interface jakarta.jms.JMSProducer

      • getBooleanProperty

        public boolean getBooleanProperty​(String name)
        Specified by:
        getBooleanProperty in interface jakarta.jms.JMSProducer

      • getByteProperty

        public byte getByteProperty​(String name)
        Specified by:
        getByteProperty in interface jakarta.jms.JMSProducer

      • getShortProperty

        public short getShortProperty​(String name)
        Specified by:
        getShortProperty in interface jakarta.jms.JMSProducer

      • getIntProperty

        public int getIntProperty​(String name)
        Specified by:
        getIntProperty in interface jakarta.jms.JMSProducer

      • getLongProperty

        public long getLongProperty​(String name)
        Specified by:
        getLongProperty in interface jakarta.jms.JMSProducer

      • getFloatProperty

        public float getFloatProperty​(String name)
        Specified by:
        getFloatProperty in interface jakarta.jms.JMSProducer

      • getDoubleProperty

        public double getDoubleProperty​(String name)
        Specified by:
        getDoubleProperty in interface jakarta.jms.JMSProducer

      • getStringProperty

        public String getStringProperty​(String name)
        Specified by:
        getStringProperty in interface jakarta.jms.JMSProducer

      • getObjectProperty

        public Object getObjectProperty​(String name)
        Specified by:
        getObjectProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           boolean value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           byte value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           double value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           float value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           int value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           long value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           Object value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           short value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer

      • setProperty

        public jakarta.jms.JMSProducer setProperty​(String name,
                                           String value)
        Specified by:
        setProperty in interface jakarta.jms.JMSProducer