Package org.apache.beam.sdk.io.jms

Class JmsRecord

java.lang.Object
org.apache.beam.sdk.io.jms.JmsRecord
All Implemented Interfaces:
Serializable
public class JmsRecord extends Object implements Serializable
JmsRecord contains message payload of the record as well as metadata (JMS headers and properties).
See Also:

  • Constructor Details

    • JmsRecord

      public JmsRecord(@Nullable String jmsMessageID, long jmsTimestamp, String jmsCorrelationID, @Nullable javax.jms.Destination jmsReplyTo, javax.jms.Destination jmsDestination, int jmsDeliveryMode, boolean jmsRedelivered, String jmsType, long jmsExpiration, int jmsPriority, Map<String,Object> properties, String text)

  • Method Details

    • getJmsMessageID

      public String getJmsMessageID()

    • getJmsTimestamp

      public long getJmsTimestamp()

    • getJmsCorrelationID

      public String getJmsCorrelationID()

    • getJmsReplyTo

      public @Nullable javax.jms.Destination getJmsReplyTo()

    • getJmsDestination

      public javax.jms.Destination getJmsDestination()

    • getJmsDeliveryMode

      public int getJmsDeliveryMode()

    • getJmsRedelivered

      public boolean getJmsRedelivered()

    • getJmsType

      public String getJmsType()

    • getJmsExpiration

      public long getJmsExpiration()

    • getJmsPriority

      public int getJmsPriority()

    • getProperties

      public Map<String,Object> getProperties()

    • getPayload

      public String getPayload()

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(@Nullable Object obj)
      Overrides:
      equals in class Object