activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r511753 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
Date Mon, 26 Feb 2007 08:49:22 GMT
Author: jstrachan
Date: Mon Feb 26 00:49:21 2007
New Revision: 511753

URL: http://svn.apache.org/viewvc?view=rev&rev=511753
Log:
added another helper method and fixed up some broken javadoc

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java?view=diff&rev=511753&r1=511752&r2=511753
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java Mon
Feb 26 00:49:21 2007
@@ -386,9 +386,30 @@
      *             internal error.
      */
     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();
         configureMessage(message);
         message.setURL(url);
+        message.setDeletedByBroker(deletedByBroker);
         return message;
     }
 
@@ -396,10 +417,10 @@
      * 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
      * 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
-     *            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
      * @throws JMSException
@@ -420,10 +441,10 @@
      * 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
      * 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
-     *            the file to be uploaded to some remote repo (or the broker) depending on
the
+     * @param in
+     *            the stream to be uploaded to some remote repo (or the broker) depending
on the strategy
      *
      * @return a BlobMessage
      * @throws JMSException



Mime
View raw message