Class ActiveMQStreamMessage

Namespace

Apache.NMS.ActiveMQ.Commands

Assembly

Apache.NMS.ActiveMQ.dll

public class ActiveMQStreamMessage : ActiveMQMessage, Command, DataStructure, MessageReference, ICloneable, MarshallAware, IStreamMessage, IMessage

Inheritance

object

BaseDataStructure

BaseCommand

Message

ActiveMQMessage

ActiveMQStreamMessage

Implements

Command

DataStructure

MessageReference

ICloneable

MarshallAware

IStreamMessage

IMessage

Inherited Members

ActiveMQMessage.ID_ACTIVEMQMESSAGE

ActiveMQMessage.Transform(IMessage)

ActiveMQMessage.GetHashCode()

ActiveMQMessage.Equals(object)

ActiveMQMessage.Equals(ActiveMQMessage)

ActiveMQMessage.Acknowledge()

ActiveMQMessage.ClearProperties()

ActiveMQMessage.FailIfReadOnlyBody()

ActiveMQMessage.FailIfWriteOnlyBody()

ActiveMQMessage.GetObjectProperty(string)

ActiveMQMessage.SetObjectProperty(string, object)

ActiveMQMessage.IsMarshallAware()

ActiveMQMessage.BeforeMarshall(OpenWireFormat)

ActiveMQMessage.Visit(ICommandVisitor)

ActiveMQMessage.ReadOnlyProperties

ActiveMQMessage.Properties

ActiveMQMessage.FromDestination

ActiveMQMessage.Connection

ActiveMQMessage.NMSCorrelationID

ActiveMQMessage.NMSDestination

ActiveMQMessage.NMSTimeToLive

ActiveMQMessage.NMSMessageId

ActiveMQMessage.NMSDeliveryMode

ActiveMQMessage.NMSPriority

ActiveMQMessage.NMSRedelivered

ActiveMQMessage.NMSReplyTo

ActiveMQMessage.NMSTimestamp

ActiveMQMessage.NMSType

ActiveMQMessage.NMSXDeliveryCount

ActiveMQMessage.NMSXGroupID

ActiveMQMessage.NMSXGroupSeq

ActiveMQMessage.NMSXProducerTXID

ActiveMQMessage.Acknowledger

Message.ID_MESSAGE

Message.DEFAULT_MINIMUM_MESSAGE_SIZE

Message.ToString()

Message.Size()

Message.OnMessageRollback()

Message.IsExpired()

Message.ProducerId

Message.Destination

Message.TransactionId

Message.OriginalDestination

Message.MessageId

Message.OriginalTransactionId

Message.GroupID

Message.GroupSequence

Message.CorrelationId

Message.Persistent

Message.Expiration

Message.Priority

Message.ReplyTo

Message.Timestamp

Message.Type

Message.Content

Message.MarshalledProperties

Message.DataStructure

Message.TargetConsumerId

Message.Compressed

Message.RedeliveryCounter

Message.BrokerPath

Message.Arrival

Message.UserID

Message.RecievedByDFBridge

Message.Droppable

Message.Cluster

Message.BrokerInTime

Message.BrokerOutTime

Message.JMSXGroupFirstForConsumer

Message.ReadOnlyBody

Message.IsMessage

BaseCommand.GetDataStructureTypeAsString(int)

BaseCommand.CommandId

BaseCommand.IsBrokerInfo

BaseCommand.IsConnectionControl

BaseCommand.IsConnectionInfo

BaseCommand.IsConnectionError

BaseCommand.IsConsumerControl

BaseCommand.IsConsumerInfo

BaseCommand.IsControlCommand

BaseCommand.IsDestinationInfo

BaseCommand.IsFlushCommand

BaseCommand.IsKeepAliveInfo

BaseCommand.IsMessageAck

BaseCommand.IsMessageDispatch

BaseCommand.IsMessageDispatchNotification

BaseCommand.IsMessagePull

BaseCommand.IsProducerAck

BaseCommand.IsProducerInfo

BaseCommand.IsRemoveInfo

BaseCommand.IsRemoveSubscriptionInfo

BaseCommand.IsReplayCommand

BaseCommand.IsResponse

BaseCommand.IsSessionInfo

BaseCommand.IsShutdownInfo

BaseCommand.IsTransactionInfo

BaseCommand.IsWireFormatInfo

BaseCommand.ResponseRequired

BaseDataStructure.AfterMarshall(OpenWireFormat)

BaseDataStructure.BeforeUnmarshall(OpenWireFormat)

BaseDataStructure.AfterUnmarshall(OpenWireFormat)

BaseDataStructure.SetMarshalledForm(OpenWireFormat, byte[])

BaseDataStructure.GetMarshalledForm(OpenWireFormat)

BaseDataStructure.HashCode(object)

object.GetType()

object.MemberwiseClone()

object.Equals(object, object)

object.ReferenceEquals(object, object)

Constructors

ActiveMQStreamMessage()

public ActiveMQStreamMessage()

Fields

ID_ACTIVEMQSTREAMMESSAGE

public const byte ID_ACTIVEMQSTREAMMESSAGE = 27

Field Value

byte

Methods

ClearBody()

public override void ClearBody()

Clone()

public override object Clone()

Returns

object

GetDataStructureType()

public override byte GetDataStructureType()

Returns

byte

OnSend()

public override void OnSend()

ReadBoolean()

public bool ReadBoolean()

Returns

bool

ReadByte()

public byte ReadByte()

Returns

byte

ReadBytes(byte[])

public int ReadBytes(byte[] value)

Parameters

value byte[]

Returns

int

ReadChar()

public char ReadChar()

Returns

char

ReadDouble()

public double ReadDouble()

Returns

double

ReadInt16()

public short ReadInt16()

Returns

short

ReadInt32()

public int ReadInt32()

Returns

int

ReadInt64()

public long ReadInt64()

Returns

long

ReadObject()

public object ReadObject()

Returns

object

ReadSingle()

public float ReadSingle()

Returns

float

ReadString()

public string ReadString()

Returns

string

Reset()

public void Reset()

WriteBoolean(bool)

public void WriteBoolean(bool value)

Parameters

value bool

WriteByte(byte)

public void WriteByte(byte value)

Parameters

value byte

WriteBytes(byte[])

public void WriteBytes(byte[] value)

Parameters

value byte[]

WriteBytes(byte[], int, int)

public void WriteBytes(byte[] value, int offset, int length)

Parameters

value byte[]

offset int

length int

WriteChar(char)

public void WriteChar(char value)

Parameters

value char

WriteDouble(double)

public void WriteDouble(double value)

Parameters

value double

WriteInt16(short)

public void WriteInt16(short value)

Parameters

value short

WriteInt32(int)

public void WriteInt32(int value)

Parameters

value int

WriteInt64(long)

public void WriteInt64(long value)

Parameters

value long

WriteObject(object)

public void WriteObject(object value)

Parameters

value object

WriteSingle(float)

public void WriteSingle(float value)

Parameters

value float

WriteString(string)

public void WriteString(string value)

Parameters

value string