Package org.springframework.integration.sftp.session

Class DefaultSftpSessionFactory.ConcurrentSftpClient

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.client.subsystem.AbstractSubsystemClient

org.apache.sshd.sftp.client.impl.AbstractSftpClient

org.apache.sshd.sftp.client.impl.DefaultSftpClient

org.springframework.integration.sftp.session.DefaultSftpSessionFactory.ConcurrentSftpClient

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, org.apache.sshd.client.channel.ClientChannelHolder, org.apache.sshd.client.session.ClientSessionHolder, org.apache.sshd.client.subsystem.SubsystemClient, org.apache.sshd.common.channel.ChannelHolder, org.apache.sshd.common.NamedResource, org.apache.sshd.common.session.SessionContextHolder, org.apache.sshd.common.session.SessionHolder<org.apache.sshd.client.session.ClientSession>, org.apache.sshd.sftp.client.FullAccessSftpClient, org.apache.sshd.sftp.client.RawSftpClient, org.apache.sshd.sftp.client.SftpClient, org.apache.sshd.sftp.client.SftpErrorDataHandler

Enclosing class:

DefaultSftpSessionFactory

protected static class DefaultSftpSessionFactory.ConcurrentSftpClient
extends org.apache.sshd.sftp.client.impl.DefaultSftpClient

The DefaultSftpClient extension to lock the send(int, Buffer) for concurrent interaction.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.sshd.sftp.client.impl.DefaultSftpClient

org.apache.sshd.sftp.client.impl.DefaultSftpClient.SftpChannelSubsystem

Nested classes/interfaces inherited from interface org.apache.sshd.sftp.client.SftpClient

org.apache.sshd.sftp.client.SftpClient.Attribute, org.apache.sshd.sftp.client.SftpClient.Attributes, org.apache.sshd.sftp.client.SftpClient.CloseableHandle, org.apache.sshd.sftp.client.SftpClient.CopyMode, org.apache.sshd.sftp.client.SftpClient.DirEntry, org.apache.sshd.sftp.client.SftpClient.Handle, org.apache.sshd.sftp.client.SftpClient.OpenMode

Field Summary

Fields inherited from class org.apache.sshd.sftp.client.impl.AbstractSftpClient

errorDataHandler, INIT_COMMAND_SIZE

Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

log

Fields inherited from interface org.apache.sshd.common.NamedResource

BY_NAME_COMPARATOR, NAME_EXTRACTOR

Fields inherited from interface org.apache.sshd.sftp.client.SftpClient

DEFAULT_CHANNEL_MODES, EMPTY_DIR_ENTRIES, IO_BUFFER_SIZE, MIN_BUFFER_SIZE, MIN_READ_BUFFER_SIZE, MIN_WRITE_BUFFER_SIZE

Fields inherited from interface org.apache.sshd.sftp.client.SftpErrorDataHandler

EMPTY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ConcurrentSftpClient(org.apache.sshd.client.session.ClientSession clientSession, org.apache.sshd.sftp.client.SftpVersionSelector initialVersionSelector, org.apache.sshd.sftp.client.SftpErrorDataHandler errorDataHandler)

Method Summary

Modifier and Type	Method	Description
int	send(int cmd, org.apache.sshd.common.util.buffer.Buffer buffer)

Methods inherited from class org.apache.sshd.sftp.client.impl.DefaultSftpClient

close, createSftpChannelSubsystem, data, getClientChannel, getClientSession, getNameDecodingCharset, getServerExtensions, getVersion, handleInitResponse, init, isClosing, isOpen, negotiateVersion, process, receive, receive, receive, receive, setNameDecodingCharset, waitForInitResponse

Methods inherited from class org.apache.sshd.sftp.client.impl.AbstractSftpClient

canonicalPath, checkAttributes, checkAttributesResponse, checkCommandStatus, checkData, checkDataResponse, checkDirResponse, checkHandle, checkHandleResponse, checkOneName, checkOneNameResponse, checkResponseStatus, checkResponseStatus, close, errorData, getChannel, getExtension, getExtension, getParsedServerExtensions, getParsedServerExtensions, getReadBufferSize, getReferencedName, getWriteBufferSize, handleUnexpectedAttributesPacket, handleUnexpectedHandlePacket, handleUnexpectedPacket, handleUnknownDataPacket, handleUnknownDirListingPacket, handleUnknownOneNamePacket, link, listDir, lock, lstat, mkdir, open, openDir, openRemoteFileChannel, putReferencedName, read, read, readAttributes, readDir, readDir, readLink, remove, rename, rmdir, setStat, setStat, stat, stat, throwStatusException, unlock, validateIncomingResponse, write, write, writeAttributes

Methods inherited from class org.apache.sshd.client.subsystem.AbstractSubsystemClient

toString

Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.sshd.common.session.SessionHolder

getSessionContext

Methods inherited from interface org.apache.sshd.sftp.client.SftpClient

getExtension, getName, open, open, openRemoteFileChannel, openRemotePathChannel, openRemotePathChannel, read, read, read, read, read, read, read, read, readDir, readEntries, rename, rename, singleSessionInstance, symLink, write, write, write, write, write, write

Methods inherited from interface org.apache.sshd.client.subsystem.SubsystemClient

getSession

Constructor Details

ConcurrentSftpClient

protected ConcurrentSftpClient(org.apache.sshd.client.session.ClientSession clientSession,
 org.apache.sshd.sftp.client.SftpVersionSelector initialVersionSelector,
 org.apache.sshd.sftp.client.SftpErrorDataHandler errorDataHandler)
                        throws IOException

Throws:

IOException

Method Details

send

public int send(int cmd,
 org.apache.sshd.common.util.buffer.Buffer buffer)
         throws IOException

Specified by:

send in interface org.apache.sshd.sftp.client.RawSftpClient

Overrides:

send in class org.apache.sshd.sftp.client.impl.DefaultSftpClient

Throws:

IOException