org.apache.beam.sdk.io.jms

Class JmsRecord

java.lang.Object

org.apache.beam.sdk.io.jms.JmsRecord

All Implemented Interfaces:

java.io.Serializable

public class JmsRecord
extends java.lang.Object
implements java.io.Serializable

JmsRecord contains message payload of the record as well as metadata (JMS headers and properties).

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable java.lang.Object obj)
java.lang.String	getJmsCorrelationID()
int	getJmsDeliveryMode()
javax.jms.Destination	getJmsDestination()
long	getJmsExpiration()
java.lang.String	getJmsMessageID()
int	getJmsPriority()
boolean	getJmsRedelivered()
@Nullable javax.jms.Destination	getJmsReplyTo()
long	getJmsTimestamp()
java.lang.String	getJmsType()
java.lang.String	getPayload()
java.util.Map<java.lang.String,java.lang.Object>	getProperties()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsRecord

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

Method Detail

getJmsMessageID

public java.lang.String getJmsMessageID()

getJmsTimestamp

public long getJmsTimestamp()

getJmsCorrelationID

public java.lang.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 java.lang.String getJmsType()

getJmsExpiration

public long getJmsExpiration()

getJmsPriority

public int getJmsPriority()

getProperties

public java.util.Map<java.lang.String,java.lang.Object> getProperties()

getPayload

public java.lang.String getPayload()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(@Nullable java.lang.Object obj)

Overrides:

equals in class java.lang.Object