org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.setBlockOnAcknowledge()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(2.3k)|赞(0)|评价(0)|浏览(71)

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

ActiveMQConnectionFactory.setBlockOnAcknowledge介绍

暂无

代码示例

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

private ConnectionFactory newCF() {
 if (protocol.equals("core")) {
   ConnectionFactory factory = new ActiveMQConnectionFactory();
   ((ActiveMQConnectionFactory) factory).setBlockOnAcknowledge(true);
   return factory;
 } else if (protocol.equals("amqp")) {
   final JmsConnectionFactory factory = new JmsConnectionFactory("amqp://localhost:61616");
   factory.setForceAsyncAcks(true);
   return factory;
 } else {
   org.apache.activemq.ActiveMQConnectionFactory cf = new org.apache.activemq.ActiveMQConnectionFactory("tcp://localhost:61616?wireFormat.cacheEnabled=true");
   cf.setSendAcksAsync(false);
   return cf;
 }
}

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

cf.setProducerWindowSize(cfConfig.getProducerWindowSize());
cf.setProducerMaxRate(cfConfig.getProducerMaxRate());
cf.setBlockOnAcknowledge(cfConfig.isBlockOnAcknowledge());
cf.setBlockOnDurableSend(cfConfig.isBlockOnDurableSend());
cf.setBlockOnNonDurableSend(cfConfig.isBlockOnNonDurableSend());

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

factory.setConfirmationWindowSize(confirmationWindowSize);
factory.setProducerMaxRate(producerMaxRate);
factory.setBlockOnAcknowledge(blockOnAcknowledge);
factory.setBlockOnDurableSend(blockOnDurableSend);
factory.setBlockOnNonDurableSend(blockOnNonDurableSend);

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

cf.setBlockOnAcknowledge(val);

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

cf.setConfirmationWindowSize(confirmationWindowSize);
cf.setProducerMaxRate(producerMaxRate);
cf.setBlockOnAcknowledge(blockOnAcknowledge);
cf.setBlockOnDurableSend(blockOnDurableSend);
cf.setBlockOnNonDurableSend(blockOnNonDurableSend);

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

cf.setBlockOnAcknowledge(val);

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

cf.setBlockOnAcknowledge(blockOnAcknowledge);
  Assert.fail("Should throw exception");
} catch (IllegalStateException e) {

相关文章

微信公众号

最新文章

更多

ActiveMQConnectionFactory类方法