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

Queue.addSubscription介绍

暂无

代码示例

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

@Override
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception {
  // Only consumers on the same connection can consume from
  // the temporary destination
  // However, we could have failed over - and we do this
  // check client side anyways ....
  if (!context.isFaultTolerant()
      && (!context.isNetworkConnection() && !tempDest
          .getConnectionId().equals(
              sub.getConsumerInfo().getConsumerId()
                  .getConnectionId()))) {
    tempDest.setConnectionId(sub.getConsumerInfo().getConsumerId().getConnectionId());
    LOG.debug("changed ownership of {} to {}", this, tempDest.getConnectionId());
  }
  super.addSubscription(context, sub);
}

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

@Override
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception {
  // Only consumers on the same connection can consume from
  // the temporary destination
  // However, we could have failed over - and we do this
  // check client side anyways ....
  if (!context.isFaultTolerant()
      && (!context.isNetworkConnection() && !tempDest
          .getConnectionId().equals(
              sub.getConsumerInfo().getConsumerId()
                  .getConnectionId()))) {
    tempDest.setConnectionId(sub.getConsumerInfo().getConsumerId().getConnectionId());
    LOG.debug("changed ownership of {} to {}", this, tempDest.getConnectionId());
  }
  super.addSubscription(context, sub);
}

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

@Override
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception {
  // Only consumers on the same connection can consume from
  // the temporary destination
  // However, we could have failed over - and we do this
  // check client side anyways ....
  if (!context.isFaultTolerant()
      && (!context.isNetworkConnection() && !tempDest
          .getConnectionId().equals(
              sub.getConsumerInfo().getConsumerId()
                  .getConnectionId()))) {
    tempDest.setConnectionId(sub.getConsumerInfo().getConsumerId().getConnectionId());
    LOG.debug("changed ownership of {} to {}", this, tempDest.getConnectionId());
  }
  super.addSubscription(context, sub);
}

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

@Override
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception {
  // Only consumers on the same connection can consume from
  // the temporary destination
  // However, we could have failed over - and we do this
  // check client side anyways ....
  if (!context.isFaultTolerant()
      && (!context.isNetworkConnection() && !tempDest
          .getConnectionId().equals(
              sub.getConsumerInfo().getConsumerId()
                  .getConnectionId()))) {
    tempDest.setConnectionId(sub.getConsumerInfo().getConsumerId().getConnectionId());
    LOG.debug("changed ownership of {} to {}", this, tempDest.getConnectionId());
  }
  super.addSubscription(context, sub);
}

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

@Override
public void addSubscription(ConnectionContext context, Subscription sub) throws Exception {
  // Only consumers on the same connection can consume from
  // the temporary destination
  // However, we could have failed over - and we do this
  // check client side anyways ....
  if (!context.isFaultTolerant()
      && (!context.isNetworkConnection() && !tempDest
          .getConnectionId().equals(
              sub.getConsumerInfo().getConsumerId()
                  .getConnectionId()))) {
    tempDest.setConnectionId(sub.getConsumerInfo().getConsumerId().getConnectionId());
    LOG.debug(" changed ownership of " + this + " to "+ tempDest.getConnectionId());
  }
  super.addSubscription(context, sub);
}