org.apache.james.queue.activemq

Class FileSystemBlobStrategy

java.lang.Object

org.apache.james.queue.activemq.FileSystemBlobStrategy

All Implemented Interfaces:

org.apache.activemq.blob.BlobDownloadStrategy, org.apache.activemq.blob.BlobUploadStrategy, ActiveMQSupport, JMSSupport

public class FileSystemBlobStrategy
extends Object
implements org.apache.activemq.blob.BlobUploadStrategy, org.apache.activemq.blob.BlobDownloadStrategy, ActiveMQSupport

BlobUploadStrategy and BlobDownloadStrategy implementation which use the FileSystem to lookup the File for the BlobMessage

Field Summary

Fields inherited from interface org.apache.james.queue.activemq.ActiveMQSupport

JAMES_BLOB_URL, JAMES_QUEUE_NAME, JAMES_REUSE_BLOB_URL

Fields inherited from interface org.apache.james.queue.jms.JMSSupport

JAMES_MAIL_ATTRIBUTE_NAMES, JAMES_MAIL_ERROR_MESSAGE, JAMES_MAIL_LAST_UPDATED, JAMES_MAIL_MESSAGE_SIZE, JAMES_MAIL_NAME, JAMES_MAIL_RECIPIENTS, JAMES_MAIL_REMOTEADDR, JAMES_MAIL_REMOTEHOST, JAMES_MAIL_SENDER, JAMES_MAIL_SEPARATOR, JAMES_MAIL_STATE, JAMES_NEXT_DELIVERY

Constructor Summary

Constructors

Constructor and Description
FileSystemBlobStrategy(org.apache.activemq.blob.BlobTransferPolicy policy, FileSystem fs, int splitCount)

Method Summary

Methods

Modifier and Type	Method and Description
void	deleteFile(org.apache.activemq.command.ActiveMQBlobMessage message)
protected File	getFile(org.apache.activemq.command.ActiveMQBlobMessage message) Return the File for the ActiveMQBlobMessage.
InputStream	getInputStream(org.apache.activemq.command.ActiveMQBlobMessage message) Returns a FileInputStream for the give BlobMessage
URL	uploadFile(org.apache.activemq.command.ActiveMQBlobMessage message, File file)
URL	uploadStream(org.apache.activemq.command.ActiveMQBlobMessage message, InputStream in)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemBlobStrategy

public FileSystemBlobStrategy(org.apache.activemq.blob.BlobTransferPolicy policy,
                      FileSystem fs,
                      int splitCount)

Method Detail

uploadFile

public URL uploadFile(org.apache.activemq.command.ActiveMQBlobMessage message,
             File file)
               throws javax.jms.JMSException,
                      IOException

Specified by:

uploadFile in interface org.apache.activemq.blob.BlobUploadStrategy

Throws:

javax.jms.JMSException

IOException

See Also:

BlobUploadStrategy.uploadFile(org.apache.activemq.command.ActiveMQBlobMessage, java.io.File)

uploadStream

public URL uploadStream(org.apache.activemq.command.ActiveMQBlobMessage message,
               InputStream in)
                 throws javax.jms.JMSException,
                        IOException

Specified by:

uploadStream in interface org.apache.activemq.blob.BlobUploadStrategy

Throws:

javax.jms.JMSException

IOException

See Also:

BlobUploadStrategy.uploadStream(org.apache.activemq.command.ActiveMQBlobMessage, java.io.InputStream)

deleteFile

public void deleteFile(org.apache.activemq.command.ActiveMQBlobMessage message)
                throws IOException,
                       javax.jms.JMSException

Specified by:

deleteFile in interface org.apache.activemq.blob.BlobDownloadStrategy

Throws:

IOException

javax.jms.JMSException

See Also:

BlobDownloadStrategy.deleteFile(org.apache.activemq.command.ActiveMQBlobMessage)

getInputStream

public InputStream getInputStream(org.apache.activemq.command.ActiveMQBlobMessage message)
                           throws IOException,
                                  javax.jms.JMSException

Returns a FileInputStream for the give BlobMessage

Specified by:

getInputStream in interface org.apache.activemq.blob.BlobDownloadStrategy

Throws:

IOException

javax.jms.JMSException

getFile

protected File getFile(org.apache.activemq.command.ActiveMQBlobMessage message)
                throws javax.jms.JMSException,
                       IOException

Return the File for the ActiveMQBlobMessage. The File is lookup via the FileSystem service

Parameters:

message -

Returns:

file

Throws:

javax.jms.JMSException

FileNotFoundException

IOException