public class SslTransport extends TcpTransport
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, socketOptions, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
SslTransport(WireFormat wireFormat,
SSLSocket socket)
Initialize from a ServerSocket.
|
SslTransport(WireFormat wireFormat,
SSLSocketFactory socketFactory,
URI remoteLocation,
URI localLocation,
boolean needClientAuth)
Connect to a remote node such as a Broker.
|
Modifier and Type | Method and Description |
---|---|
void |
doConsume(Object command)
Overriding in order to add the client's certificates to ConnectionInfo
Commmands.
|
X509Certificate[] |
getPeerCertificates() |
protected void |
initialiseSocket(Socket sock)
Configures the socket for use
|
void |
setVerifyHostName(Boolean verifyHostName) |
String |
toString() |
closeStreams, connect, doRun, doStart, doStop, getConnectionTimeout, getDiffServ, getIoBufferSize, getJmxPort, getKeepAlive, getLogWriterName, getMinmumWireFormatVersion, getReceiveCounter, getRemoteAddress, getSocketBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTypeOfService, getWireFormat, initializeStreams, isCloseAsync, isDynamicManagement, isStartLogging, isTrace, isUseLocalHost, narrow, oneway, readCommand, resolveHostName, run, setCloseAsync, setConnectionTimeout, setDiffServ, setDynamicManagement, setIoBufferSize, setJmxPort, setKeepAlive, setLogWriterName, setMinmumWireFormatVersion, setSocketBufferSize, setSocketOptions, setSoLinger, setSoTimeout, setStartLogging, setTcpNoDelay, setTrace, setTypeOfService, setUseLocalHost, stop
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
public SslTransport(WireFormat wireFormat, SSLSocketFactory socketFactory, URI remoteLocation, URI localLocation, boolean needClientAuth) throws IOException
wireFormat
- The WireFormat to be used.socketFactory
- The socket factory to be used. Forcing SSLSockets
for obvious reasons.remoteLocation
- The remote location.localLocation
- The local location.needClientAuth
- If set to true, the underlying socket will need
client certificate authentication.UnknownHostException
- If TcpTransport throws.IOException
- If TcpTransport throws.public SslTransport(WireFormat wireFormat, SSLSocket socket) throws IOException
wireFormat
- The WireFormat to be used.socket
- The Socket to be used. Forcing SSL.IOException
- If TcpTransport throws.protected void initialiseSocket(Socket sock) throws SocketException, IllegalArgumentException
TcpTransport
initialiseSocket
in class TcpTransport
sock
- the socketSocketException
IllegalArgumentException
public void doConsume(Object command)
doConsume
in class TransportSupport
command
- The Command coming in.public void setVerifyHostName(Boolean verifyHostName)
public X509Certificate[] getPeerCertificates()
public String toString()
toString
in class TcpTransport
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.