Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

added another helper method and fixed up some broken javadoc 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511753 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2007-02-26 08:49:21 +00:00
parent 05a8cba7d0
commit 53bf323e74
1 changed files with 26 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
View File

@ -386,9 +386,30 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* internal error. * internal error.
*/ */
public BlobMessage createBlobMessage(URL url) throws JMSException { public BlobMessage createBlobMessage(URL url) throws JMSException {
return createBlobMessage(url, false);
}
/**
* Creates an initialized <CODE>BlobMessage</CODE> object. A <CODE>BlobMessage</CODE>
* object is used to send a message containing a <CODE>URL</CODE> which points to some
* network addressible BLOB.
*
* @param url
* the network addressable URL used to pass directly to the consumer
* @param deletedByBroker
* indicates whether or not the resource is deleted by the broker when the message
* is acknowledged
* @return a BlobMessage
* @throws JMSException
* if the JMS provider fails to create this message due to some
* internal error.
*/
public BlobMessage createBlobMessage(URL url, boolean deletedByBroker) throws JMSException {
ActiveMQBlobMessage message = new ActiveMQBlobMessage(); ActiveMQBlobMessage message = new ActiveMQBlobMessage();
configureMessage(message); configureMessage(message);
message.setURL(url); message.setURL(url);
message.setDeletedByBroker(deletedByBroker);
return message; return message;
} }
@ -396,10 +417,10 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* Creates an initialized <CODE>BlobMessage</CODE> object. A <CODE>BlobMessage</CODE> * Creates an initialized <CODE>BlobMessage</CODE> object. A <CODE>BlobMessage</CODE>
* object is used to send a message containing the <CODE>File</CODE> content. Before the * object is used to send a message containing the <CODE>File</CODE> content. Before the
* message is sent the file conent will be uploaded to the broker or some other remote repository * message is sent the file conent will be uploaded to the broker or some other remote repository
* depending on the {@link #getBlobUploadStrategy()}. * depending on the {@link #getBlobTransferPolicy()}.
* *
* @param file * @param file
* the file to be uploaded to some remote repo (or the broker) depending on the * the file to be uploaded to some remote repo (or the broker) depending on the strategy
* *
* @return a BlobMessage * @return a BlobMessage
* @throws JMSException * @throws JMSException
@ -420,10 +441,10 @@ public class ActiveMQSession implements Session, QueueSession, TopicSession, Sta
* Creates an initialized <CODE>BlobMessage</CODE> object. A <CODE>BlobMessage</CODE> * Creates an initialized <CODE>BlobMessage</CODE> object. A <CODE>BlobMessage</CODE>
* object is used to send a message containing the <CODE>File</CODE> content. Before the * object is used to send a message containing the <CODE>File</CODE> content. Before the
* message is sent the file conent will be uploaded to the broker or some other remote repository * message is sent the file conent will be uploaded to the broker or some other remote repository
* depending on the {@link #getBlobUploadStrategy()}. * depending on the {@link #getBlobTransferPolicy()}.
* *
* @param file * @param in
* the file to be uploaded to some remote repo (or the broker) depending on the * the stream to be uploaded to some remote repo (or the broker) depending on the strategy
* *
* @return a BlobMessage * @return a BlobMessage
* @throws JMSException * @throws JMSException