public class TcpNioClientConnectionFactory extends AbstractClientConnectionFactory implements SchedulingAwareRunnable
TcpNioConnection を作成するクライアント接続ファクトリ。DEFAULT_REPLY_TIMEOUT, lifecycleMonitorEXPRESSION_PARSER, logger| コンストラクターと説明 |
|---|
TcpNioClientConnectionFactory(StringSE host, int port) ホストとポートへの接続用の TcpNioClientConnectionFactory を作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected TcpConnectionSupport | buildNewConnection() |
protected void | checkActive() |
protected MapSE<SocketChannelSE, TcpNioConnection> | getConnections() |
protected BlockingQueueSE<SocketChannelSE> | getNewChannels() |
boolean | isLongLived() |
protected boolean | isUsingDirectBuffers() |
void | run() |
void | setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport) |
void | setUsingDirectBuffers(boolean usingDirectBuffers)true に設定すると、このファクトリによって作成された接続は、可能な場合は直接バッファーを使用しようとします。 |
void | start() |
void | stop() サーバーの停止。 |
enableManualListenerRegistration, forceClose, getConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnectionaddConnection, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getLifecycleMonitor, getListener, getMapper, getOpenConnectionIds, getPort, getReadDelay, getSender, getSenders, getSerializer, getSoLinger, getSoReceiveBufferSize, getSoSendBufferSize, getSoTimeout, getSoTrafficClass, getSslHandshakeTimeout, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, isLookupHost, isRunning, isSingleUse, isSoKeepAlive, isSoTcpNoDelay, onInit, processNioSelections, registerListener, registerSender, setActive, setApplicationEventPublisher, setDeserializer, setHost, setInterceptorFactoryChain, setLeaveOpen, setLookupHost, setMapper, setNioHarvestInterval, setPort, setReadDelay, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setSslHandshakeTimeout, setTaskExecutor, setTcpSocketSupport, toString, unregisterSender, wrapConnectionafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskSchedulercloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEpublic TcpNioClientConnectionFactory(StringSE host, int port)
host - ザホスト port - 港 protected void checkActive()
AbstractConnectionFactory の checkActive protected TcpConnectionSupport buildNewConnection()
AbstractClientConnectionFactory の buildNewConnection public void setUsingDirectBuffers(boolean usingDirectBuffers)
usingDirectBuffers - 設定する usingDirectBuffers。ByteBufferSEpublic void setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)
public boolean isLongLived()
SchedulingAwareRunnable の isLongLived public void stop()
AbstractConnectionFactoryLifecycle の stop ManageableLifecycle の stop AbstractConnectionFactory の stop public void start()
Lifecycle の start ManageableLifecycle の start AbstractConnectionFactory の start public void run()
RunnableSE の runSE protected boolean isUsingDirectBuffers()
protected MapSE<SocketChannelSE,TcpNioConnection> getConnections()
protected BlockingQueueSE<SocketChannelSE> getNewChannels()