public class SslTransport extends TcpTransport
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, 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() |
String |
toString() |
closeStreams, connect, doRun, doStart, doStop, getConnectionTimeout, getDiffServ, getIoBufferSize, getJmxPort, getKeepAlive, getLogWriterName, getMinmumWireFormatVersion, getReceiveCounter, getRemoteAddress, getSocketBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTypeOfService, getWireFormat, initialiseSocket, 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.public void doConsume(Object command)
doConsume
in class TransportSupport
command
- The Command coming in.public X509Certificate[] getPeerCertificates()
public String toString()
toString
in class TcpTransport
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.