gpt4 book ai didi

org.fabric3.spi.federation.ZoneTopologyService.openChannel()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-16 04:15:31 26 4
gpt4 key购买 nike

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

ZoneTopologyService.openChannel介绍

暂无

代码示例

代码示例来源:origin: org.codehaus.fabric3/fabric3-binding-zeromq

@Init
public void init() throws MessageException {
  topologyService.register(this);
  topologyService.openChannel(qualifiedChannelName, null, this);
  AddressRequest request = new AddressRequest(info.getRuntimeName());
  topologyService.sendAsynchronous(qualifiedChannelName, request);
}

代码示例来源:origin: org.codehaus.fabric3/fabric3-channel-impl

public Channel build(PhysicalChannelDefinition definition) throws BuilderException {
  URI uri = definition.getUri();
  QName deployable = definition.getDeployable();
  FanOutHandler fanOutHandler;
  if (definition.getBindingDefinition() != null) {
    // if a binding is set on the channel, make the channel synchronous since async behavior will be provided by the binding
    fanOutHandler = new SyncFanOutHandler();
  } else {
    // the channel is local, have it implement asynchrony
    fanOutHandler = new AsyncFanOutHandler(executorService);
  }
  Channel channel;
  if (definition.isReplicate() && replicationCapable) {
    String channelName = uri.toString();
    ReplicationHandler replicationHandler = new ReplicationHandler(channelName, topologyService, monitor);
    channel = new DefaultChannelImpl(uri, deployable, replicationHandler, fanOutHandler, definition.getChannelSide());
    if (!topologyService.isChannelOpen(channelName)) {
      try {
        topologyService.openChannel(channelName, null, replicationHandler);
      } catch (ZoneChannelException e) {
        throw new BuilderException(e);
      }
    }
  } else {
    channel = new DefaultChannelImpl(uri, deployable, fanOutHandler, definition.getChannelSide());
  }
  PhysicalChannelBindingDefinition bindingDefinition = definition.getBindingDefinition();
  buildBinding(channel, bindingDefinition);
  return channel;
}

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com