public class ActiveMQBlobMessage extends ActiveMQMessage
Modifier and Type | Field and Description |
---|---|
static org.fusesource.hawtbuf.UTF8Buffer |
BINARY_MIME_TYPE |
static byte |
DATA_STRUCTURE_TYPE |
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 |
---|
ActiveMQBlobMessage() |
Modifier and Type | Method and Description |
---|---|
Message |
copy() |
BlobUploader |
getBlobUploader() |
byte |
getDataStructureType() |
java.io.InputStream |
getInputStream() |
org.fusesource.hawtbuf.UTF8Buffer |
getJMSXMimeType() |
org.fusesource.hawtbuf.UTF8Buffer |
getMimeType()
The MIME type of the BLOB which can be used to apply different content
types to messages.
|
org.fusesource.hawtbuf.UTF8Buffer |
getName() |
org.fusesource.hawtbuf.UTF8Buffer |
getRemoteBlobUrl() |
java.net.URL |
getURL() |
boolean |
isDeletedByBroker() |
void |
onSend()
Send operation event listener.
|
void |
setBlobUploader(BlobUploader blobUploader) |
void |
setDeletedByBroker(boolean deletedByBroker) |
void |
setMimeType(org.fusesource.hawtbuf.UTF8Buffer mimeType) |
void |
setName(org.fusesource.hawtbuf.UTF8Buffer name)
The name of the attachment which can be useful information if
transmitting files over ActiveMQ
|
void |
setRemoteBlobUrl(org.fusesource.hawtbuf.UTF8Buffer remoteBlobUrl) |
void |
setURL(java.net.URL url) |
checkReadOnlyBody, checkValidObject, clearBody, 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, toString
copy, getCommandId, isBrokerInfo, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setResponseRequired
public static final byte DATA_STRUCTURE_TYPE
public static final org.fusesource.hawtbuf.UTF8Buffer BINARY_MIME_TYPE
public Message copy()
copy
in class ActiveMQMessage
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
getDataStructureType
in class ActiveMQMessage
public org.fusesource.hawtbuf.UTF8Buffer getRemoteBlobUrl()
public void setRemoteBlobUrl(org.fusesource.hawtbuf.UTF8Buffer remoteBlobUrl)
public org.fusesource.hawtbuf.UTF8Buffer getMimeType()
public void setMimeType(org.fusesource.hawtbuf.UTF8Buffer mimeType)
public org.fusesource.hawtbuf.UTF8Buffer getName()
public void setName(org.fusesource.hawtbuf.UTF8Buffer name)
public boolean isDeletedByBroker()
public void setDeletedByBroker(boolean deletedByBroker)
public org.fusesource.hawtbuf.UTF8Buffer getJMSXMimeType()
public java.io.InputStream getInputStream() throws java.io.IOException, OpenwireException
java.io.IOException
OpenwireException
public java.net.URL getURL() throws OpenwireException
OpenwireException
public void setURL(java.net.URL url)
public BlobUploader getBlobUploader()
public void setBlobUploader(BlobUploader blobUploader)
public void onSend() throws OpenwireException
ActiveMQMessage
onSend
in class ActiveMQMessage
OpenwireException
Copyright © 2011-2014 Red Hat. All Rights Reserved.