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 class DefaultSftpSessionFactory.ConcurrentSftpClient extends org.apache.sshd.sftp.client.impl.DefaultSftpClient
The DefaultSftpClient extension to lock the send(int, Buffer) for concurrent interaction.

Also sets the provided DefaultSftpSessionFactory.timeout as a AbstractSftpClient.SFTP_CLIENT_CMD_TIMEOUT property.

  • 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, SFTP_CLIENT_CMD_TIMEOUT

    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
    protected org.apache.sshd.client.channel.ChannelSubsystem
    createSftpChannelSubsystem(org.apache.sshd.client.session.ClientSession clientSession)
     
    int
    send(int cmd, org.apache.sshd.common.util.buffer.Buffer buffer)
     

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

    close, 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, response, rmdir, rpc, setStat, setStat, stat, stat, throwStatusException, unlock, 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

    • createSftpChannelSubsystem

      protected org.apache.sshd.client.channel.ChannelSubsystem createSftpChannelSubsystem(org.apache.sshd.client.session.ClientSession clientSession)
      Overrides:
      createSftpChannelSubsystem in class org.apache.sshd.sftp.client.impl.DefaultSftpClient