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

Queue.getMaxConsumers介绍

暂无

代码示例

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

@Override
  StringBuilder format(Queue queue, StringBuilder output) {
   output.append("Queue [name=").append(queue.getName());
   output.append(", address=").append(queue.getAddress());
   output.append(", routingType=").append(queue.getRoutingType());
   final Filter filter = queue.getFilter();
   if (filter != null) {
     output.append(", filter=").append(filter.getFilterString());
   }
   output.append(", durable=").append(queue.isDurable());
   final int maxConsumers = queue.getMaxConsumers();
   if (maxConsumers != Queue.MAX_CONSUMERS_UNLIMITED) {
     output.append(", maxConsumers=").append(queue.getMaxConsumers());
   }
   output.append(", purgeOnNoConsumers=").append(queue.isPurgeOnNoConsumers());
   output.append(", autoCreateAddress=").append(queue.isAutoCreated());
   output.append(", exclusive=").append(queue.isExclusive());
   output.append(", lastValue=").append(queue.isLastValue());
   output.append(", lastValueKey=").append(queue.getLastValueKey());
   output.append(", nonDestructive=").append(queue.isNonDestructive());
   output.append(", consumersBeforeDispatch=").append(queue.getConsumersBeforeDispatch());
   output.append(", delayBeforeDispatch=").append(queue.getDelayBeforeDispatch());
   output.append(", autoCreateAddress=").append(queue.isAutoCreated());
   output.append(']');
   return output;
  }
};

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

@Override
public int getMaxConsumers() {
 checkStarted();
 clearIO();
 try {
   return queue.getMaxConsumers();
 } finally {
   blockOnIO();
 }
}

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

@Test
public void defaultAutoCreatedQueueConfigTest2() throws Exception {
 final String queueName = "q1";
 server.getAddressSettingsRepository().addMatch(queueName, new AddressSettings().setDefaultMaxConsumers(5).setDefaultPurgeOnNoConsumers(true));
 Connection connection = cf.createConnection();
 Session session = connection.createSession();
 session.createProducer(session.createQueue(queueName));
 org.apache.activemq.artemis.core.server.Queue  queue = server.locateQueue(SimpleString.toSimpleString(queueName));
 assertEquals(5, queue.getMaxConsumers());
 assertEquals(true, queue.isPurgeOnNoConsumers());
 connection.close();
}

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

@Test
public void defaultAutoCreatedQueueConfigTest() throws Exception {
 final String queueName = "q1";
 server.getAddressSettingsRepository()
    .addMatch(queueName, new AddressSettings()
      .setDefaultMaxConsumers(5)
      .setDefaultPurgeOnNoConsumers(true));
 Connection connection = cf.createConnection();
 Session session = connection.createSession();
 session.createConsumer(session.createQueue(queueName));
 org.apache.activemq.artemis.core.server.Queue  queue = server.locateQueue(SimpleString.toSimpleString(queueName));
 assertEquals(5, queue.getMaxConsumers());
 assertEquals(true, queue.isPurgeOnNoConsumers());
 connection.close();
}

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

if (maxConsumers != null && queue.getMaxConsumers() != maxConsumers.intValue()) {
  changed = true;
  queue.setMaxConsumer(maxConsumers);

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

@Test
public void testCreateCoreQueueAutoCreateAddressDefaultAddress() throws Exception {
 String queueName = UUID.randomUUID().toString();
 CreateQueue command = new CreateQueue();
 command.setName(queueName);
 command.setAutoCreateAddress(true);
 command.setMulticast(true);
 command.setAnycast(false);
 command.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
 checkExecutionPassed(command);
 assertNotNull(server.getAddressInfo(new SimpleString(queueName)));
 Queue queue = server.locateQueue(new SimpleString(queueName));
 assertEquals(-1, queue.getMaxConsumers());
 assertEquals(false, queue.isPurgeOnNoConsumers());
 assertTrue(server.queueQuery(new SimpleString(queueName)).isExists());
}

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

@Test
public void testDuplicateQueue() throws Exception {
 String filename = "duplicateQueue.xml";
 FileConfiguration fc = new FileConfiguration();
 FileDeploymentManager deploymentManager = new FileDeploymentManager(filename);
 deploymentManager.addDeployable(fc);
 deploymentManager.readConfiguration();
 ActiveMQServer server = addServer((ActiveMQServer) deploymentManager.buildService(null, null).get("core"));
 server.start();
 assertEquals(0, server.locateQueue(SimpleString.toSimpleString("q")).getMaxConsumers());
}

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

Assert.assertEquals(1, queue.getMaxConsumers());

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

Assert.assertEquals(1, queue.getMaxConsumers());

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

@Test
public void testCreateCoreQueueAddressExists() throws Exception {
 String queueName = "queue";
 String address = "address";
 CreateQueue command = new CreateQueue();
 command.setName(queueName);
 command.setAutoCreateAddress(false);
 command.setMulticast(true);
 command.setAnycast(false);
 command.setAddress(address);
 server.addOrUpdateAddressInfo(new AddressInfo(new SimpleString(address), RoutingType.MULTICAST));
 command.execute(new ActionContext(System.in, new PrintStream(output), new PrintStream(error)));
 checkExecutionPassed(command);
 assertNotNull(server.getAddressInfo(new SimpleString(address)));
 Queue queue = server.locateQueue(new SimpleString(queueName));
 assertEquals(-1, queue.getMaxConsumers());
 assertEquals(false, queue.isPurgeOnNoConsumers());
 assertTrue(server.queueQuery(new SimpleString(queueName)).isExists());
}

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

Assert.assertEquals(10, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").getMaxConsumers());
Assert.assertEquals(false, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").isPurgeOnNoConsumers());
Assert.assertEquals(1, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").getMaxConsumers());
Assert.assertEquals(true, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").isPurgeOnNoConsumers());

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

private void internalQueueBinding(boolean update, final long tx, final Binding binding) throws Exception {
 Queue queue = (Queue) binding.getBindable();
 Filter filter = queue.getFilter();
 SimpleString filterString = filter == null ? null : filter.getFilterString();
 PersistentQueueBindingEncoding bindingEncoding = new PersistentQueueBindingEncoding(queue.getName(), binding.getAddress(), filterString, queue.getUser(), queue.isAutoCreated(), queue.getMaxConsumers(), queue.isPurgeOnNoConsumers(), queue.isExclusive(), queue.isLastValue(), queue.getLastValueKey(), queue.isNonDestructive(), queue.getConsumersBeforeDispatch(), queue.getDelayBeforeDispatch(), queue.getRoutingType().getType(), queue.isConfigurationManaged());
 readLock();
 try {
   if (update) {
    bindingsJournal.appendUpdateRecordTransactional(tx, binding.getID(), JournalRecordIds.QUEUE_BINDING_RECORD, bindingEncoding);
   } else {
    bindingsJournal.appendAddRecordTransactional(tx, binding.getID(), JournalRecordIds.QUEUE_BINDING_RECORD, bindingEncoding);
   }
 } finally {
   readUnLock();
 }
}

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

Assert.assertEquals(10, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").getMaxConsumers());
  Assert.assertEquals(false, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").isPurgeOnNoConsumers());
  Assert.assertEquals(1, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").getMaxConsumers());
  Assert.assertEquals(true, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").isPurgeOnNoConsumers());
} finally {
  Assert.assertEquals(1, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").getMaxConsumers());
  Assert.assertEquals(true, getQueue(embeddedActiveMQ, "config_test_queue_change_queue").isPurgeOnNoConsumers());

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

@Test
public void defaultAutoCreatedQueueConfigTest() throws Exception {
 final String queueName = "q1";
 server.getAddressSettingsRepository().addMatch(queueName, new AddressSettings().setDefaultMaxConsumers(5).setDefaultPurgeOnNoConsumers(true));
 Queue q1 = context.createQueue(queueName);
 context.createProducer().setProperty("prop1", 1).setProperty("prop2", 2).send(q1, "Text1");
 org.apache.activemq.artemis.core.server.Queue  queue = server.locateQueue(SimpleString.toSimpleString(queueName));
 assertEquals(5, queue.getMaxConsumers());
 assertEquals(true, queue.isPurgeOnNoConsumers());
}

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

response = new QueueQueryResult(realName, binding.getAddress(), queue.isDurable(), queue.isTemporary(), filterString, queue.getConsumerCount(), queue.getMessageCount(), autoCreateQueues, true, queue.isAutoCreated(), queue.isPurgeOnNoConsumers(), queue.getRoutingType(), queue.getMaxConsumers(), queue.isExclusive(), queue.isLastValue(), queue.getLastValueKey(), queue.isNonDestructive(), queue.getConsumersBeforeDispatch(), queue.getDelayBeforeDispatch(), defaultConsumerWindowSize);
} else if (realName.equals(managementAddress)) {