Package com.netlang.queue

Class NQMessageImpl

java.lang.Object

com.netlang.queue.NQMessageImpl

All Implemented Interfaces:

NQMessage

public class NQMessageImpl
extends Object
implements NQMessage

The NQMessageImpl class

Constructor Summary

Constructors

Constructor	Description
NQMessageImpl()	Initializes a newly created NQMessageImpl
NQMessageImpl(com.xtellus.queue.XQMessage msg)	Initializes a newly created NQMessageImpl

Method Summary

Modifier and Type	Method	Description
long	getBodyLength()
String	getCorrelationId()
byte[]	getCorrelationIdAsBytes()
long	getExpiration()
String	getId()
com.xtellus.queue.XQMessage	getInternal()
int	getPriority()
com.net4z.serializable.impl.SerializableRow	getRaw()
boolean	getRedelivered()
javax.jms.Destination	getReplyTo()
String	getText()
long	getTimestamp()
boolean	isNewMessage()
boolean	isReply()
boolean	readBoolean()
int	readBytes(byte[] arg0)
double	readDouble()
float	readFloat()
int	readInt()
long	readLong()
String	readUTF()
void	writeBoolean(boolean arg0)
void	writeBytes(byte[] arg0)
void	writeDouble(double arg0)
void	writeFloat(float arg0)
void	writeInt(int arg0)
void	writeLong(long arg0)
void	writeUTF(String arg0)

Methods inherited from class java.lang.Object

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

Constructor Details

NQMessageImpl

public NQMessageImpl()

Initializes a newly created NQMessageImpl

NQMessageImpl

public NQMessageImpl(com.xtellus.queue.XQMessage msg)

Initializes a newly created NQMessageImpl

Method Details

getInternal

public com.xtellus.queue.XQMessage getInternal()

Specified by:

getInternal in interface NQMessage

writeBoolean

public void writeBoolean(boolean arg0)
                  throws Exception

Specified by:

writeBoolean in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeByte(byte)

writeBytes

public void writeBytes(byte[] arg0)
                throws Exception

Specified by:

writeBytes in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeBytes(byte[])

writeDouble

public void writeDouble(double arg0)
                 throws Exception

Specified by:

writeDouble in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeDouble(double)

writeFloat

public void writeFloat(float arg0)
                throws Exception

Specified by:

writeFloat in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeFloat(float)

writeInt

public void writeInt(int arg0)
              throws Exception

Specified by:

writeInt in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeInt(int)

writeLong

public void writeLong(long arg0)
               throws Exception

Specified by:

writeLong in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeLong(long)

writeUTF

public void writeUTF(String arg0)
              throws Exception

Specified by:

writeUTF in interface NQMessage

Parameters:

arg0 -

Throws:

Exception

See Also:

• BytesMessage.writeUTF(java.lang.String)

isReply

public boolean isReply()

Specified by:

isReply in interface NQMessage

getCorrelationId

public String getCorrelationId()
                        throws Exception

Specified by:

getCorrelationId in interface NQMessage

Throws:

Exception

getReplyTo

public javax.jms.Destination getReplyTo()
                                 throws Exception

Specified by:

getReplyTo in interface NQMessage

Throws:

Exception

getCorrelationIdAsBytes

public byte[] getCorrelationIdAsBytes()
                               throws Exception

Specified by:

getCorrelationIdAsBytes in interface NQMessage

Throws:

Exception

getTimestamp

public long getTimestamp()
                  throws Exception

Specified by:

getTimestamp in interface NQMessage

Throws:

Exception

isNewMessage

public boolean isNewMessage()

getExpiration

public long getExpiration()
                   throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getRedelivered

public boolean getRedelivered()
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

readBoolean

public boolean readBoolean()
                    throws Exception

Specified by:

readBoolean in interface NQMessage

Throws:

Exception

readBytes

public int readBytes(byte[] arg0)
              throws Exception

Specified by:

readBytes in interface NQMessage

Throws:

Exception

readDouble

public double readDouble()
                  throws Exception

Specified by:

readDouble in interface NQMessage

Throws:

Exception

readFloat

public float readFloat()
                throws Exception

Specified by:

readFloat in interface NQMessage

Throws:

Exception

readInt

public int readInt()
            throws Exception

Specified by:

readInt in interface NQMessage

Throws:

Exception

readLong

public long readLong()
              throws Exception

Specified by:

readLong in interface NQMessage

Throws:

Exception

readUTF

public String readUTF()
               throws Exception

Specified by:

readUTF in interface NQMessage

Throws:

Exception

getBodyLength

public long getBodyLength()
                   throws Exception

Throws:

Exception

getText

public String getText()
               throws Exception

Specified by:

getText in interface NQMessage

Throws:

Exception

getId

public String getId()
             throws Exception

Specified by:

getId in interface NQMessage

Throws:

Exception

getRaw

public com.net4z.serializable.impl.SerializableRow getRaw()

Specified by:

getRaw in interface NQMessage

getPriority

public int getPriority()
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException