public class AutoSslTransportServer 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 |
---|
AutoSslTransportServer(SslTransportFactory transportFactory,
URI location,
SSLServerSocketFactory serverSocketFactory,
BrokerService brokerService,
Set<String> enabledProtocols) |
Modifier and Type | Method and Description |
---|---|
void |
bind()
Binds this socket to the previously specified URI.
|
protected TcpTransport |
createTransport(Socket socket,
WireFormat format,
TcpTransportFactory detectedTransportFactory,
TcpTransport.InitBuffer initBuffer)
Used to create Transports for this server.
|
boolean |
getNeedClientAuth()
Returns whether client authentication should be required.
|
boolean |
getWantClientAuth()
Returns whether client authentication should be requested.
|
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.
|
void |
setNeedClientAuth(boolean needAuth)
Sets whether client authentication should be required
Must be called before
bind()
Note: Calling this method clears the wantClientAuth flag
in the underlying implementation. |
void |
setWantClientAuth(boolean wantAuth)
Sets whether client authentication should be requested.
|
append, configureTransport, detectProtocol, doStop, findTransportFactory, findWireFormatFactory, getMaxConnectionThreadPoolSize, handleSocket, initOpenWireProtocolVerifier, initProtocolVerifiers, isAllProtocols, setAutoTransportOptions, setEnabledProtocols, setMaxConnectionThreadPoolSize, setProtocolDetectionTimeOut, setWireFormatFactory, setWireFormatOptions, waitForProtocolDetectionFinish
createTransport, 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 AutoSslTransportServer(SslTransportFactory transportFactory, URI location, SSLServerSocketFactory serverSocketFactory, BrokerService brokerService, Set<String> enabledProtocols) throws IOException, URISyntaxException
IOException
URISyntaxException
public void setNeedClientAuth(boolean needAuth)
bind()
Note: Calling this method clears the wantClientAuth flag
in the underlying implementation.public boolean getNeedClientAuth()
public boolean getWantClientAuth()
public void setWantClientAuth(boolean wantAuth)
bind()
Note: Calling this method clears the needClientAuth flag
in the underlying implementation.public void bind() throws IOException
bind
in class TcpTransportServer
IOException
- passed up from TcpTransportServer.protected TcpTransport createTransport(Socket socket, WireFormat format, TcpTransportFactory detectedTransportFactory, TcpTransport.InitBuffer initBuffer) throws IOException
createTransport
in class AutoTcpTransportServer
socket
- The incoming socket that will be wrapped into the new Transport.format
- The WireFormat being used.IOException
public boolean isSslServer()
TransportServer
isSslServer
in interface TransportServer
isSslServer
in class TcpTransportServer
Copyright © 2005–2020 The Apache Software Foundation. All rights reserved.