本文整理了Java中org.apache.activemq.ActiveMQConnectionFactory.getRedeliveryPolicy()
方法的一些代码示例,展示了ActiveMQConnectionFactory.getRedeliveryPolicy()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ActiveMQConnectionFactory.getRedeliveryPolicy()
方法的具体详情如下:
包路径:org.apache.activemq.ActiveMQConnectionFactory
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!