|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.command.BaseCommand
org.apache.activemq.command.Message
org.apache.activemq.command.ActiveMQMessage
org.apache.activemq.command.ActiveMQBlobMessage
public class ActiveMQBlobMessage
An implementation of BlobMessage
for out of band BLOB transfer
Field Summary | |
---|---|
static java.lang.String |
BINARY_MIME_TYPE
|
static byte |
DATA_STRUCTURE_TYPE
|
Fields inherited from class org.apache.activemq.command.ActiveMQMessage |
---|
acknowledgeCallback, DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY |
Fields inherited from class org.apache.activemq.command.Message |
---|
arrival, brokerInTime, brokerOutTime, compressed, content, correlationId, dataStructure, DEFAULT_MINIMUM_MESSAGE_SIZE, destination, droppable, expiration, groupID, groupSequence, marshalledProperties, messageId, originalDestination, originalTransactionId, persistent, priority, producerId, properties, readOnlyBody, readOnlyProperties, recievedByDFBridge, redeliveryCounter, replyTo, size, targetConsumerId, timestamp, transactionId, type, userID |
Fields inherited from class org.apache.activemq.command.BaseCommand |
---|
commandId, responseRequired |
Fields inherited from interface javax.jms.Message |
---|
DEFAULT_DELIVERY_MODE, DEFAULT_PRIORITY, DEFAULT_TIME_TO_LIVE |
Constructor Summary | |
---|---|
ActiveMQBlobMessage()
|
Method Summary | |
---|---|
Message |
copy()
|
void |
deleteFile()
|
BlobDownloader |
getBlobDownloader()
|
BlobUploader |
getBlobUploader()
|
byte |
getDataStructureType()
|
java.io.InputStream |
getInputStream()
Return the input stream to process the BLOB |
java.lang.String |
getJMSXMimeType()
Returns the MIME type of this mesage. |
java.lang.String |
getMimeType()
The MIME type of the BLOB which can be used to apply different content types to messages. |
java.lang.String |
getName()
|
java.lang.String |
getRemoteBlobUrl()
|
java.net.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(java.lang.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(java.lang.String name)
The name of the attachment which can be useful information if transmitting files over ActiveMQ |
void |
setRemoteBlobUrl(java.lang.String remoteBlobUrl)
|
void |
setURL(java.net.URL url)
|
Methods inherited from class org.apache.activemq.command.BaseCommand |
---|
copy, getCommandId, getFrom, getTo, isBrokerInfo, isConnectionControl, isMessageAck, isMessageDispatch, isMessageDispatchNotification, isResponse, isResponseRequired, isShutdownInfo, isWireFormatInfo, setCommandId, setFrom, setResponseRequired, setTo |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Methods inherited from interface javax.jms.Message |
---|
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 |
Field Detail |
---|
public static final byte DATA_STRUCTURE_TYPE
public static final java.lang.String BINARY_MIME_TYPE
Constructor Detail |
---|
public ActiveMQBlobMessage()
Method Detail |
---|
public Message copy()
copy
in class ActiveMQMessage
public byte getDataStructureType()
getDataStructureType
in interface DataStructure
getDataStructureType
in class ActiveMQMessage
public java.lang.String getRemoteBlobUrl()
public void setRemoteBlobUrl(java.lang.String remoteBlobUrl)
public java.lang.String getMimeType()
getMimeType
in interface BlobMessage
public void setMimeType(java.lang.String mimeType)
BlobMessage
setMimeType
in interface BlobMessage
public java.lang.String getName()
getName
in interface BlobMessage
public void setName(java.lang.String name)
setName
in interface BlobMessage
public boolean isDeletedByBroker()
public void setDeletedByBroker(boolean deletedByBroker)
public java.lang.String getJMSXMimeType()
Message
BlobMessage
it allows you to create a selector on the MIME type of the BLOB body
getJMSXMimeType
in class ActiveMQMessage
public java.io.InputStream getInputStream() throws java.io.IOException, javax.jms.JMSException
BlobMessage
getInputStream
in interface BlobMessage
java.io.IOException
javax.jms.JMSException
public java.net.URL getURL() throws javax.jms.JMSException
BlobMessage
getURL
in interface BlobMessage
javax.jms.JMSException
public void setURL(java.net.URL url)
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 java.io.IOException, javax.jms.JMSException
java.io.IOException
javax.jms.JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |