public class ActiveMQStreamMessage extends ActiveMQMessage
Modifier and Type | Field and Description |
---|---|
protected org.fusesource.hawtbuf.ByteArrayOutputStream |
bytesOut |
static byte |
DATA_STRUCTURE_TYPE |
protected DataInputStream |
dataIn |
protected DataOutputStream |
dataOut |
protected int |
remainingBytes |
arrival, brokerInTime, brokerOutTime, cachedEncoding, compressed, content, correlationId, dataStructure, DEFAULT_MINIMUM_MESSAGE_SIZE, destination, droppable, encodedSize, expiration, groupID, groupSequence, marshalledProperties, messageId, originalDestination, originalTransactionId, persistent, priority, producerId, properties, readOnlyBody, readOnlyProperties, recievedByDFBridge, redeliveryCounter, replyTo, size, targetConsumerId, timestamp, transactionId, type, userID
commandId, responseRequired
Constructor and Description |
---|
ActiveMQStreamMessage() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkWriteOnlyBody() |
void |
clearBody() |
Message |
copy() |
byte |
getDataStructureType() |
String |
getJMSXMimeType() |
void |
onSend()
Send operation event listener.
|
boolean |
readBoolean() |
byte |
readByte() |
int |
readBytes(byte[] value) |
char |
readChar() |
double |
readDouble() |
float |
readFloat() |
int |
readInt() |
long |
readLong() |
Object |
readObject() |
short |
readShort() |
String |
readString() |
void |
reset() |
String |
toString() |
void |
writeBoolean(boolean value) |
void |
writeByte(byte value) |
void |
writeBytes(byte[] value) |
void |
writeBytes(byte[] value,
int offset,
int length) |
void |
writeChar(char value) |
void |
writeDouble(double value) |
void |
writeFloat(float value) |
void |
writeInt(int value) |
void |
writeLong(long value) |
void |
writeObject(Object value) |
void |
writeShort(short value) |
void |
writeString(String value) |
checkReadOnlyBody, checkValidObject, clearProperties, copy, equals, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isExpired, propertyExists, setBooleanProperty, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setObjectProperty, setShortProperty, setStringProperty
afterMarshall, afterUnmarshall, beforeMarshall, beforeUnmarshall, clearMarshalledState, copy, decrementReferenceCount, getArrival, getBrokerInTime, getBrokerOutTime, getBrokerPath, getCachedEncoding, getCluster, getContent, getCorrelationId, getDataStructure, getDestination, getEncodedSize, getExpiration, getGroupID, getGroupSequence, getMarshalledProperties, getMessage, getMessageHardRef, getMessageId, getMinimumMessageSize, getOriginalDestination, getOriginalTransactionId, getPriority, getProducerId, getProperties, getProperty, getRedeliveryCounter, getReferenceCount, getReplyTo, getSize, getTargetConsumerId, getTimestamp, getTransactionId, getType, getUserID, incrementRedeliveryCounter, incrementReferenceCount, isAdvisory, isCompressed, isDroppable, isDropped, isInTransaction, isMarshallAware, isMessage, isPersistent, isReadOnlyBody, isReadOnlyProperties, isRecievedByDFBridge, isRedelivered, lazyCreateProperties, onMessageRolledBack, setArrival, setBrokerInTime, setBrokerOutTime, setBrokerPath, setCachedEncoding, setCluster, setCompressed, setContent, setCorrelationId, setDataStructure, setDestination, setDroppable, setEncodedSize, setExpiration, setGroupID, setGroupSequence, setMarshalledProperties, setMessageId, setOriginalDestination, setOriginalTransactionId, setPersistent, setPriority, setProducerId, setProperty, setReadOnlyBody, setReadOnlyProperties, setRecievedByDFBridge, setRedelivered, setRedeliveryCounter, setReplyTo, setTargetConsumerId, setTimestamp, setTransactionId, setType, setUserID, toString
copy, getCommandId, isBrokerInfo, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setResponseRequired
public static final byte DATA_STRUCTURE_TYPE
protected transient DataOutputStream dataOut
protected transient org.fusesource.hawtbuf.ByteArrayOutputStream bytesOut
protected transient DataInputStream dataIn
protected transient int remainingBytes
public Message copy()
copy
in class ActiveMQMessage
public void onSend() throws OpenwireException
ActiveMQMessage
onSend
in class ActiveMQMessage
OpenwireException
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
getDataStructureType
in class ActiveMQMessage
public String getJMSXMimeType()
public void clearBody() throws OpenwireException
clearBody
in class ActiveMQMessage
OpenwireException
public boolean readBoolean() throws OpenwireException
OpenwireException
public byte readByte() throws OpenwireException
OpenwireException
public short readShort() throws OpenwireException
OpenwireException
public char readChar() throws OpenwireException
OpenwireException
public int readInt() throws OpenwireException
OpenwireException
public long readLong() throws OpenwireException
OpenwireException
public float readFloat() throws OpenwireException
OpenwireException
public double readDouble() throws OpenwireException
OpenwireException
public String readString() throws OpenwireException
OpenwireException
public int readBytes(byte[] value) throws OpenwireException
OpenwireException
public Object readObject() throws OpenwireException
OpenwireException
public void writeBoolean(boolean value) throws OpenwireException
OpenwireException
public void writeByte(byte value) throws OpenwireException
OpenwireException
public void writeShort(short value) throws OpenwireException
OpenwireException
public void writeChar(char value) throws OpenwireException
OpenwireException
public void writeInt(int value) throws OpenwireException
OpenwireException
public void writeLong(long value) throws OpenwireException
OpenwireException
public void writeFloat(float value) throws OpenwireException
OpenwireException
public void writeDouble(double value) throws OpenwireException
OpenwireException
public void writeString(String value) throws OpenwireException
OpenwireException
public void writeBytes(byte[] value) throws OpenwireException
OpenwireException
public void writeBytes(byte[] value, int offset, int length) throws OpenwireException
OpenwireException
public void writeObject(Object value) throws OpenwireException
OpenwireException
public void reset() throws OpenwireException
OpenwireException
protected void checkWriteOnlyBody() throws OpenwireException
OpenwireException
Copyright © 2011–2014 Red Hat. All rights reserved.