default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.AdvancedStreamEndpointConsumerBuilder.basic() |
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.encoding(String encoding) |
You can configure the encoding (is a charset name) to use text-based
streams (for example, message body is a String object).
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.fileName(String fileName) |
When using the stream:file URI format, this option specifies the
filename to stream to/from.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.fileWatcher(boolean fileWatcher) |
To use JVM file watcher to listen for file change events to support
re-loading files that may be overwritten, somewhat like tail --retry.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.fileWatcher(String fileWatcher) |
To use JVM file watcher to listen for file change events to support
re-loading files that may be overwritten, somewhat like tail --retry.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.groupLines(int groupLines) |
To group X number of lines in the consumer.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.groupLines(String groupLines) |
To group X number of lines in the consumer.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.groupStrategy(Object groupStrategy) |
Allows to use a custom GroupStrategy to control how to group lines.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.groupStrategy(String groupStrategy) |
Allows to use a custom GroupStrategy to control how to group lines.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.initialPromptDelay(long initialPromptDelay) |
Initial delay in milliseconds before showing the message prompt.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.initialPromptDelay(String initialPromptDelay) |
Initial delay in milliseconds before showing the message prompt.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.promptDelay(long promptDelay) |
Optional delay in milliseconds before showing the message prompt.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.promptDelay(String promptDelay) |
Optional delay in milliseconds before showing the message prompt.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.promptMessage(String promptMessage) |
Message prompt to use when reading from stream:in; for example, you
could set this to Enter a command:.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.retry(boolean retry) |
Will retry opening the stream if it's overwritten, somewhat like tail
--retry If reading from files then you should also enable the
fileWatcher option, to make it work reliable.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.retry(String retry) |
Will retry opening the stream if it's overwritten, somewhat like tail
--retry If reading from files then you should also enable the
fileWatcher option, to make it work reliable.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.scanStream(boolean scanStream) |
To be used for continuously reading a stream such as the unix tail
command.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.scanStream(String scanStream) |
To be used for continuously reading a stream such as the unix tail
command.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.scanStreamDelay(long scanStreamDelay) |
Delay in milliseconds between read attempts when using scanStream.
|
default StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder |
StreamEndpointBuilderFactory.StreamEndpointConsumerBuilder.scanStreamDelay(String scanStreamDelay) |
Delay in milliseconds between read attempts when using scanStream.
|