org.apache.nifi.remote.io.socket.ssl

Class SSLSocketChannelCommunicationsSession

java.lang.Object

org.apache.nifi.remote.AbstractCommunicationsSession

org.apache.nifi.remote.io.socket.ssl.SSLSocketChannelCommunicationsSession

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, CommunicationsSession

public class SSLSocketChannelCommunicationsSession
extends AbstractCommunicationsSession

Field Summary

Fields inherited from interface org.apache.nifi.remote.protocol.CommunicationsSession

MAGIC_BYTES

Constructor Summary

Constructors

Constructor and Description
SSLSocketChannelCommunicationsSession(SSLSocketChannel channel)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getBytesRead()
long	getBytesWritten()
SSLSocketChannelInput	getInput()
SSLSocketChannelOutput	getOutput()
int	getTimeout()
void	interrupt() Asynchronously interrupts this FlowFileCodec.
boolean	isClosed()
boolean	isDataAvailable()
void	setTimeout(int millis)
java.lang.String	toString()

Methods inherited from class org.apache.nifi.remote.AbstractCommunicationsSession

createTransitUri, getUserDn, setUserDn

Methods inherited from class java.lang.Object

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

Constructor Detail

SSLSocketChannelCommunicationsSession

public SSLSocketChannelCommunicationsSession(SSLSocketChannel channel)

Method Detail

getInput

public SSLSocketChannelInput getInput()

getOutput

public SSLSocketChannelOutput getOutput()

setTimeout

public void setTimeout(int millis)
                throws java.io.IOException

Throws:

java.io.IOException

getTimeout

public int getTimeout()
               throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

isClosed

public boolean isClosed()

Returns:

true if the connection is closed, false otherwise

isDataAvailable

public boolean isDataAvailable()

getBytesWritten

public long getBytesWritten()

getBytesRead

public long getBytesRead()

interrupt

public void interrupt()

Description copied from interface: CommunicationsSession

Asynchronously interrupts this FlowFileCodec. Implementations must ensure that they stop sending and receiving data as soon as possible after this method has been called, even if doing so results in sending only partial data to the peer. This will usually result in the peer throwing a SocketTimeoutException.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object