org.apache.activemq.blob: public class: BlobUploader

org.apache.activemq.blob
public class: BlobUploader [javadoc | source]

java.lang.Object
   org.apache.activemq.blob.BlobUploader

A helper class to represent a required upload of a BLOB to some remote URL

version: $ - Revision: $

Constructor:
public BlobUploader(BlobTransferPolicy blobTransferPolicy, InputStream in) { this.blobTransferPolicy = blobTransferPolicy; this.in = in; }
public BlobUploader(BlobTransferPolicy blobTransferPolicy, File file) { this.blobTransferPolicy = blobTransferPolicy; this.file = file; }

Constructor:

 public BlobUploader(BlobTransferPolicy blobTransferPolicy,
    InputStream in) {
        this.blobTransferPolicy = blobTransferPolicy;
        this.in = in;
}

 public BlobUploader(BlobTransferPolicy blobTransferPolicy,
    File file) {
        this.blobTransferPolicy = blobTransferPolicy;
        this.file = file;
}

Method from org.apache.activemq.blob.BlobUploader Summary:
getBlobTransferPolicy, getStrategy, upload

Methods from java.lang.Object:
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.apache.activemq.blob.BlobUploader Detail:
public BlobTransferPolicy getBlobTransferPolicy() { return blobTransferPolicy; }
public BlobUploadStrategy getStrategy() { return getBlobTransferPolicy().getUploadStrategy(); }
public URL upload(ActiveMQBlobMessage message) throws JMSException, IOException { if (file != null) { return getStrategy().uploadFile(message, file); } else { return getStrategy().uploadStream(message, in); } }

Method from org.apache.activemq.blob.BlobUploader Detail:

 public BlobTransferPolicy getBlobTransferPolicy() {
        return blobTransferPolicy;
}

 public BlobUploadStrategy getStrategy() {
        return getBlobTransferPolicy().getUploadStrategy();
}

 public URL upload(ActiveMQBlobMessage message) throws JMSException, IOException {
        if (file != null) {
            return getStrategy().uploadFile(message, file);
        } else {
            return getStrategy().uploadStream(message, in);
        }
}