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

Message.setBrokerInTime介绍

暂无

代码示例

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));
info.setJMSXGroupFirstForConsumer(dataIn.readBoolean());

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));
info.setJMSXGroupFirstForConsumer(dataIn.readBoolean());

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

@Override
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  ActiveMQDestination destination = message.getDestination();
  message.setBrokerInTime(System.currentTimeMillis());
  if (producerExchange.isMutable() || producerExchange.getRegion() == null
    || (producerExchange.getRegionDestination() != null && producerExchange.getRegionDestination().isDisposed())) {
    // ensure the destination is registered with the RegionBroker
    producerExchange.getConnectionContext().getBroker()
      .addDestination(producerExchange.getConnectionContext(), destination, isAllowTempAutoCreationOnSend());
    producerExchange.setRegion(getRegion(destination));
    producerExchange.setRegionDestination(null);
  }
  producerExchange.getRegion().send(producerExchange, message);
  // clean up so these references aren't kept (possible leak) in the producer exchange
  // especially since temps are transitory
  if (producerExchange.isMutable()) {
    producerExchange.setRegionDestination(null);
    producerExchange.setRegion(null);
  }
}

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));
info.setJMSXGroupFirstForConsumer(dataIn.readBoolean());

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));

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

info.setCluster(null);
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setJMSXGroupFirstForConsumer(bs.readBoolean());

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setJMSXGroupFirstForConsumer(bs.readBoolean());

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setJMSXGroupFirstForConsumer(bs.readBoolean());

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

@Override
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  message.setBrokerInTime(System.currentTimeMillis());
  if (producerExchange.isMutable() || producerExchange.getRegion() == null
      || (producerExchange.getRegion() != null && producerExchange.getRegion().getDestinationMap().get(message.getDestination()) == null)) {
    ActiveMQDestination destination = message.getDestination();
    // ensure the destination is registered with the RegionBroker
    producerExchange.getConnectionContext().getBroker().addDestination(producerExchange.getConnectionContext(), destination,false);
    Region region;
    switch (destination.getDestinationType()) {
    case ActiveMQDestination.QUEUE_TYPE:
      region = queueRegion;
      break;
    case ActiveMQDestination.TOPIC_TYPE:
      region = topicRegion;
      break;
    case ActiveMQDestination.TEMP_QUEUE_TYPE:
      region = tempQueueRegion;
      break;
    case ActiveMQDestination.TEMP_TOPIC_TYPE:
      region = tempTopicRegion;
      break;
    default:
      throw createUnknownDestinationTypeException(destination);
    }
    producerExchange.setRegion(region);
    producerExchange.setRegionDestination(null);
  }
  producerExchange.getRegion().send(producerExchange, message);
}

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

@Override
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  ActiveMQDestination destination = message.getDestination();
  message.setBrokerInTime(System.currentTimeMillis());
  if (producerExchange.isMutable() || producerExchange.getRegion() == null
    || (producerExchange.getRegionDestination() != null && producerExchange.getRegionDestination().isDisposed())) {
    // ensure the destination is registered with the RegionBroker
    producerExchange.getConnectionContext().getBroker()
      .addDestination(producerExchange.getConnectionContext(), destination, isAllowTempAutoCreationOnSend());
    producerExchange.setRegion(getRegion(destination));
    producerExchange.setRegionDestination(null);
  }
  producerExchange.getRegion().send(producerExchange, message);
  // clean up so these references aren't kept (possible leak) in the producer exchange
  // especially since temps are transitory
  if (producerExchange.isMutable()) {
    producerExchange.setRegionDestination(null);
    producerExchange.setRegion(null);
  }
}

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

@Override
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  ActiveMQDestination destination = message.getDestination();
  message.setBrokerInTime(System.currentTimeMillis());
  if (producerExchange.isMutable() || producerExchange.getRegion() == null
    || (producerExchange.getRegionDestination() != null && producerExchange.getRegionDestination().isDisposed())) {
    // ensure the destination is registered with the RegionBroker
    producerExchange.getConnectionContext().getBroker()
      .addDestination(producerExchange.getConnectionContext(), destination, isAllowTempAutoCreationOnSend());
    producerExchange.setRegion(getRegion(destination));
    producerExchange.setRegionDestination(null);
  }
  producerExchange.getRegion().send(producerExchange, message);
  // clean up so these references aren't kept (possible leak) in the producer exchange
  // especially since temps are transitory
  if (producerExchange.isMutable()) {
    producerExchange.setRegionDestination(null);
    producerExchange.setRegion(null);
  }
}

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

@Override
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception {
  ActiveMQDestination destination = message.getDestination();
  message.setBrokerInTime(System.currentTimeMillis());
  if (producerExchange.isMutable() || producerExchange.getRegion() == null
    || (producerExchange.getRegionDestination() != null && producerExchange.getRegionDestination().isDisposed())) {
    // ensure the destination is registered with the RegionBroker
    producerExchange.getConnectionContext().getBroker()
      .addDestination(producerExchange.getConnectionContext(), destination, isAllowTempAutoCreationOnSend());
    producerExchange.setRegion(getRegion(destination));
    producerExchange.setRegionDestination(null);
  }
  producerExchange.getRegion().send(producerExchange, message);
  // clean up so these references aren't kept (possible leak) in the producer exchange
  // especially since temps are transitory
  if (producerExchange.isMutable()) {
    producerExchange.setRegionDestination(null);
    producerExchange.setRegion(null);
  }
}

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

info.setCluster(null);
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));