本文整理了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
暂无
代码示例来源: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) {
内容来源于网络,如有侵权,请联系作者删除!