Repository: james-project Updated Branches: refs/heads/master ea12b94b5 -> a5f014f2d
JAMES-2285 Re-add lost blob policy Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/b78ac089 Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/b78ac089 Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/b78ac089 Branch: refs/heads/master Commit: b78ac089e6a455899614149f4b39c98c2451618e Parents: ea12b94 Author: benwa <[email protected]> Authored: Fri Jan 19 10:06:02 2018 +0700 Committer: benwa <[email protected]> Committed: Fri Jan 19 10:06:02 2018 +0700 ---------------------------------------------------------------------- .../james/queue/activemq/ActiveMQMailQueueBlobTest.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/b78ac089/server/queue/queue-activemq/src/test/java/org/apache/james/queue/activemq/ActiveMQMailQueueBlobTest.java ---------------------------------------------------------------------- diff --git a/server/queue/queue-activemq/src/test/java/org/apache/james/queue/activemq/ActiveMQMailQueueBlobTest.java b/server/queue/queue-activemq/src/test/java/org/apache/james/queue/activemq/ActiveMQMailQueueBlobTest.java index 0eab66b..77d5655 100644 --- a/server/queue/queue-activemq/src/test/java/org/apache/james/queue/activemq/ActiveMQMailQueueBlobTest.java +++ b/server/queue/queue-activemq/src/test/java/org/apache/james/queue/activemq/ActiveMQMailQueueBlobTest.java @@ -24,8 +24,6 @@ import java.io.IOException; import java.io.InputStream; import java.util.concurrent.ExecutorService; -import javax.jms.ConnectionFactory; - import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.broker.BrokerPlugin; import org.apache.activemq.broker.BrokerService; @@ -66,7 +64,11 @@ public class ActiveMQMailQueueBlobTest implements DelayedManageableMailQueueCont fileSystem = new MyFileSystem(); broker = createBroker(); broker.start(); - ConnectionFactory connectionFactory = createConnectionFactory(); + ActiveMQConnectionFactory connectionFactory = createConnectionFactory(); + FileSystemBlobTransferPolicy policy = new FileSystemBlobTransferPolicy(); + policy.setFileSystem(fileSystem); + policy.setDefaultUploadUrl(BASE_DIR); + connectionFactory.setBlobTransferPolicy(policy); RawMailQueueItemDecoratorFactory mailQueueItemDecoratorFactory = new RawMailQueueItemDecoratorFactory(); NoopMetricFactory metricFactory = new NoopMetricFactory(); mailQueue = new ActiveMQMailQueue(connectionFactory, mailQueueItemDecoratorFactory, QUEUE_NAME, USE_BLOB, metricFactory); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
