org.fusesource.hawtdispatch.transport

Class SslTransport

java.lang.Object

org.fusesource.hawtdispatch.transport.ServiceBase

org.fusesource.hawtdispatch.transport.TcpTransport

org.fusesource.hawtdispatch.transport.SslTransport

All Implemented Interfaces:

SecuredSession, Transport

public class SslTransport
extends TcpTransport
implements SecuredSession

An SSL Transport for secure communications.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	SslTransport.ClientAuth
class	SslTransport.SSLChannel

Nested classes/interfaces inherited from class org.fusesource.hawtdispatch.transport.TcpTransport

TcpTransport.CANCELED, TcpTransport.CANCELING, TcpTransport.CONNECTED, TcpTransport.CONNECTING, TcpTransport.DISCONNECTED, TcpTransport.OneWay, TcpTransport.RateLimitingChannel, TcpTransport.SocketState

Nested classes/interfaces inherited from class org.fusesource.hawtdispatch.transport.ServiceBase

ServiceBase.CallbackSupport, ServiceBase.STARTING, ServiceBase.State, ServiceBase.STOPPING

Field Summary

Fields

Modifier and Type	Field and Description
private SslTransport.ClientAuth	clientAuth
private java.lang.String	disabledCypherSuites
private java.lang.String	enabledCipherSuites
private javax.net.ssl.SSLEngine	engine
private java.nio.ByteBuffer	readBuffer
private java.nio.ByteBuffer	readOverflowBuffer
private boolean	readUnderflow
private SslTransport.SSLChannel	ssl_channel
private javax.net.ssl.SSLContext	sslContext
private java.nio.ByteBuffer	writeBuffer
private boolean	writeFlushing

Fields inherited from class org.fusesource.hawtdispatch.transport.TcpTransport

blockingExecutor, channel, closeOnCancel, codec, dispatchQueue, drainOutboundSource, IPTOS_LOWCOST, IPTOS_LOWDELAY, IPTOS_RELIABILITY, IPTOS_THROUGHPUT, keepAlive, listener, localAddress, localhost, localLocation, maxReadRate, maxWriteRate, rateLimitingChannel, receiveBufferSize, rejectingOffers, remoteAddress, remoteLocation, sendBufferSize, socketState, trafficClass, useLocalHost, writeResumedForCodecFlush, yieldSource

Fields inherited from class org.fusesource.hawtdispatch.transport.ServiceBase

_serviceState, CREATED, STARTED, STOPPED

Constructor Summary

Constructors

Constructor and Description
SslTransport()

Method Summary

Modifier and Type	Method and Description
void	connected(java.nio.channels.SocketChannel channel)
void	connecting(java.net.URI remoteLocation, java.net.URI localLocation)
static SslTransport	createTransport(java.net.URI uri) Allows subclasses of TcpTransportFactory to create custom instances of TcpTransport.
void	drainInbound()
void	flush() Forces a flush of any output buffers.
java.lang.String	getClientAuth()
java.lang.String	getDisabledCypherSuites()
java.lang.String	getEnabledCypherSuites()
java.security.cert.X509Certificate[]	getPeerX509Certificates() Gets the X509Certificate associated withe the peer.
java.nio.channels.ReadableByteChannel	getReadChannel()
javax.net.ssl.SSLSession	getSSLSession()
java.nio.channels.WritableByteChannel	getWriteChannel()
void	handshake()
protected void	initializeChannel()
protected void	onConnected()
static java.lang.String	protocol(java.lang.String scheme) Maps uri schemes to a protocol algorithm names.
private int	secure_read(java.nio.ByteBuffer plain)
private int	secure_write(java.nio.ByteBuffer plain)
void	setClientAuth(java.lang.String clientAuth)
void	setDisabledCypherSuites(java.lang.String disabledCypherSuites)
void	setEnabledCypherSuites(java.lang.String enabledCypherSuites)
void	setSSLContext(javax.net.ssl.SSLContext ctx)
private java.lang.String[]	splitOnCommas(java.lang.String value)
protected boolean	transportFlush()

Methods inherited from class org.fusesource.hawtdispatch.transport.TcpTransport

_start, _stop, full, getBlockingExecutor, getDispatchQueue, getLocalAddress, getLocalHost, getMaxReadRate, getMaxWriteRate, getProtocolCodec, getReceiveBufferSize, getRemoteAddress, getSendBufferSize, getSocketChannel, getTrafficClass, getTransportListener, initializeCodec, isClosed, isCloseOnCancel, isConnected, isKeepAlive, isUseLocalHost, offer, onTransportFailure, resolveHostName, resumeRead, resumeWrite, setBlockingExecutor, setCloseOnCancel, setDispatchQueue, setKeepAlive, setMaxReadRate, setMaxWriteRate, setProtocolCodec, setReceiveBufferSize, setSendBufferSize, setTrafficClass, setTransportListener, setUseLocalHost, suspendRead, suspendWrite

Methods inherited from class org.fusesource.hawtdispatch.transport.ServiceBase

getServiceState, start, start, stop, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.fusesource.hawtdispatch.transport.Transport

start, start, stop, stop

Field Detail

clientAuth

private SslTransport.ClientAuth clientAuth

disabledCypherSuites

private java.lang.String disabledCypherSuites

enabledCipherSuites

private java.lang.String enabledCipherSuites

sslContext

private javax.net.ssl.SSLContext sslContext

engine

private javax.net.ssl.SSLEngine engine

readBuffer

private java.nio.ByteBuffer readBuffer

readUnderflow

private boolean readUnderflow

writeBuffer

private java.nio.ByteBuffer writeBuffer

writeFlushing

private boolean writeFlushing

readOverflowBuffer

private java.nio.ByteBuffer readOverflowBuffer

ssl_channel

private SslTransport.SSLChannel ssl_channel

Constructor Detail

SslTransport

public SslTransport()

Method Detail

protocol

public static java.lang.String protocol(java.lang.String scheme)

Maps uri schemes to a protocol algorithm names. Valid algorithm names listed at: http://download.oracle.com/javase/6/docs/technotes/guides/security/StandardNames.html#SSLContext

setSSLContext

public void setSSLContext(javax.net.ssl.SSLContext ctx)

createTransport

public static SslTransport createTransport(java.net.URI uri)
                                    throws java.lang.Exception

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransport.

Throws:

java.lang.Exception

getSSLSession

public javax.net.ssl.SSLSession getSSLSession()

getPeerX509Certificates

public java.security.cert.X509Certificate[] getPeerX509Certificates()

Description copied from interface: SecuredSession

Gets the X509Certificate associated withe the peer.

Specified by:

getPeerX509Certificates in interface SecuredSession

Returns:

connecting

public void connecting(java.net.URI remoteLocation,
                       java.net.URI localLocation)
                throws java.lang.Exception

Overrides:

connecting in class TcpTransport

Throws:

java.lang.Exception

connected

public void connected(java.nio.channels.SocketChannel channel)
               throws java.lang.Exception

Overrides:

connected in class TcpTransport

Throws:

java.lang.Exception

splitOnCommas

private java.lang.String[] splitOnCommas(java.lang.String value)

initializeChannel

protected void initializeChannel()
                          throws java.lang.Exception

Overrides:

initializeChannel in class TcpTransport

Throws:

java.lang.Exception

onConnected

protected void onConnected()
                    throws java.io.IOException

Overrides:

onConnected in class TcpTransport

Throws:

java.io.IOException

flush

public void flush()

Description copied from interface: Transport

Forces a flush of any output buffers. Once the flush completes the listener's 'onRefill()' method will execute.

Specified by:

flush in interface Transport

Overrides:

flush in class TcpTransport

drainInbound

public void drainInbound()

Specified by:

drainInbound in interface Transport

Overrides:

drainInbound in class TcpTransport

transportFlush

protected boolean transportFlush()
                          throws java.io.IOException

Overrides:

transportFlush in class TcpTransport

Returns:

true if fully flushed.

Throws:

java.io.IOException

secure_write

private int secure_write(java.nio.ByteBuffer plain)
                  throws java.io.IOException

Throws:

java.io.IOException

secure_read

private int secure_read(java.nio.ByteBuffer plain)
                 throws java.io.IOException

Throws:

java.io.IOException

handshake

public void handshake()

getReadChannel

public java.nio.channels.ReadableByteChannel getReadChannel()

Specified by:

getReadChannel in interface Transport

Overrides:

getReadChannel in class TcpTransport

getWriteChannel

public java.nio.channels.WritableByteChannel getWriteChannel()

Specified by:

getWriteChannel in interface Transport

Overrides:

getWriteChannel in class TcpTransport

getClientAuth

public java.lang.String getClientAuth()

setClientAuth

public void setClientAuth(java.lang.String clientAuth)

getDisabledCypherSuites

public java.lang.String getDisabledCypherSuites()

getEnabledCypherSuites

public java.lang.String getEnabledCypherSuites()

setDisabledCypherSuites

public void setDisabledCypherSuites(java.lang.String disabledCypherSuites)

setEnabledCypherSuites

public void setEnabledCypherSuites(java.lang.String enabledCypherSuites)