org.apache.activemq.ActiveMQConnectionFactory.getRedeliveryPolicy()方法的使用及代码示例

x33g5p2x  于2022-01-15 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(150)

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

ActiveMQConnectionFactory.getRedeliveryPolicy介绍

暂无

代码示例

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

IntrospectionSupport.getProperties(getRedeliveryPolicy(), props, "redeliveryPolicy.");
IntrospectionSupport.getProperties(getBlobTransferPolicy(), props, "blobTransferPolicy.");

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

IntrospectionSupport.getProperties(getRedeliveryPolicy(), props, "redeliveryPolicy.");
IntrospectionSupport.getProperties(getBlobTransferPolicy(), props, "blobTransferPolicy.");

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

IntrospectionSupport.getProperties(getRedeliveryPolicy(), props, "redeliveryPolicy.");
IntrospectionSupport.getProperties(getBlobTransferPolicy(), props, "blobTransferPolicy.");

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

IntrospectionSupport.getProperties(getRedeliveryPolicy(), props, "redeliveryPolicy.");
IntrospectionSupport.getProperties(getBlobTransferPolicy(), props, "blobTransferPolicy.");

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

IntrospectionSupport.getProperties(getRedeliveryPolicy(), props, "redeliveryPolicy.");
IntrospectionSupport.getProperties(getBlobTransferPolicy(), props, "blobTransferPolicy.");

代码示例来源:origin: pl.edu.icm.synat/synat-platform-connector

@Override
public ConnectionFactory getConnectionFactory(final JmsConfig jmsConfig, final boolean poolable) {
  
  final String brokerUrl = jmsConfig.getBrokerUrl(); 
  
  final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
  
  final RedeliveryPolicy redeliveryPolicy = connectionFactory.getRedeliveryPolicy();
  
  connectionFactory.setUseAsyncSend(true);

  setupRedeliveryPolicy(redeliveryPolicy, jmsConfig);
  
  if (poolable) {
    return new PooledConnectionFactory(connectionFactory); 
  } else {
    return connectionFactory;
  }
  
}

代码示例来源:origin: com.github.hqstevenson.splunk/splunk.jms.activemq

protected void configureRedelivery(ActiveMQConnectionFactory connectionFactory) {
  if (useRedelivery) {
    RedeliveryPolicy redeliveryPolicy = connectionFactory.getRedeliveryPolicy();
    if (redeliveryPolicy == null) {
      redeliveryPolicy = new RedeliveryPolicy();
      connectionFactory.setRedeliveryPolicy(redeliveryPolicy);
    }
    redeliveryPolicy.setMaximumRedeliveries(maximumRedeliveries);
    if (useExponentialBackOff) {
      redeliveryPolicy.setUseExponentialBackOff(true);
      redeliveryPolicy.setBackOffMultiplier(backoffMultiplier);
      redeliveryPolicy.setInitialRedeliveryDelay(initialRedeliveryDelay);
      redeliveryPolicy.setMaximumRedeliveryDelay(maximumRedeliveryDelay);
    } else {
      redeliveryPolicy.setUseExponentialBackOff(false);
      redeliveryPolicy.setRedeliveryDelay(redeliveryDelay);
    }
  }
}

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

connection.setUseRetroactiveConsumer(isUseRetroactiveConsumer());
connection.setExclusiveConsumer(isExclusiveConsumer());
connection.setRedeliveryPolicy(getRedeliveryPolicy());
connection.setTransformer(getTransformer());
connection.setBlobTransferPolicy(getBlobTransferPolicy().copy());

相关文章

微信公众号

最新文章

更多

ActiveMQConnectionFactory类方法