public class ActiveMQMapMessage extends ActiveMQMessage
Modifier and Type | Field and Description |
---|---|
static byte |
DATA_STRUCTURE_TYPE |
protected Map<String,Object> |
map |
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 |
---|
ActiveMQMapMessage() |
Modifier and Type | Method and Description |
---|---|
void |
beforeMarshall(OpenWireFormat wireFormat) |
void |
clearBody() |
void |
clearMarshalledState() |
Message |
copy() |
boolean |
getBoolean(String name) |
byte |
getByte(String name) |
byte[] |
getBytes(String name) |
char |
getChar(String name) |
Map<String,Object> |
getContentMap() |
byte |
getDataStructureType() |
double |
getDouble(String name) |
float |
getFloat(String name) |
int |
getInt(String name) |
String |
getJMSXMimeType() |
long |
getLong(String name) |
Enumeration<String> |
getMapNames() |
Object |
getObject(String name) |
short |
getShort(String name) |
String |
getString(String name) |
boolean |
itemExists(String name) |
protected void |
put(String name,
Object value) |
void |
setBoolean(String name,
boolean value) |
void |
setByte(String name,
byte value) |
void |
setBytes(String name,
byte[] value) |
void |
setBytes(String name,
byte[] value,
int offset,
int length) |
void |
setChar(String name,
char value) |
void |
setDouble(String name,
double value) |
void |
setFloat(String name,
float value) |
void |
setInt(String name,
int value) |
void |
setLong(String name,
long value) |
void |
setObject(String name,
Object value) |
void |
setShort(String name,
short value) |
void |
setString(String name,
String value) |
String |
toString() |
checkReadOnlyBody, checkValidObject, clearProperties, copy, equals, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isExpired, onSend, propertyExists, setBooleanProperty, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setLongProperty, setObjectProperty, setObjectProperty, setShortProperty, setStringProperty
afterMarshall, afterUnmarshall, beforeUnmarshall, 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
public Message copy()
copy
in class ActiveMQMessage
public void beforeMarshall(OpenWireFormat wireFormat) throws IOException
beforeMarshall
in interface MarshallAware
beforeMarshall
in class Message
IOException
public void clearMarshalledState()
clearMarshalledState
in class Message
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 getBoolean(String name) throws OpenwireException
OpenwireException
public byte getByte(String name) throws OpenwireException
OpenwireException
public short getShort(String name) throws OpenwireException
OpenwireException
public char getChar(String name) throws OpenwireException
OpenwireException
public int getInt(String name) throws OpenwireException
OpenwireException
public long getLong(String name) throws OpenwireException
OpenwireException
public float getFloat(String name) throws OpenwireException
OpenwireException
public double getDouble(String name) throws OpenwireException
OpenwireException
public String getString(String name) throws OpenwireException
OpenwireException
public byte[] getBytes(String name) throws OpenwireException
OpenwireException
public Object getObject(String name) throws OpenwireException
OpenwireException
public Enumeration<String> getMapNames() throws OpenwireException
OpenwireException
protected void put(String name, Object value) throws OpenwireException
OpenwireException
public void setBoolean(String name, boolean value) throws OpenwireException
OpenwireException
public void setByte(String name, byte value) throws OpenwireException
OpenwireException
public void setShort(String name, short value) throws OpenwireException
OpenwireException
public void setChar(String name, char value) throws OpenwireException
OpenwireException
public void setInt(String name, int value) throws OpenwireException
OpenwireException
public void setLong(String name, long value) throws OpenwireException
OpenwireException
public void setFloat(String name, float value) throws OpenwireException
OpenwireException
public void setDouble(String name, double value) throws OpenwireException
OpenwireException
public void setString(String name, String value) throws OpenwireException
OpenwireException
public void setBytes(String name, byte[] value) throws OpenwireException
OpenwireException
public void setBytes(String name, byte[] value, int offset, int length) throws OpenwireException
OpenwireException
public void setObject(String name, Object value) throws OpenwireException
OpenwireException
public boolean itemExists(String name) throws OpenwireException
OpenwireException
public Map<String,Object> getContentMap() throws OpenwireException
OpenwireException
Copyright © 2011–2014 Red Hat. All rights reserved.