org.apache.activemq.broker.region.Queue.getMemoryUsage()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(126)

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

Queue.getMemoryUsage介绍

暂无

代码示例

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

destinationStatistics.getEnqueues().getCount(),
    destinationStatistics.getDequeues().getCount(),
    getMemoryUsage().getUsage(),
    maxPageSize
});

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

public void configure(Broker broker,Queue queue) {
  baseConfiguration(broker,queue);
  if (dispatchPolicy != null) {
    queue.setDispatchPolicy(dispatchPolicy);
  }
  queue.setDeadLetterStrategy(getDeadLetterStrategy());
  queue.setMessageGroupMapFactory(getMessageGroupMapFactory());
  if (memoryLimit > 0) {
    queue.getMemoryUsage().setLimit(memoryLimit);
  }
  if (pendingQueuePolicy != null) {
    PendingMessageCursor messages = pendingQueuePolicy.getQueuePendingMessageCursor(broker,queue);
    queue.setMessages(messages);
  }
  queue.setUseConsumerPriority(isUseConsumerPriority());
  queue.setStrictOrderDispatch(isStrictOrderDispatch());
  queue.setOptimizedDispatch(isOptimizedDispatch());
  queue.setLazyDispatch(isLazyDispatch());
  queue.setTimeBeforeDispatchStarts(getTimeBeforeDispatchStarts());
  queue.setConsumersBeforeDispatchStarts(getConsumersBeforeDispatchStarts());
  queue.setAllConsumersExclusiveByDefault(isAllConsumersExclusiveByDefault());
  queue.setPersistJMSRedelivered(isPersistJMSRedelivered());
}

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

baseUpdate(queue, includedProperties);
if (isUpdate("memoryLimit", includedProperties) && memoryLimit > 0) {
  queue.getMemoryUsage().setLimit(memoryLimit);

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

destinationStatistics.getEnqueues().getCount(),
    destinationStatistics.getDequeues().getCount(),
    getMemoryUsage().getUsage(),
    maxPageSize
});

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

destinationStatistics.getEnqueues().getCount(),
    destinationStatistics.getDequeues().getCount(),
    getMemoryUsage().getUsage(),
    maxPageSize
});

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

destinationStatistics.getEnqueues().getCount(),
    destinationStatistics.getDequeues().getCount(),
    getMemoryUsage().getUsage(),
    maxPageSize
});

代码示例来源:origin: pierre/meteo

public void configure(Broker broker,Queue queue) {
  baseConfiguration(broker,queue);
  if (dispatchPolicy != null) {
    queue.setDispatchPolicy(dispatchPolicy);
  }
  queue.setDeadLetterStrategy(getDeadLetterStrategy());
  queue.setMessageGroupMapFactory(getMessageGroupMapFactory());
  if (memoryLimit > 0) {
    queue.getMemoryUsage().setLimit(memoryLimit);
  }
  if (pendingQueuePolicy != null) {
    PendingMessageCursor messages = pendingQueuePolicy.getQueuePendingMessageCursor(broker,queue);
    queue.setMessages(messages);
  }
  
  queue.setUseConsumerPriority(isUseConsumerPriority());
  queue.setStrictOrderDispatch(isStrictOrderDispatch());
  queue.setOptimizedDispatch(isOptimizedDispatch());
  queue.setLazyDispatch(isLazyDispatch());
  queue.setTimeBeforeDispatchStarts(getTimeBeforeDispatchStarts());
  queue.setConsumersBeforeDispatchStarts(getConsumersBeforeDispatchStarts());
  queue.setAllConsumersExclusiveByDefault(isAllConsumersExclusiveByDefault());
}

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

public void configure(Broker broker,Queue queue) {
  baseConfiguration(broker,queue);
  if (dispatchPolicy != null) {
    queue.setDispatchPolicy(dispatchPolicy);
  }
  queue.setDeadLetterStrategy(getDeadLetterStrategy());
  queue.setMessageGroupMapFactory(getMessageGroupMapFactory());
  if (memoryLimit > 0) {
    queue.getMemoryUsage().setLimit(memoryLimit);
  }
  if (pendingQueuePolicy != null) {
    PendingMessageCursor messages = pendingQueuePolicy.getQueuePendingMessageCursor(broker,queue);
    queue.setMessages(messages);
  }
  queue.setUseConsumerPriority(isUseConsumerPriority());
  queue.setStrictOrderDispatch(isStrictOrderDispatch());
  queue.setOptimizedDispatch(isOptimizedDispatch());
  queue.setLazyDispatch(isLazyDispatch());
  queue.setTimeBeforeDispatchStarts(getTimeBeforeDispatchStarts());
  queue.setConsumersBeforeDispatchStarts(getConsumersBeforeDispatchStarts());
  queue.setAllConsumersExclusiveByDefault(isAllConsumersExclusiveByDefault());
  queue.setPersistJMSRedelivered(isPersistJMSRedelivered());
}

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

public void configure(Broker broker,Queue queue) {
  baseConfiguration(broker,queue);
  if (dispatchPolicy != null) {
    queue.setDispatchPolicy(dispatchPolicy);
  }
  queue.setDeadLetterStrategy(getDeadLetterStrategy());
  queue.setMessageGroupMapFactory(getMessageGroupMapFactory());
  if (memoryLimit > 0) {
    queue.getMemoryUsage().setLimit(memoryLimit);
  }
  if (pendingQueuePolicy != null) {
    PendingMessageCursor messages = pendingQueuePolicy.getQueuePendingMessageCursor(broker,queue);
    queue.setMessages(messages);
  }
  queue.setUseConsumerPriority(isUseConsumerPriority());
  queue.setStrictOrderDispatch(isStrictOrderDispatch());
  queue.setOptimizedDispatch(isOptimizedDispatch());
  queue.setLazyDispatch(isLazyDispatch());
  queue.setTimeBeforeDispatchStarts(getTimeBeforeDispatchStarts());
  queue.setConsumersBeforeDispatchStarts(getConsumersBeforeDispatchStarts());
  queue.setAllConsumersExclusiveByDefault(isAllConsumersExclusiveByDefault());
  queue.setPersistJMSRedelivered(isPersistJMSRedelivered());
}

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

public void configure(Broker broker,Queue queue) {
  baseConfiguration(broker,queue);
  if (dispatchPolicy != null) {
    queue.setDispatchPolicy(dispatchPolicy);
  }
  queue.setDeadLetterStrategy(getDeadLetterStrategy());
  queue.setMessageGroupMapFactory(getMessageGroupMapFactory());
  if (memoryLimit > 0) {
    queue.getMemoryUsage().setLimit(memoryLimit);
  }
  if (pendingQueuePolicy != null) {
    PendingMessageCursor messages = pendingQueuePolicy.getQueuePendingMessageCursor(broker,queue);
    queue.setMessages(messages);
  }
  queue.setUseConsumerPriority(isUseConsumerPriority());
  queue.setStrictOrderDispatch(isStrictOrderDispatch());
  queue.setOptimizedDispatch(isOptimizedDispatch());
  queue.setLazyDispatch(isLazyDispatch());
  queue.setTimeBeforeDispatchStarts(getTimeBeforeDispatchStarts());
  queue.setConsumersBeforeDispatchStarts(getConsumersBeforeDispatchStarts());
  queue.setAllConsumersExclusiveByDefault(isAllConsumersExclusiveByDefault());
  queue.setPersistJMSRedelivered(isPersistJMSRedelivered());
}

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

baseUpdate(queue, includedProperties);
if (isUpdate("memoryLimit", includedProperties) && memoryLimit > 0) {
  queue.getMemoryUsage().setLimit(memoryLimit);

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

baseUpdate(queue, includedProperties);
if (isUpdate("memoryLimit", includedProperties) && memoryLimit > 0) {
  queue.getMemoryUsage().setLimit(memoryLimit);

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

baseUpdate(queue, includedProperties);
if (isUpdate("memoryLimit", includedProperties) && memoryLimit > 0) {
  queue.getMemoryUsage().setLimit(memoryLimit);

相关文章

Queue类方法