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

Broker.getAdaptor介绍

[英]Get a Broker from the Broker Stack that is a particular class
[中]从作为特定类的代理堆栈中获取代理

代码示例

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

@Override
public Broker getAdaptor(Class<?> type) {
  if (type.isInstance(this)) {
    return this;
  }
  return next.get().getAdaptor(type);
}

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

@Override
public Broker getAdaptor(Class<?> type) {
  return type.isInstance(this) ? this : getNext().getAdaptor(type);
}

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

public SelectorAwareVirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic) {
  super(next, virtualTopic);
  selectorCachePlugin = (SubQueueSelectorCacheBroker)
      ((Topic)next).createConnectionContext().getBroker().getAdaptor(SubQueueSelectorCacheBroker.class);
}

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

public AuthorizationBroker(Broker next, AuthorizationMap authorizationMap) {
  super(next);
  this.authorizationMap = authorizationMap;
  // add DestinationInterceptor
  final RegionBroker regionBroker = (RegionBroker) next.getAdaptor(RegionBroker.class);
  final CompositeDestinationInterceptor compositeInterceptor = (CompositeDestinationInterceptor) regionBroker.getDestinationInterceptor();
  DestinationInterceptor[] interceptors = compositeInterceptor.getInterceptors();
  interceptors = Arrays.copyOf(interceptors, interceptors.length + 1);
  interceptors[interceptors.length - 1] = new AuthorizationDestinationInterceptor(this);
  compositeInterceptor.setInterceptors(interceptors);
}

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

private synchronized MessageInterceptorFilter getFilter() {
    if (filter == null) {
      try {
        MutableBrokerFilter mutableBrokerFilter = (MutableBrokerFilter) brokerService.getBroker().getAdaptor(MutableBrokerFilter.class);
        Broker next = mutableBrokerFilter.getNext();
        filter = new MessageInterceptorFilter(next);
        mutableBrokerFilter.setNext(filter);
      } catch (Exception e) {
        LOG.error("Failed to create MessageInterceptorFilter", e);
      }
    }
    return filter;
  }
}

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

private void fireFailedForwardAdvisory(MessageDispatch messageDispatch, Throwable error) {
  if (configuration.isAdvisoryForFailedForward()) {
    AdvisoryBroker advisoryBroker = null;
    try {
      advisoryBroker = (AdvisoryBroker) brokerService.getBroker().getAdaptor(AdvisoryBroker.class);
      if (advisoryBroker != null) {
        ConnectionContext context = new ConnectionContext();
        context.setSecurityContext(SecurityContext.BROKER_SECURITY_CONTEXT);
        context.setBroker(brokerService.getBroker());
        ActiveMQMessage advisoryMessage = new ActiveMQMessage();
        advisoryMessage.setStringProperty("cause", error.getLocalizedMessage());
        advisoryBroker.fireAdvisory(context, AdvisorySupport.getNetworkBridgeForwardFailureAdvisoryTopic(), messageDispatch.getMessage(), null,
            advisoryMessage);
      }
    } catch (Exception e) {
      LOG.warn("failed to fire forward failure advisory, cause: {}", e);
      LOG.debug("detail", e);
    }
  }
}

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

AdvisoryBroker ab = (AdvisoryBroker) brokerService.getBroker().getAdaptor(AdvisoryBroker.class);
if (ab != null && brokerService.isUseVirtualDestSubs() && config.isUseVirtualDestSubs()) {
  for (ConsumerInfo info : ab.getVirtualDestinationConsumers().keySet()) {

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

this.brokerService = broker.getBrokerService();
RegionBroker rb = (RegionBroker) broker.getAdaptor(RegionBroker.class);
brokerConnectionStates = rb.getConnectionStates();
if (connector != null) {

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

final RegionBroker regionBroker = (RegionBroker) context.getBroker().getAdaptor(RegionBroker.class);
final Set<Destination> virtualDests = regionBroker.getDestinations(virtualDestination);

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

@Override
public Broker getAdaptor(Class<?> type) {
  if (type.isInstance(this)) {
    return this;
  }
  return next.get().getAdaptor(type);
}

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

@Override
public Broker getAdaptor(Class<?> type) {
  if (type.isInstance(this)) {
    return this;
  }
  return next.get().getAdaptor(type);
}

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

@Override
public Broker getAdaptor(Class<?> type) {
  if (type.isInstance(this)) {
    return this;
  }
  return next.get().getAdaptor(type);
}

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

private AuthenticationBroker getAuthenticator() {
  if (authenticator == null) {
    try {
      authenticator = (AuthenticationBroker) brokerService.getBroker().getAdaptor(AuthenticationBroker.class);
    } catch (Exception e) {
      LOG.debug("Failed to lookup AuthenticationBroker from Broker, will use a default Noop version.");
    }
    if (authenticator == null) {
      authenticator = new DefaultAuthenticationBroker();
    }
  }
  return authenticator;
}

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

public SelectorAwareVirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic) {
  super(next, virtualTopic);
  selectorCachePlugin = (SubQueueSelectorCacheBroker)
      ((Topic)next).createConnectionContext().getBroker().getAdaptor(SubQueueSelectorCacheBroker.class);
}

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

public SelectorAwareVirtualTopicInterceptor(Destination next, VirtualTopic virtualTopic) {
  super(next, virtualTopic);
  selectorCachePlugin = (SubQueueSelectorCacheBroker)
      ((Topic)next).createConnectionContext().getBroker().getAdaptor(SubQueueSelectorCacheBroker.class);
}

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

Subscription lookupPrefetchSubscription(ConsumerInfo consumerInfo)  {
  Subscription subscription = null;
  try {
    subscription = ((AbstractRegion)((RegionBroker) brokerService.getBroker().getAdaptor(RegionBroker.class)).getRegion(consumerInfo.getDestination())).getSubscriptions().get(consumerInfo.getConsumerId());
  } catch (Exception e) {
    LOG.warn("Error finding subscription for: " + consumerInfo + ": " + e.getMessage(), false, e);
  }
  return subscription;
}

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

Subscription lookupPrefetchSubscription(ConsumerInfo consumerInfo)  {
  Subscription subscription = null;
  try {
    subscription = ((AbstractRegion)((RegionBroker) brokerService.getBroker().getAdaptor(RegionBroker.class)).getRegion(consumerInfo.getDestination())).getSubscriptions().get(consumerInfo.getConsumerId());
  } catch (Exception e) {
    LOG.warn("Error finding subscription for: " + consumerInfo + ": " + e.getMessage(), false, e);
  }
  return subscription;
}

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

public AuthorizationBroker(Broker next, AuthorizationMap authorizationMap) {
  super(next);
  this.authorizationMap = authorizationMap;
  // add DestinationInterceptor
  final RegionBroker regionBroker = (RegionBroker) next.getAdaptor(RegionBroker.class);
  final CompositeDestinationInterceptor compositeInterceptor = (CompositeDestinationInterceptor) regionBroker.getDestinationInterceptor();
  DestinationInterceptor[] interceptors = compositeInterceptor.getInterceptors();
  interceptors = Arrays.copyOf(interceptors, interceptors.length + 1);
  interceptors[interceptors.length - 1] = new AuthorizationDestinationInterceptor(this);
  compositeInterceptor.setInterceptors(interceptors);
}

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

public AuthorizationBroker(Broker next, AuthorizationMap authorizationMap) {
  super(next);
  this.authorizationMap = authorizationMap;
  // add DestinationInterceptor
  final RegionBroker regionBroker = (RegionBroker) next.getAdaptor(RegionBroker.class);
  final CompositeDestinationInterceptor compositeInterceptor = (CompositeDestinationInterceptor) regionBroker.getDestinationInterceptor();
  DestinationInterceptor[] interceptors = compositeInterceptor.getInterceptors();
  interceptors = Arrays.copyOf(interceptors, interceptors.length + 1);
  interceptors[interceptors.length - 1] = new AuthorizationDestinationInterceptor(this);
  compositeInterceptor.setInterceptors(interceptors);
}

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

public AuthorizationBroker(Broker next, AuthorizationMap authorizationMap) {
  super(next);
  this.authorizationMap = authorizationMap;
  // add DestinationInterceptor
  final RegionBroker regionBroker = (RegionBroker) next.getAdaptor(RegionBroker.class);
  final CompositeDestinationInterceptor compositeInterceptor = (CompositeDestinationInterceptor) regionBroker.getDestinationInterceptor();
  DestinationInterceptor[] interceptors = compositeInterceptor.getInterceptors();
  interceptors = Arrays.copyOf(interceptors, interceptors.length + 1);
  interceptors[interceptors.length - 1] = new AuthorizationDestinationInterceptor(this);
  compositeInterceptor.setInterceptors(interceptors);
}