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

Transport.setIdleTimeout介绍

暂无

代码示例

代码示例来源：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.setEmitFlowEventOnSend(false);
if (idleTimeout > 0) {
  transport.setIdleTimeout(idleTimeout);

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

transport.setEmitFlowEventOnSend(false);
if (idleTimeout > 0) {
  transport.setIdleTimeout(idleTimeout);

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

protonTransport.setIdleTimeout(idleTimeout);
protonTransport.bind(protonConnection);
protonConnection.collect(protonCollector);

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

protonTransport.setIdleTimeout(idleTimeout);
protonTransport.bind(protonConnection);
protonConnection.collect(protonCollector);

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

if (amqpTransport.isUseInactivityMonitor() && amqpWireFormat.getIdleTimeout() > 0) {
  LOG.trace("Connection requesting Idle timeout of: {} mills", amqpWireFormat.getIdleTimeout());
  protonTransport.setIdleTimeout(amqpWireFormat.getIdleTimeout());

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

if (amqpTransport.isUseInactivityMonitor() && amqpWireFormat.getIdleTimeout() > 0) {
  LOG.trace("Connection requesting Idle timeout of: {} mills", amqpWireFormat.getIdleTimeout());
  protonTransport.setIdleTimeout(amqpWireFormat.getIdleTimeout());

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

protonTransport.setIdleTimeout(getIdleTimeout());

代码示例来源：origin: io.vertx/vertx-proton

ProtonTransport(Connection connection, Vertx vertx, NetClient netClient, NetSocket socket,
        ProtonSaslAuthenticator authenticator, ProtonTransportOptions options) {
 this.connection = connection;
 this.vertx = vertx;
 this.netClient = netClient;
 this.socket = socket;
 int maxFrameSize = options.getMaxFrameSize() == 0 ? DEFAULT_MAX_FRAME_SIZE : options.getMaxFrameSize();
 transport.setMaxFrameSize(maxFrameSize);
 transport.setOutboundFrameSizeLimit(maxFrameSize);
 transport.setEmitFlowEventOnSend(false); // TODO: make configurable
 transport.setIdleTimeout(2 * options.getHeartbeat());
 ((TransportInternal) transport).setUseReadOnlyOutputBuffer(false);
 if (authenticator != null) {
  authenticator.init(this.socket, (ProtonConnection) this.connection.getContext(), transport);
 }
 this.authenticator = authenticator;
 transport.bind(connection);
 connection.collect(collector);
 socket.endHandler(this::handleSocketEnd);
 socket.handler(this::handleSocketBuffer);
}

代码示例来源：origin: com.ibm.mqlight/mqlight-api

ProtocolTracer protocolTracer = new EngineProtocolTracer(or.clientId);
((TransportImpl) transport).setProtocolTracer(protocolTracer);
transport.setIdleTimeout(or.endpoint.getIdleTimeout());
transport.bind(protonConnection);
Collector collector = Proton.collector();