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

Queue.setMessageGroupMapFactory介绍

暂无

代码示例

代码示例来源：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: 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());
}