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

Transport.setChannelMax介绍

[英]Set the local value of channel-max, to be advertised to the peer on the Open frame emitted by the transport. The remote peers advertised channel-max can be observed using #getRemoteChannelMax().
[中]设置通道最大值的本地值，该值将在传输发出的Open frame上通告给对等方。可以使用#getRemoteChannelMax（）来观察远程通道最大值。

代码示例

代码示例来源：origin: org.apache.activemq/artemis-proton-plug

public AbstractConnectionContext(AMQPConnectionCallback connectionCallback,
                String containerId,
                int idleTimeout,
                int maxFrameSize,
                int channelMax,
                Executor dispatchExecutor,
                ScheduledExecutorService scheduledPool) {
 this.connectionCallback = connectionCallback;
 this.containerId = (containerId != null) ? containerId : UUID.randomUUID().toString();
 connectionProperties.put(Symbol.valueOf("product"), "apache-activemq-artemis");
 connectionProperties.put(Symbol.valueOf("version"), VersionLoader.getVersion().getFullVersion());
 this.scheduledPool = scheduledPool;
 connectionCallback.setConnection(this);
 this.handler =   ProtonHandler.Factory.create(dispatchExecutor);
 Transport transport = handler.getTransport();
 transport.setEmitFlowEventOnSend(false);
 if (idleTimeout > 0) {
   transport.setIdleTimeout(idleTimeout);
 }
 transport.setChannelMax(channelMax);
 transport.setMaxFrameSize(maxFrameSize);
 handler.addEventHandler(listener);
}

代码示例来源：origin: org.apache.activemq/artemis-amqp-protocol

transport.setIdleTimeout(idleTimeout);
transport.setChannelMax(channelMax);
transport.setInitialRemoteMaxFrameSize(protocolManager.getInitialRemoteMaxFrameSize());
transport.setMaxFrameSize(maxFrameSize);

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

transport.setIdleTimeout(idleTimeout);
transport.setChannelMax(channelMax);
transport.setInitialRemoteMaxFrameSize(protocolManager.getInitialRemoteMaxFrameSize());
transport.setMaxFrameSize(maxFrameSize);

代码示例来源：origin: apache/qpid-jms

protonTransport.setChannelMax(getChannelMax());
protonTransport.setIdleTimeout(idleTimeout);
protonTransport.bind(protonConnection);

代码示例来源：origin: org.apache.qpid/qpid-jms-client

protonTransport.setChannelMax(getChannelMax());
protonTransport.setIdleTimeout(idleTimeout);
protonTransport.bind(protonConnection);

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

protonTransport.setChannelMax(getChannelMax());
protonTransport.setEmitFlowEventOnSend(false);
protonTransport.bind(getEndpoint());

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

public AmqpConnection(AmqpTransport transport, BrokerService brokerService) {
  this.amqpTransport = transport;
  AmqpInactivityMonitor monitor = transport.getInactivityMonitor();
  if (monitor != null) {
    monitor.setAmqpTransport(amqpTransport);
  }
  this.amqpWireFormat = transport.getWireFormat();
  this.brokerService = brokerService;
  // the configured maxFrameSize on the URI.
  int maxFrameSize = amqpWireFormat.getMaxAmqpFrameSize();
  if (maxFrameSize > AmqpWireFormat.NO_AMQP_MAX_FRAME_SIZE) {
    this.protonTransport.setMaxFrameSize(maxFrameSize);
    try {
      this.protonTransport.setOutboundFrameSizeLimit(maxFrameSize);
    } catch (Throwable e) {
      // Ignore if older proton-j was injected.
    }
  }
  this.protonTransport.bind(this.protonConnection);
  this.protonTransport.setChannelMax(CHANNEL_MAX);
  this.protonTransport.setEmitFlowEventOnSend(false);
  this.protonConnection.collect(eventCollector);
  updateTracer();
}

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

public AmqpConnection(AmqpTransport transport, BrokerService brokerService) {
  this.amqpTransport = transport;
  AmqpInactivityMonitor monitor = transport.getInactivityMonitor();
  if (monitor != null) {
    monitor.setAmqpTransport(amqpTransport);
  }
  this.amqpWireFormat = transport.getWireFormat();
  this.brokerService = brokerService;
  // the configured maxFrameSize on the URI.
  int maxFrameSize = amqpWireFormat.getMaxAmqpFrameSize();
  if (maxFrameSize > AmqpWireFormat.NO_AMQP_MAX_FRAME_SIZE) {
    this.protonTransport.setMaxFrameSize(maxFrameSize);
    try {
      this.protonTransport.setOutboundFrameSizeLimit(maxFrameSize);
    } catch (Throwable e) {
      // Ignore if older proton-j was injected.
    }
  }
  this.protonTransport.bind(this.protonConnection);
  this.protonTransport.setChannelMax(CHANNEL_MAX);
  this.protonTransport.setEmitFlowEventOnSend(false);
  this.protonConnection.collect(eventCollector);
  updateTracer();
}