本文整理了Java中org.apache.activemq.ActiveMQConnectionFactory.setBlobTransferPolicy()方法的一些代码示例，展示了ActiveMQConnectionFactory.setBlobTransferPolicy()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ActiveMQConnectionFactory.setBlobTransferPolicy()方法的具体详情如下：
包路径：org.apache.activemq.ActiveMQConnectionFactory
类名称：ActiveMQConnectionFactory
方法名：setBlobTransferPolicy

ActiveMQConnectionFactory.setBlobTransferPolicy介绍

[英]Sets the policy used to describe how out-of-band BLOBs (Binary Large OBjects) are transferred from producers to brokers to consumers
[中]设置用于描述带外BLOB（二进制大对象）如何从生产者到代理再到消费者的策略

代码示例

代码示例来源：origin: apache/activemq

public boolean buildFromMap(Map<String, Object> properties) {
  boolean rc = false;
  ActiveMQPrefetchPolicy p = new ActiveMQPrefetchPolicy();
  if (IntrospectionSupport.setProperties(p, properties, "prefetchPolicy.")) {
    setPrefetchPolicy(p);
    rc = true;
  }
  RedeliveryPolicy rp = new RedeliveryPolicy();
  if (IntrospectionSupport.setProperties(rp, properties, "redeliveryPolicy.")) {
    setRedeliveryPolicy(rp);
    rc = true;
  }
  BlobTransferPolicy blobTransferPolicy = new BlobTransferPolicy();
  if (IntrospectionSupport.setProperties(blobTransferPolicy, properties, "blobTransferPolicy.")) {
    setBlobTransferPolicy(blobTransferPolicy);
    rc = true;
  }
  rc |= IntrospectionSupport.setProperties(this, properties);
  return rc;
}

代码示例来源：origin: org.apache.james/james-server-queue-activemq

private ActiveMQConnectionFactory createActiveMQConnectionFactory(BlobTransferPolicy blobTransferPolicy) {
  ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://james?create=false");
  connectionFactory.setBlobTransferPolicy(blobTransferPolicy);
  connectionFactory.setPrefetchPolicy(createActiveMQPrefetchPolicy());
  return connectionFactory;
}

代码示例来源：origin: org.apache.activemq/activemq-client

public boolean buildFromMap(Map<String, Object> properties) {
  boolean rc = false;
  ActiveMQPrefetchPolicy p = new ActiveMQPrefetchPolicy();
  if (IntrospectionSupport.setProperties(p, properties, "prefetchPolicy.")) {
    setPrefetchPolicy(p);
    rc = true;
  }
  RedeliveryPolicy rp = new RedeliveryPolicy();
  if (IntrospectionSupport.setProperties(rp, properties, "redeliveryPolicy.")) {
    setRedeliveryPolicy(rp);
    rc = true;
  }
  BlobTransferPolicy blobTransferPolicy = new BlobTransferPolicy();
  if (IntrospectionSupport.setProperties(blobTransferPolicy, properties, "blobTransferPolicy.")) {
    setBlobTransferPolicy(blobTransferPolicy);
    rc = true;
  }
  rc |= IntrospectionSupport.setProperties(this, properties);
  return rc;
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

public boolean buildFromMap(Map<String, Object> properties) {
  boolean rc = false;
  ActiveMQPrefetchPolicy p = new ActiveMQPrefetchPolicy();
  if (IntrospectionSupport.setProperties(p, properties, "prefetchPolicy.")) {
    setPrefetchPolicy(p);
    rc = true;
  }
  RedeliveryPolicy rp = new RedeliveryPolicy();
  if (IntrospectionSupport.setProperties(rp, properties, "redeliveryPolicy.")) {
    setRedeliveryPolicy(rp);
    rc = true;
  }
  BlobTransferPolicy blobTransferPolicy = new BlobTransferPolicy();
  if (IntrospectionSupport.setProperties(blobTransferPolicy, properties, "blobTransferPolicy.")) {
    setBlobTransferPolicy(blobTransferPolicy);
    rc = true;
  }
  rc |= IntrospectionSupport.setProperties(this, properties);
  return rc;
}

代码示例来源：origin: pierre/meteo

public boolean buildFromMap(Map<String, Object> properties) {
  boolean rc = false;
  ActiveMQPrefetchPolicy p = new ActiveMQPrefetchPolicy();
  if (IntrospectionSupport.setProperties(p, properties, "prefetchPolicy.")) {
    setPrefetchPolicy(p);
    rc = true;
  }
  RedeliveryPolicy rp = new RedeliveryPolicy();
  if (IntrospectionSupport.setProperties(rp, properties, "redeliveryPolicy.")) {
    setRedeliveryPolicy(rp);
    rc = true;
  }
  BlobTransferPolicy blobTransferPolicy = new BlobTransferPolicy();
  if (IntrospectionSupport.setProperties(blobTransferPolicy, properties, "blobTransferPolicy.")) {
    setBlobTransferPolicy(blobTransferPolicy);
    rc = true;
  }
  rc |= IntrospectionSupport.setProperties(this, properties);
  return rc;
}

代码示例来源：origin: org.apache.james/james-server-queue-activemq

protected ActiveMQConnectionFactory createConnectionFactory() {
  ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost?create=false");
  FileSystemBlobTransferPolicy policy = new FileSystemBlobTransferPolicy();
  policy.setFileSystem(new MyFileSystem());
  policy.setDefaultUploadUrl(BASE_DIR);
  factory.setBlobTransferPolicy(policy);
  return factory;
}

代码示例来源：origin: org.apache.activemq/activemq-all

public boolean buildFromMap(Map<String, Object> properties) {
  boolean rc = false;
  ActiveMQPrefetchPolicy p = new ActiveMQPrefetchPolicy();
  if (IntrospectionSupport.setProperties(p, properties, "prefetchPolicy.")) {
    setPrefetchPolicy(p);
    rc = true;
  }
  RedeliveryPolicy rp = new RedeliveryPolicy();
  if (IntrospectionSupport.setProperties(rp, properties, "redeliveryPolicy.")) {
    setRedeliveryPolicy(rp);
    rc = true;
  }
  BlobTransferPolicy blobTransferPolicy = new BlobTransferPolicy();
  if (IntrospectionSupport.setProperties(blobTransferPolicy, properties, "blobTransferPolicy.")) {
    setBlobTransferPolicy(blobTransferPolicy);
    rc = true;
  }
  rc |= IntrospectionSupport.setProperties(this, properties);
  return rc;
}

代码示例来源：origin: org.apache.james/james-server-queue-activemq

@BeforeEach
public void setUp(BrokerService broker, MailQueueMetricExtension.MailQueueMetricTestSystem metricTestSystem) {
  fileSystem = new MyFileSystem();
  ActiveMQConnectionFactory connectionFactory = createConnectionFactory();
  FileSystemBlobTransferPolicy policy = new FileSystemBlobTransferPolicy();
  policy.setFileSystem(fileSystem);
  policy.setDefaultUploadUrl(BASE_DIR);
  connectionFactory.setBlobTransferPolicy(policy);
  RawMailQueueItemDecoratorFactory mailQueueItemDecoratorFactory = new RawMailQueueItemDecoratorFactory();
  MetricFactory metricFactory = metricTestSystem.getSpyMetricFactory();
  GaugeRegistry gaugeRegistry = metricTestSystem.getSpyGaugeRegistry();
  String queueName = BrokerExtension.generateRandomQueueName(broker);
  mailQueue = new ActiveMQMailQueue(connectionFactory, mailQueueItemDecoratorFactory, queueName, USE_BLOB, metricFactory, gaugeRegistry);
}

代码示例来源：origin: org.apache.james/james-server-queue-activemq

@BeforeEach
public void setUp(BrokerService brokerService) {
  fileSystem = new ActiveMQMailQueueBlobTest.MyFileSystem();
  ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://localhost?create=false");
  FileSystemBlobTransferPolicy policy = new FileSystemBlobTransferPolicy();
  policy.setFileSystem(fileSystem);
  policy.setDefaultUploadUrl(BASE_DIR);
  connectionFactory.setBlobTransferPolicy(policy);
  RawMailQueueItemDecoratorFactory mailQueueItemDecoratorFactory = new RawMailQueueItemDecoratorFactory();
  NoopMetricFactory metricFactory = new NoopMetricFactory();
  NoopGaugeRegistry gaugeRegistry = new NoopGaugeRegistry();
  mailQueueFactory = new ActiveMQMailQueueFactory(connectionFactory, mailQueueItemDecoratorFactory, metricFactory, gaugeRegistry);
  mailQueueFactory.setUseJMX(false);
  mailQueueFactory.setUseBlobMessages(true);
}