Build a new {@link ChannelManagementSyncClient}.
481643
public ChannelManagementSyncClient build() {
        final Builder okHttpClientBuilder = new Builder();

        okHttpClientBuilder
                .addInterceptor(buildAuthenticationInterceptor(channelTokenSupplier))
                .addInterceptor(buildLoggingInterceptor());

        final OkHttpClient okHttpClient = okHttpClientBuilder.build();

        final Retrofit.Builder retrofitBuilder = createDefaultRetrofitBuilder();

        retrofitBuilder.client(okHttpClient);
        retrofitBuilder.baseUrl(apiEndPoint.toString());
        final Retrofit retrofit = retrofitBuilder.build();

        final ChannelManagementClientRetrofitIface retrofitIface =
                retrofit.create(ChannelManagementClientRetrofitIface.class);
        return ChannelManagementSyncClientImpl.of(retrofitIface);
    }
608257
public PingOperation newPingOperation(boolean releaseChannel) {
      return new PingOperation(codec, topologyId, cfg, cacheNameBytes, channelFactory, releaseChannel, this);
   }
243903
private IChannelConsumer getClientChannelFor(
            String functionalityName,
            IAsyncMessageClient client,
            String conversationID) throws ServiceGroundingException
    {
        IChannelConsumer channel = this.channelConsumersHelper.getChannel(functionalityName, client.getName(), conversationID);
        if (null != channel)
        {
            return channel;
        }

        IChannelConsumer newChannel = createClientChannelFor(functionalityName, client.getName(), conversationID);
        newChannel.addClientCallback(client);
        this.channelConsumersHelper.addChannel(newChannel, functionalityName, client.getName(), conversationID);
        return newChannel;
    }
556462
public ListenableFuture<T> createAsync(final TwilioRestClient client) {
        return Twilio.getExecutorService().submit(new Callable<T>() {
            public T call() {
                return create(client);
            }
        });
    }
378324
public static base_response add(nitro_service client, channel resource) throws Exception {
		channel addresource = new channel();
		addresource.id = resource.id;
		addresource.ifnum = resource.ifnum;
		addresource.state = resource.state;
		addresource.mode = resource.mode;
		addresource.conndistr = resource.conndistr;
		addresource.macdistr = resource.macdistr;
		addresource.lamac = resource.lamac;
		addresource.speed = resource.speed;
		addresource.flowctl = resource.flowctl;
		addresource.hamonitor = resource.hamonitor;
		addresource.tagall = resource.tagall;
		addresource.trunk = resource.trunk;
		addresource.ifalias = resource.ifalias;
		addresource.throughput = resource.throughput;
		addresource.bandwidthhigh = resource.bandwidthhigh;
		addresource.bandwidthnormal = resource.bandwidthnormal;
		return addresource.add_resource(client);
	}
65796
public static CuratorFramework newClient(String connectString, int sessionTimeoutMs, int connectionTimeoutMs, RetryPolicy retryPolicy)
    {
        return builder().
            connectString(connectString).
            sessionTimeoutMs(sessionTimeoutMs).
            connectionTimeoutMs(connectionTimeoutMs).
            retryPolicy(retryPolicy).
            build();
    }
1039893
@Override
    public synchronized ClientBootstrap newClientBootstrap() throws Exception {

        if (clientChannelFactory == null) {
            Executor workerExecutor = executorServiceFactory.newExecutorService("worker.client");
            NioDatagramWorkerPool workerPool = new NioDatagramWorkerPool(workerExecutor, 1);
            clientChannelFactory = new NioDatagramChannelFactory(workerPool);

            // unshared
            channelFactories.add(clientChannelFactory);
        }

        return new UdpClientBootstrap(clientChannelFactory, timer);
    }
787523
public T open(RequestChannel channel)
    {
        return clientManager.createClient(channel, clientType, clientName, eventHandlers);
    }
82660
public final ControlCreateStream createNewControlCreateStream() throws MessageCreateFailedException {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "createNewControlCreateStream");
    ControlCreateStream msg = null;
    try {
      msg = new ControlCreateStreamImpl(MfpConstants.CONSTRUCTOR_NO_OP);
    }
    catch (MessageDecodeFailedException e) {
      /* No need to FFDC this as JsMsgObject will already have done so */
      // No FFDC code needed
      throw new MessageCreateFailedException(e);
    }
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "createNewControlCreateStream");
    return msg;
  }
1018518
public final ControlCreateDurable createNewControlCreateDurable() throws MessageCreateFailedException {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "createNewControlCreateDurable");
    ControlCreateDurable msg = null;
    try {
      msg = new ControlCreateDurableImpl(MfpConstants.CONSTRUCTOR_NO_OP);
    }
    catch (MessageDecodeFailedException e) {
      /* No need to FFDC this as JsMsgObject will already have done so */
      // No FFDC code needed
      throw new MessageCreateFailedException(e);
    }
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "createNewControlCreateDurable");
    return msg;
  }
441747
public static Bridge create(final BandwidthClient client, final Map<String, Object>params)
    	    throws Exception {
    	
        assert (client!= null && params != null);
    	final String bridgesUri =  client.getUserResourceUri(BandwidthConstants.BRIDGES_URI_PATH);
    	final RestResponse response = client.post(bridgesUri, params);
    	final JSONObject callObj = toJSONObject(client.get(response.getLocation(), null));
    	final Bridge bridge = new Bridge(client, callObj);
    	return bridge;
	}
382684
@Override
    public void openChannel(FutureCallback<Channel> callback) throws IllegalStateException {
        assertOpen();

        ChannelFuture future = this.bootstrap.clone().register();
        future.addListener(new NetworkManagerChannelFutureCallback(callback));
    }
1262168
public Channel build() {
        Channel channel = null;
        if (_channelClass != null) {
            channel = Construction.construct(_channelClass);
            if (channel instanceof SwitchYardServiceChannel) {
                SwitchYardServiceChannel sysc = (SwitchYardServiceChannel)channel;
                sysc.setServiceName(_serviceName);
                sysc.setOperationName(_operationName);
                sysc.setInvoker(new SwitchYardServiceInvoker(getServiceDomain(), _targetNamespace));
            }
        }
        return channel;
    }
81635
public Client newClient(String clientName, Collection<JaxRsFeatureGroup> featureGroups) {
        return newBuilder(clientName, featureGroups).build();
    }
933947
public final ControlReject createNewControlReject() throws MessageCreateFailedException {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "createNewControlReject");
    ControlReject msg = null;
    try {
      msg = new ControlRejectImpl(MfpConstants.CONSTRUCTOR_NO_OP);
    }
    catch (MessageDecodeFailedException e) {
      /* No need to FFDC this as JsMsgObject will already have done so */
      // No FFDC code needed
      throw new MessageCreateFailedException(e);
    }
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "createNewControlReject");
    return msg;
  }
1305883
static SocketChannelUDT newConnectorChannelUDT(final TypeUDT type) {
        try {
            return SelectorProviderUDT.from(type).openSocketChannel();
        } catch (final IOException e) {
            throw new ChannelException("failed to open a socket channel", e);
        }
    }
580105
public final ControlRequestAck createNewControlRequestAck() throws MessageCreateFailedException {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "createNewControlRequestAck");
    ControlRequestAck msg = null;
    try {
      msg = new ControlRequestAckImpl(MfpConstants.CONSTRUCTOR_NO_OP);
    }
    catch (MessageDecodeFailedException e) {
      /* No need to FFDC this as JsMsgObject will already have done so */
      // No FFDC code needed
      throw new MessageCreateFailedException(e);
    }
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "createNewControlRequestAck");
    return msg;
  }