public class SslTransportServer extends TcpTransportServer
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 |
---|
SslTransportServer(SslTransportFactory transportFactory,
URI location,
SSLServerSocketFactory serverSocketFactory)
Creates a ssl transport server for the specified url using the provided
serverSocketFactory
|
Modifier and Type | Method and Description |
---|---|
void |
bind()
Binds this socket to the previously specified URI.
|
protected Transport |
createTransport(Socket socket,
WireFormat format)
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.
|
doStart, doStop, getBacklog, getConnectionTimeout, getLogWriterName, getMaximumConnections, getMaxInactivityDuration, getMaxInactivityDurationInitalDelay, getMinmumWireFormatVersion, getSocketAddress, getSocketBufferSize, getSoTimeout, getWireFormatFactory, handleSocket, isAllowLinkStealing, isDynamicManagement, isStartLogging, isTrace, isUseQueueForAccept, resolveHostName, run, setAllowLinkStealing, setBacklog, setBrokerInfo, setConnectionTimeout, setDynamicManagement, setLogWriterName, setMaximumConnections, setMaxInactivityDuration, setMaxInactivityDurationInitalDelay, setMinmumWireFormatVersion, setSocketBufferSize, setSoTimeout, setStartLogging, setTrace, setUseQueueForAccept, setWireFormatFactory, 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 SslTransportServer(SslTransportFactory transportFactory, URI location, SSLServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException
transportFactory
- The factory used to create transports when connections arrive.location
- The location of the broker to bind to.serverSocketFactory
- The factory used to create this server.IOException
- passed up from TcpTransportFactory.URISyntaxException
- passed up from TcpTransportFactory.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 Transport createTransport(Socket socket, WireFormat format) throws IOException
createTransport
in class TcpTransportServer
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–2016 FuseSource, Corp.. All rights reserved.