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

ActiveMQConnectionFactory.setPreAcknowledge介绍

暂无

代码示例

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

@Test
public void testPreCommitAcksWithMessageExpirySetOnConnectionFactory() throws Exception {
 ((ActiveMQConnectionFactory) cf).setPreAcknowledge(true);
 conn = cf.createConnection();
 Session session = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
 jBossQueue = ActiveMQJMSClient.createQueue(JmsConsumerTest.Q_NAME);
 MessageProducer producer = session.createProducer(jBossQueue);
 MessageConsumer consumer = session.createConsumer(jBossQueue);
 int noOfMessages = 1000;
 for (int i = 0; i < noOfMessages; i++) {
   TextMessage textMessage = session.createTextMessage("m" + i);
   producer.setTimeToLive(1);
   producer.send(textMessage);
 }
 Thread.sleep(2);
 conn.start();
 Message m = consumer.receiveNoWait();
 Assert.assertNull(m);
 // Asserting delivering count is zero is bogus since messages might still be being delivered and expired at this
 // point
 // which can cause delivering count to flip to 1
}

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

@Test
public void testPreCommitAcksSetOnConnectionFactory() throws Exception {
 ((ActiveMQConnectionFactory) cf).setPreAcknowledge(true);
 conn = cf.createConnection();
 Session session = conn.createSession(false, Session.CLIENT_ACKNOWLEDGE);
 jBossQueue = ActiveMQJMSClient.createQueue(JmsConsumerTest.Q_NAME);
 MessageProducer producer = session.createProducer(jBossQueue);
 MessageConsumer consumer = session.createConsumer(jBossQueue);
 int noOfMessages = 100;
 for (int i = 0; i < noOfMessages; i++) {
   producer.send(session.createTextMessage("m" + i));
 }
 conn.start();
 for (int i = 0; i < noOfMessages; i++) {
   Message m = consumer.receive(500);
   Assert.assertNotNull(m);
 }
 // Messages should all have been acked since we set pre ack on the cf
 SimpleString queueName = new SimpleString(JmsConsumerTest.Q_NAME);
 Queue queue = server.locateQueue(queueName);
 Wait.assertEquals(0, queue::getDeliveringCount);
 Wait.assertEquals(0, queue::getMessageCount);
}

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

@Override
@Before
public void setUp() throws Exception {
 super.setUp();
 cf = ActiveMQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(INVM_CONNECTOR_FACTORY));
 cf.setBlockOnDurableSend(true);
 cf.setPreAcknowledge(true);
}

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

@Override
@Before
public void setUp() throws Exception {
 super.setUp();
 cf = ActiveMQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(INVM_CONNECTOR_FACTORY));
 cf.setBlockOnDurableSend(true);
 cf.setPreAcknowledge(true);
}

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

@Override
@Before
public void setUp() throws Exception {
 super.setUp();
 server = addServer(ActiveMQServers.newActiveMQServer(createDefaultInVMConfig(), false));
 server.start();
 cf = ActiveMQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(INVM_CONNECTOR_FACTORY));
 cf.setBlockOnDurableSend(true);
 cf.setPreAcknowledge(true);
}

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

cf.setBlockOnNonDurableSend(cfConfig.isBlockOnNonDurableSend());
cf.setAutoGroup(cfConfig.isAutoGroup());
cf.setPreAcknowledge(cfConfig.isPreAcknowledge());
cf.setConnectionLoadBalancingPolicyClassName(cfConfig.getLoadBalancingPolicyClassName());
cf.setTransactionBatchSize(cfConfig.getTransactionBatchSize());

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

factory.setBlockOnNonDurableSend(blockOnNonDurableSend);
factory.setAutoGroup(autoGroup);
factory.setPreAcknowledge(preAcknowledge);
factory.setConnectionLoadBalancingPolicyClassName(loadBalancingPolicyClassName);
factory.setUseGlobalPools(useGlobalPools);

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

cf.setBlockOnNonDurableSend(blockOnNonDurableSend);
cf.setAutoGroup(autoGroup);
cf.setPreAcknowledge(preAcknowledge);
cf.setConnectionLoadBalancingPolicyClassName(loadBalancingPolicyClassName);
cf.setUseGlobalPools(useGlobalPools);

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

cf.setPreAcknowledge(val);

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

cf.setPreAcknowledge(val);

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

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