public class AutoNIOSSLTransportServer extends AutoTcpTransportServer
AutoTcpTransportServer.ProtocolInfo
TcpTransportServer.TransportInfo
autoTransportOptions, brokerService, enabledProtocols, maxConnectionThreadPoolSize, newConnectionExecutor, protocolDetectionExecutor, protocolDetectionTimeOut, protocolVerifiers, wireFormatOptions
allowLinkStealing, backlog, connectionTimeout, currentTransportCount, dynamicManagement, logWriterName, maximumConnections, maxInactivityDuration, maxInactivityDurationInitalDelay, minmumWireFormatVersion, selector, serverSocket, serverSocketFactory, socketBufferSize, socketHandlerThread, socketQueue, soTimeout, startLogging, trace, transportFactory, useQueueForAccept, wireFormatFactory
transportOptions
Constructor and Description |
---|
AutoNIOSSLTransportServer(SSLContext context,
TcpTransportFactory transportFactory,
URI location,
ServerSocketFactory serverSocketFactory,
BrokerService brokerService,
Set<String> enabledProtocols) |
Modifier and Type | Method and Description |
---|---|
protected TcpTransportServer.TransportInfo |
configureTransport(TcpTransportServer server,
Socket socket) |
protected TcpTransport |
createTransport(Socket socket,
WireFormat format)
Allow derived classes to override the Transport implementation that this transport server creates.
|
protected Transport |
createTransport(Socket socket,
WireFormat format,
SSLEngine engine,
TcpTransport.InitBuffer initBuffer,
ByteBuffer inputBuffer,
TcpTransportFactory detectedFactory) |
boolean |
isNeedClientAuth() |
boolean |
isSslServer()
For TransportServers that provide SSL connections to their connected peers they should
return true here if and only if they populate the ConnectionInfo command presented to
the Broker with the peers certificate chain so that the broker knows it can use that
information to authenticate the connected peer.
|
boolean |
isWantClientAuth() |
void |
setNeedClientAuth(boolean value) |
void |
setWantClientAuth(boolean value) |
append, createTransport, detectProtocol, doStop, findTransportFactory, findWireFormatFactory, getMaxConnectionThreadPoolSize, handleSocket, initOpenWireProtocolVerifier, initProtocolVerifiers, isAllProtocols, setAutoTransportOptions, setEnabledProtocols, setMaxConnectionThreadPoolSize, setProtocolDetectionTimeOut, setWireFormatFactory, setWireFormatOptions, waitForProtocolDetectionFinish
bind, doHandleSocket, doStart, getBacklog, getConnectionTimeout, getCurrentTransportCount, getLogWriterName, getMaximumConnections, getMaxInactivityDuration, getMaxInactivityDurationInitalDelay, getMinmumWireFormatVersion, getSocketAddress, getSocketBufferSize, getSoTimeout, getWireFormatFactory, isAllowLinkStealing, isDynamicManagement, isStartLogging, isTrace, isUseQueueForAccept, resolveHostName, run, setAllowLinkStealing, setBacklog, setBrokerInfo, setConnectionTimeout, setDynamicManagement, setLogWriterName, setMaximumConnections, setMaxInactivityDuration, setMaxInactivityDurationInitalDelay, setMinmumWireFormatVersion, setSocketBufferSize, setSoTimeout, setStartLogging, setTrace, setUseQueueForAccept, started, stopped, toString
getStackSize, isDaemon, isJoinOnStop, setDaemon, setJoinOnStop, setStackSize
getAcceptListener, getBindLocation, getConnectURI, onAcceptError, setAcceptListener, setBindLocation, setConnectURI, setTransportOption
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
public AutoNIOSSLTransportServer(SSLContext context, TcpTransportFactory transportFactory, URI location, ServerSocketFactory serverSocketFactory, BrokerService brokerService, Set<String> enabledProtocols) throws IOException, URISyntaxException
IOException
URISyntaxException
protected Transport createTransport(Socket socket, WireFormat format, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer, TcpTransportFactory detectedFactory) throws IOException
IOException
protected TcpTransport createTransport(Socket socket, WireFormat format) throws IOException
TcpTransportServer
createTransport
in class TcpTransportServer
IOException
public boolean isSslServer()
TransportServer
isSslServer
in interface TransportServer
isSslServer
in class TcpTransportServer
public boolean isNeedClientAuth()
public void setNeedClientAuth(boolean value)
public boolean isWantClientAuth()
public void setWantClientAuth(boolean value)
protected TcpTransportServer.TransportInfo configureTransport(TcpTransportServer server, Socket socket) throws Exception
configureTransport
in class AutoTcpTransportServer
Exception
Copyright © 2005–2017. All rights reserved.