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

ActiveMQConnectionFactory.setConsumerWindowSize介绍

暂无

代码示例

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

@Test
public void testBrowserOnly() throws Exception {
 ((ActiveMQConnectionFactory) cf).setConsumerWindowSize(0);
 conn = cf.createConnection();
 Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
 jBossQueue = ActiveMQJMSClient.createQueue(JmsConsumerTest.Q_NAME);
 MessageProducer producer = session.createProducer(jBossQueue);
 int noOfMessages = 10;
 for (int i = 0; i < noOfMessages; i++) {
   TextMessage textMessage = session.createTextMessage("m" + i);
   textMessage.setIntProperty("i", i);
   producer.send(textMessage);
 }
 QueueBrowser browser = session.createBrowser(jBossQueue);
 Enumeration enumMessages = browser.getEnumeration();
 for (int i = 0; i < noOfMessages; i++) {
   Assert.assertTrue(enumMessages.hasMoreElements());
   TextMessage msg = (TextMessage) enumMessages.nextElement();
   Assert.assertNotNull(msg);
   Assert.assertEquals(i, msg.getIntProperty("i"));
 }
 Assert.assertFalse(enumMessages.hasMoreElements());
 conn.close();
 // 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 testBrowserAndConsumerSimultaneousDifferentConnections() throws Exception {
 ((ActiveMQConnectionFactory) cf).setConsumerWindowSize(0);
 conn = cf.createConnection();

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

@Test
public void testLastValueKeyUsingAddressQueueParameters() throws Exception {
 ActiveMQConnectionFactory fact = (ActiveMQConnectionFactory) getCF();
 //Set the consumer window size to 0 to not buffer any messages client side.
 fact.setConsumerWindowSize(0);
 Connection connection = fact.createConnection();
 try {
   Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
   Queue queue = session.createQueue("random?last-value-key=reuters_code");
   assertEquals("random", queue.getQueueName());
   ActiveMQDestination a = (ActiveMQDestination) queue;
   assertEquals("reuters_code", a.getQueueAttributes().getLastValueKey().toString());
   MessageProducer producer = session.createProducer(queue);
   MessageConsumer consumer1 = session.createConsumer(queue);
   connection.start();
   for (int j = 0; j < 100; j++) {
    TextMessage message = session.createTextMessage();
    message.setText("Message" + j);
    message.setStringProperty("reuters_code", "key");
    producer.send(message);
   }
   //Last message only should go to the consumer
   TextMessage tm = (TextMessage) consumer1.receive(10000);
   assertNotNull(tm);
   assertEquals("Message99", tm.getText());
 } finally {
   connection.close();
 }
}

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

@Test
public void testLastValueQueueUsingAddressQueueParameters() throws Exception {
 ActiveMQConnectionFactory fact = (ActiveMQConnectionFactory) getCF();
 //Set the consumer window size to 0 to not buffer any messages client side.
 fact.setConsumerWindowSize(0);
 Connection connection = fact.createConnection();
 try {
   Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
   Queue queue = session.createQueue("random?last-value=true");
   assertEquals("random", queue.getQueueName());
   ActiveMQDestination a = (ActiveMQDestination) queue;
   assertTrue(a.getQueueAttributes().getLastValue());
   MessageProducer producer = session.createProducer(queue);
   MessageConsumer consumer1 = session.createConsumer(queue);
   connection.start();
   for (int j = 0; j < 100; j++) {
    TextMessage message = session.createTextMessage();
    message.setText("Message" + j);
    message.setStringProperty(Message.HDR_LAST_VALUE_NAME.toString(), "key");
    producer.send(message);
   }
   //Last message only should go to the consumer
   TextMessage tm = (TextMessage) consumer1.receive(10000);
   assertNotNull(tm);
   assertEquals("Message99", tm.getText());
 } finally {
   connection.close();
 }
}

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

fact.setConsumerWindowSize(0);
Connection connection = fact.createConnection();

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

fact.setConsumerWindowSize(0);
Connection connection = fact.createConnection();

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

@Test
public void testBrowserAndConsumerSimultaneous() throws Exception {
 ((ActiveMQConnectionFactory) cf).setConsumerWindowSize(0);
 conn = cf.createConnection();

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

@Test
public void testShareDurable() throws Exception {
 ((ActiveMQConnectionFactory) cf).setConsumerWindowSize(0);
 conn = cf.createConnection();
 conn.start();

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

@Test
public void testGroupingRollbackOnClose() throws Exception {
 ActiveMQConnectionFactory fact = (ActiveMQConnectionFactory) getCF();
 fact.setConsumerWindowSize(1000);
 fact.setTransactionBatchSize(0);
 Connection connection = fact.createConnection();

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

ActiveMQConnectionFactory hcf = (ActiveMQConnectionFactory) factory;
hcf.setConsumerWindowSize(0);

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

jbcf.setConsumerWindowSize(numMessages * bodySize / 10);

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

jbcf.setConsumerWindowSize(numMessages * bodySize / 10);

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

@Test
public void testShareDuraleWithJMSContext() throws Exception {
 ((ActiveMQConnectionFactory) cf).setConsumerWindowSize(0);
 JMSContext conn = cf.createContext(JMSContext.AUTO_ACKNOWLEDGE);

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

jbcf.setConsumerWindowSize(numMessages * bodySize / 10);

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

cf.setCacheLargeMessagesClient(cfConfig.isCacheLargeMessagesClient());
cf.setMinLargeMessageSize(cfConfig.getMinLargeMessageSize());
cf.setConsumerWindowSize(cfConfig.getConsumerWindowSize());
cf.setConsumerMaxRate(cfConfig.getConsumerMaxRate());
cf.setConfirmationWindowSize(cfConfig.getConfirmationWindowSize());

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

factory.setCallTimeout(callTimeout);
factory.setMinLargeMessageSize(minLargeMessageSize);
factory.setConsumerWindowSize(consumerWindowSize);
factory.setConsumerMaxRate(consumerMaxRate);
factory.setConfirmationWindowSize(confirmationWindowSize);

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

cf.setCallTimeout(callTimeout);
cf.setMinLargeMessageSize(minLargeMessageSize);
cf.setConsumerWindowSize(consumerWindowSize);
cf.setConsumerMaxRate(consumerMaxRate);
cf.setConfirmationWindowSize(confirmationWindowSize);

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

cf.setConsumerWindowSize(val2);

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

cf.setConsumerWindowSize(val2);

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

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