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

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

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

Queue.setLazyDispatch介绍

暂无

代码示例

代码示例来源: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

queue.setLazyDispatch(isLazyDispatch());

代码示例来源: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-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

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

queue.setLazyDispatch(isLazyDispatch());

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

queue.setLazyDispatch(isLazyDispatch());

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

queue.setLazyDispatch(isLazyDispatch());

相关文章

微信公众号

最新文章

更多

Queue类方法