Interface FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder

  • All Superinterfaces:
    org.apache.camel.builder.EndpointConsumerBuilder, org.apache.camel.EndpointConsumerResolver
    All Known Subinterfaces:
    FileEndpointBuilderFactory.AdvancedFileEndpointBuilder
    Enclosing interface:
    FileEndpointBuilderFactory

    public static interface FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder
    extends org.apache.camel.builder.EndpointConsumerBuilder
    Advanced builder for endpoint consumers for the File component.
    • Method Detail

      • directoryMustExist

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder directoryMustExist​(boolean directoryMustExist)
        Similar to the startingDirectoryMustExist option but this applies during polling (after starting the consumer). The option is a: boolean type. Default: false Group: consumer (advanced)
      • directoryMustExist

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder directoryMustExist​(String directoryMustExist)
        Similar to the startingDirectoryMustExist option but this applies during polling (after starting the consumer). The option will be converted to a boolean type. Default: false Group: consumer (advanced)
      • exceptionHandler

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder exceptionHandler​(org.apache.camel.spi.ExceptionHandler exceptionHandler)
        To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option is a: org.apache.camel.spi.ExceptionHandler type. Group: consumer (advanced)
      • exceptionHandler

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder exceptionHandler​(String exceptionHandler)
        To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. The option will be converted to a org.apache.camel.spi.ExceptionHandler type. Group: consumer (advanced)
      • extendedAttributes

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder extendedAttributes​(String extendedAttributes)
        To define which file attributes of interest. Like posix:permissions,posix:owner,basic:lastAccessTime, it supports basic wildcard like posix:, basic:lastAccessTime. The option is a: java.lang.String type. Group: consumer (advanced)
      • inProgressRepository

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder inProgressRepository​(org.apache.camel.spi.IdempotentRepository inProgressRepository)
        A pluggable in-progress repository org.apache.camel.spi.IdempotentRepository. The in-progress repository is used to account the current in progress files being consumed. By default a memory based repository is used. The option is a: org.apache.camel.spi.IdempotentRepository type. Group: consumer (advanced)
      • inProgressRepository

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder inProgressRepository​(String inProgressRepository)
        A pluggable in-progress repository org.apache.camel.spi.IdempotentRepository. The in-progress repository is used to account the current in progress files being consumed. By default a memory based repository is used. The option will be converted to a org.apache.camel.spi.IdempotentRepository type. Group: consumer (advanced)
      • localWorkDirectory

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder localWorkDirectory​(String localWorkDirectory)
        When consuming, a local work directory can be used to store the remote file content directly in local files, to avoid loading the content into memory. This is beneficial, if you consume a very big remote file and thus can conserve memory. The option is a: java.lang.String type. Group: consumer (advanced)
      • onCompletionExceptionHandler

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder onCompletionExceptionHandler​(org.apache.camel.spi.ExceptionHandler onCompletionExceptionHandler)
        To use a custom org.apache.camel.spi.ExceptionHandler to handle any thrown exceptions that happens during the file on completion process where the consumer does either a commit or rollback. The default implementation will log any exception at WARN level and ignore. The option is a: org.apache.camel.spi.ExceptionHandler type. Group: consumer (advanced)
      • onCompletionExceptionHandler

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder onCompletionExceptionHandler​(String onCompletionExceptionHandler)
        To use a custom org.apache.camel.spi.ExceptionHandler to handle any thrown exceptions that happens during the file on completion process where the consumer does either a commit or rollback. The default implementation will log any exception at WARN level and ignore. The option will be converted to a org.apache.camel.spi.ExceptionHandler type. Group: consumer (advanced)
      • pollStrategy

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder pollStrategy​(org.apache.camel.spi.PollingConsumerPollStrategy pollStrategy)
        A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel. The option is a: org.apache.camel.spi.PollingConsumerPollStrategy type. Group: consumer (advanced)
      • pollStrategy

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder pollStrategy​(String pollStrategy)
        A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your custom implementation to control error handling usually occurred during the poll operation before an Exchange have been created and being routed in Camel. The option will be converted to a org.apache.camel.spi.PollingConsumerPollStrategy type. Group: consumer (advanced)
      • probeContentType

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder probeContentType​(boolean probeContentType)
        Whether to enable probing of the content type. If enable then the consumer uses Files#probeContentType(java.nio.file.Path) to determine the content-type of the file, and store that as a header with key Exchange#FILE_CONTENT_TYPE on the Message. The option is a: boolean type. Default: false Group: consumer (advanced)
      • probeContentType

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder probeContentType​(String probeContentType)
        Whether to enable probing of the content type. If enable then the consumer uses Files#probeContentType(java.nio.file.Path) to determine the content-type of the file, and store that as a header with key Exchange#FILE_CONTENT_TYPE on the Message. The option will be converted to a boolean type. Default: false Group: consumer (advanced)
      • processStrategy

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder processStrategy​(Object processStrategy)
        A pluggable org.apache.camel.component.file.GenericFileProcessStrategy allowing you to implement your own readLock option or similar. Can also be used when special conditions must be met before a file can be consumed, such as a special ready file exists. If this option is set then the readLock option does not apply. The option is a: org.apache.camel.component.file.GenericFileProcessStrategy<java.io.File> type. Group: consumer (advanced)
      • processStrategy

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder processStrategy​(String processStrategy)
        A pluggable org.apache.camel.component.file.GenericFileProcessStrategy allowing you to implement your own readLock option or similar. Can also be used when special conditions must be met before a file can be consumed, such as a special ready file exists. If this option is set then the readLock option does not apply. The option will be converted to a org.apache.camel.component.file.GenericFileProcessStrategy<java.io.File> type. Group: consumer (advanced)
      • startingDirectoryMustExist

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder startingDirectoryMustExist​(boolean startingDirectoryMustExist)
        Whether the starting directory must exist. Mind that the autoCreate option is default enabled, which means the starting directory is normally auto created if it doesn't exist. You can disable autoCreate and enable this to ensure the starting directory must exist. Will thrown an exception if the directory doesn't exist. The option is a: boolean type. Default: false Group: consumer (advanced)
      • startingDirectoryMustExist

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder startingDirectoryMustExist​(String startingDirectoryMustExist)
        Whether the starting directory must exist. Mind that the autoCreate option is default enabled, which means the starting directory is normally auto created if it doesn't exist. You can disable autoCreate and enable this to ensure the starting directory must exist. Will thrown an exception if the directory doesn't exist. The option will be converted to a boolean type. Default: false Group: consumer (advanced)
      • startingDirectoryMustHaveAccess

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder startingDirectoryMustHaveAccess​(boolean startingDirectoryMustHaveAccess)
        Whether the starting directory has access permissions. Mind that the startingDirectoryMustExist parameter must be set to true in order to verify that the directory exists. Will thrown an exception if the directory doesn't have read and write permissions. The option is a: boolean type. Default: false Group: consumer (advanced)
      • startingDirectoryMustHaveAccess

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder startingDirectoryMustHaveAccess​(String startingDirectoryMustHaveAccess)
        Whether the starting directory has access permissions. Mind that the startingDirectoryMustExist parameter must be set to true in order to verify that the directory exists. Will thrown an exception if the directory doesn't have read and write permissions. The option will be converted to a boolean type. Default: false Group: consumer (advanced)
      • autoCreate

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder autoCreate​(boolean autoCreate)
        Automatically create missing directories in the file's pathname. For the file consumer, that means creating the starting directory. For the file producer, it means the directory the files should be written to. The option is a: boolean type. Default: true Group: advanced
      • autoCreate

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder autoCreate​(String autoCreate)
        Automatically create missing directories in the file's pathname. For the file consumer, that means creating the starting directory. For the file producer, it means the directory the files should be written to. The option will be converted to a boolean type. Default: true Group: advanced
      • copyAndDeleteOnRenameFail

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder copyAndDeleteOnRenameFail​(boolean copyAndDeleteOnRenameFail)
        Whether to fallback and do a copy and delete file, in case the file could not be renamed directly. This option is not available for the FTP component. The option is a: boolean type. Default: true Group: advanced
      • copyAndDeleteOnRenameFail

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder copyAndDeleteOnRenameFail​(String copyAndDeleteOnRenameFail)
        Whether to fallback and do a copy and delete file, in case the file could not be renamed directly. This option is not available for the FTP component. The option will be converted to a boolean type. Default: true Group: advanced
      • renameUsingCopy

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder renameUsingCopy​(boolean renameUsingCopy)
        Perform rename operations using a copy and delete strategy. This is primarily used in environments where the regular rename operation is unreliable (e.g. across different file systems or networks). This option takes precedence over the copyAndDeleteOnRenameFail parameter that will automatically fall back to the copy and delete strategy, but only after additional delays. The option is a: boolean type. Default: false Group: advanced
      • renameUsingCopy

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder renameUsingCopy​(String renameUsingCopy)
        Perform rename operations using a copy and delete strategy. This is primarily used in environments where the regular rename operation is unreliable (e.g. across different file systems or networks). This option takes precedence over the copyAndDeleteOnRenameFail parameter that will automatically fall back to the copy and delete strategy, but only after additional delays. The option will be converted to a boolean type. Default: false Group: advanced
      • synchronous

        default FileEndpointBuilderFactory.AdvancedFileEndpointConsumerBuilder synchronous​(boolean synchronous)
        Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). The option is a: boolean type. Default: false Group: advanced