org.apache.james.queue.activemq

Class FileSystemBlobTransferPolicy

java.lang.Object

org.apache.activemq.blob.BlobTransferPolicy

org.apache.james.queue.activemq.FileSystemBlobTransferPolicy

public class FileSystemBlobTransferPolicy
extends org.apache.activemq.blob.BlobTransferPolicy

BlobTransferPolicy which use the FileSystem to download and upload data. So this implementation is only useful when using a non-clustered ActiveMQ Broker or when using a shared Storage for the files.

Constructor Summary

Constructors

Constructor and Description
FileSystemBlobTransferPolicy()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.activemq.blob.BlobTransferPolicy	copy()
protected org.apache.activemq.blob.BlobDownloadStrategy	createDownloadStrategy()
protected org.apache.activemq.blob.BlobUploadStrategy	createUploadStrategy()
void	setFileSystem(FileSystem fs)
void	setSplitCount(int splitCount)

Methods inherited from class org.apache.activemq.blob.BlobTransferPolicy

getBrokerUploadUrl, getBufferSize, getDefaultUploadUrl, getDownloadStrategy, getUploadStrategy, getUploadUrl, setBrokerUploadUrl, setBufferSize, setDefaultUploadUrl, setUploadStrategy, setUploadUrl

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileSystemBlobTransferPolicy

public FileSystemBlobTransferPolicy()

Method Detail

setFileSystem

public void setFileSystem(FileSystem fs)

setSplitCount

public void setSplitCount(int splitCount)

copy

public org.apache.activemq.blob.BlobTransferPolicy copy()

Overrides:

copy in class org.apache.activemq.blob.BlobTransferPolicy

createDownloadStrategy

protected org.apache.activemq.blob.BlobDownloadStrategy createDownloadStrategy()

Overrides:

createDownloadStrategy in class org.apache.activemq.blob.BlobTransferPolicy

createUploadStrategy

protected org.apache.activemq.blob.BlobUploadStrategy createUploadStrategy()

Overrides:

createUploadStrategy in class org.apache.activemq.blob.BlobTransferPolicy