public class ActiveMQBlobMessage extends ActiveMQMessage implements BlobMessage
BlobMessage
for out of band BLOB transferMessage.MessageDestination
Modifier and Type | Field and Description |
---|---|
static String |
BINARY_MIME_TYPE |
static byte |
DATA_STRUCTURE_TYPE |
acknowledgeCallback, BROKER_PATH_PROPERTY, DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY
arrival, brokerInTime, brokerOutTime, compressed, content, correlationId, dataStructure, DEFAULT_MINIMUM_MESSAGE_SIZE, destination, droppable, expiration, groupID, groupSequence, jmsXGroupFirstForConsumer, marshalledProperties, messageId, ORIGINAL_EXPIRATION, originalDestination, originalTransactionId, persistent, priority, producerId, properties, readOnlyBody, readOnlyProperties, recievedByDFBridge, redeliveryCounter, replyTo, size, targetConsumerId, timestamp, transactionId, type, userID
commandId, responseRequired
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE
AMQ_SCHEDULED_CRON, AMQ_SCHEDULED_DELAY, AMQ_SCHEDULED_ID, AMQ_SCHEDULED_PERIOD, AMQ_SCHEDULED_REPEAT, AMQ_SCHEDULER_ACTION, AMQ_SCHEDULER_ACTION_BROWSE, AMQ_SCHEDULER_ACTION_END_TIME, AMQ_SCHEDULER_ACTION_REMOVE, AMQ_SCHEDULER_ACTION_REMOVEALL, AMQ_SCHEDULER_ACTION_START_TIME, AMQ_SCHEDULER_MANAGEMENT_DESTINATION
Constructor and Description |
---|
ActiveMQBlobMessage() |
Modifier and Type | Method and Description |
---|---|
Message |
copy() |
void |
deleteFile() |
BlobDownloader |
getBlobDownloader() |
BlobUploader |
getBlobUploader() |
byte |
getDataStructureType() |
InputStream |
getInputStream()
Return the input stream to process the BLOB
|
String |
getJMSXMimeType()
Returns the MIME type of this mesage.
|
String |
getMimeType()
The MIME type of the BLOB which can be used to apply different content
types to messages.
|
String |
getName() |
String |
getRemoteBlobUrl() |
URL |
getURL()
Returns the URL for the blob if its available as an external URL (such as file, http, ftp etc)
or null if there is no URL available
|
boolean |
isDeletedByBroker() |
void |
onSend()
Send operation event listener.
|
void |
setBlobDownloader(BlobDownloader blobDownloader) |
void |
setBlobUploader(BlobUploader blobUploader) |
void |
setDeletedByBroker(boolean deletedByBroker) |
void |
setMimeType(String mimeType)
Sets the MIME type of the BLOB so that a consumer can process things nicely with a Java Activation Framework
DataHandler
|
void |
setName(String name)
The name of the attachment which can be useful information if
transmitting files over ActiveMQ
|
void |
setRemoteBlobUrl(String remoteBlobUrl) |
void |
setURL(URL url) |
acknowledge, checkReadOnlyBody, checkValidObject, checkValidScheduled, clearBody, clearProperties, convertScheduled, copy, decodeString, encodeString, equals, getAcknowledgeCallback, getAllPropertyNames, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, hashCode, isContentMarshalled, propertyExists, setAcknowledgeCallback, setBooleanProperty, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setObjectProperty, setProperties, setShortProperty, setStringProperty, storeContent, storeContentAndClear, visit
afterMarshall, afterUnmarshall, beforeMarshall, beforeUnmarshall, canProcessAsExpired, clearMarshalledState, clearUnMarshalledState, compress, copy, decrementReferenceCount, doCompress, getArrival, getBrokerInTime, getBrokerOutTime, getBrokerPath, getCluster, getConnection, getContent, getCorrelationId, getDataStructure, getDestination, getExpiration, getGroupID, getGroupSequence, getMarshalledProperties, getMemoryUsage, getMessage, getMessageHardRef, getMessageId, getMinimumMessageSize, getOriginalDestination, getOriginalTransactionId, getPriority, getProducerId, getProperties, getProperty, getRedeliveryCounter, getReferenceCount, getRegionDestination, getReplyTo, getSize, getTargetConsumerId, getTimestamp, getTransactionId, getType, getUserID, incrementRedeliveryCounter, incrementReferenceCount, isAdvisory, isCompressed, isDroppable, isDropped, isExpired, isInTransaction, isJMSXGroupFirstForConsumer, isMarshallAware, isMarshalled, isMessage, isPersistent, isPropertiesMarshalled, isReadOnlyBody, isReadOnlyProperties, isRecievedByDFBridge, isRedelivered, lazyCreateProperties, onMessageRolledBack, removeProperty, setArrival, setBrokerInTime, setBrokerOutTime, setBrokerPath, setCluster, setCompressed, setConnection, setContent, setCorrelationId, setDataStructure, setDestination, setDroppable, setExpiration, setGroupID, setGroupSequence, setJMSXGroupFirstForConsumer, setMarshalledProperties, setMemoryUsage, setMessageId, setOriginalDestination, setOriginalTransactionId, setPersistent, setPriority, setProducerId, setProperty, setReadOnlyBody, setReadOnlyProperties, setRecievedByDFBridge, setRedelivered, setRedeliveryCounter, setRegionDestination, setReplyTo, setTargetConsumerId, setTimestamp, setTransactionId, setType, setUserID, toString, toString
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isConsumerControl, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
acknowledge, clearBody, clearProperties, getBooleanProperty, getByteProperty, getDoubleProperty, getFloatProperty, getIntProperty, getJMSCorrelationID, getJMSCorrelationIDAsBytes, getJMSDeliveryMode, getJMSDestination, getJMSExpiration, getJMSMessageID, getJMSPriority, getJMSRedelivered, getJMSReplyTo, getJMSTimestamp, getJMSType, getLongProperty, getObjectProperty, getPropertyNames, getShortProperty, getStringProperty, propertyExists, setBooleanProperty, setByteProperty, setDoubleProperty, setFloatProperty, setIntProperty, setJMSCorrelationID, setJMSCorrelationIDAsBytes, setJMSDeliveryMode, setJMSDestination, setJMSExpiration, setJMSMessageID, setJMSPriority, setJMSRedelivered, setJMSReplyTo, setJMSTimestamp, setJMSType, setLongProperty, setObjectProperty, setShortProperty, setStringProperty
public static final byte DATA_STRUCTURE_TYPE
public static final String BINARY_MIME_TYPE
public ActiveMQBlobMessage()
public Message copy()
copy
in class ActiveMQMessage
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
getDataStructureType
in class ActiveMQMessage
public String getRemoteBlobUrl()
public void setRemoteBlobUrl(String remoteBlobUrl)
public String getMimeType()
getMimeType
in interface BlobMessage
public void setMimeType(String mimeType)
BlobMessage
setMimeType
in interface BlobMessage
public String getName()
getName
in interface BlobMessage
public void setName(String name)
setName
in interface BlobMessage
public boolean isDeletedByBroker()
public void setDeletedByBroker(boolean deletedByBroker)
public String getJMSXMimeType()
Message
BlobMessage
it allows you to create a selector on the MIME type of the BLOB bodygetJMSXMimeType
in class ActiveMQMessage
public InputStream getInputStream() throws IOException, javax.jms.JMSException
BlobMessage
getInputStream
in interface BlobMessage
IOException
javax.jms.JMSException
public URL getURL() throws javax.jms.JMSException
BlobMessage
getURL
in interface BlobMessage
javax.jms.JMSException
public BlobUploader getBlobUploader()
public void setBlobUploader(BlobUploader blobUploader)
public BlobDownloader getBlobDownloader()
public void setBlobDownloader(BlobDownloader blobDownloader)
public void onSend() throws javax.jms.JMSException
ActiveMQMessage
onSend
in class ActiveMQMessage
javax.jms.JMSException
public void deleteFile() throws IOException, javax.jms.JMSException
IOException
javax.jms.JMSException
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.