org.springframework.integration.dsl.file

Class TailAdapterSpec

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,P>

org.springframework.integration.dsl.core.MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

org.springframework.integration.dsl.file.TailAdapterSpec

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

public class TailAdapterSpec
extends MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

A MessageProducerSpec for file tailing adapters.

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
TailAdapterSpec	autoStartup(boolean autoStartup)
TailAdapterSpec	delay(long delay)
protected org.springframework.integration.file.tail.FileTailingMessageProducerSupport	doGet()
TailAdapterSpec	end(boolean end)
TailAdapterSpec	errorChannel(org.springframework.messaging.MessageChannel errorChannel) Configure the MessageChannel to which error messages will be sent.
TailAdapterSpec	fileDelay(long fileDelay)
TailAdapterSpec	id(java.lang.String id) Configure the component identifier.
TailAdapterSpec	nativeOptions(java.lang.String nativeOptions)
TailAdapterSpec	outputChannel(org.springframework.messaging.MessageChannel outputChannel) Specify the outputChannel for the MessageProducer
TailAdapterSpec	phase(int phase)
TailAdapterSpec	reopen(boolean reopen)
TailAdapterSpec	taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) Configure a task executor.
TailAdapterSpec	taskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler) Set a task scheduler - defaults to the integration 'taskScheduler'.

Methods inherited from class org.springframework.integration.dsl.core.MessageProducerSpec

errorChannel, outputChannel

Methods inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

_this, get, getId, getObject, getObjectType, isSingleton

Methods inherited from class java.lang.Object

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

Method Detail

nativeOptions

public TailAdapterSpec nativeOptions(java.lang.String nativeOptions)

Parameters:

nativeOptions - the nativeOptions.

Returns:

the spec.

See Also:

OSDelegatingFileTailingMessageProducer.setOptions(String)

taskExecutor

public TailAdapterSpec taskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

Configure a task executor. Defaults to a SimpleAsyncTaskExecutor.

Parameters:

taskExecutor - the taskExecutor.

Returns:

the spec.

taskScheduler

public TailAdapterSpec taskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)

Set a task scheduler - defaults to the integration 'taskScheduler'.

Parameters:

taskScheduler - the taskScheduler.

Returns:

the spec.

delay

public TailAdapterSpec delay(long delay)

Parameters:

delay - the delay.

Returns:

the spec.

See Also:

ApacheCommonsFileTailingMessageProducer.setPollingDelay(long)

fileDelay

public TailAdapterSpec fileDelay(long fileDelay)

Parameters:

fileDelay - the fileDelay.

Returns:

the spec.

See Also:

FileTailingMessageProducerSupport.setTailAttemptsDelay(long)

end

public TailAdapterSpec end(boolean end)

Parameters:

end - the end.

Returns:

the spec.

See Also:

ApacheCommonsFileTailingMessageProducer.setEnd(boolean)

reopen

public TailAdapterSpec reopen(boolean reopen)

Parameters:

reopen - the reopen.

Returns:

the spec.

See Also:

ApacheCommonsFileTailingMessageProducer.setReopen(boolean)

id

public TailAdapterSpec id(java.lang.String id)

Description copied from class: MessageProducerSpec

Configure the component identifier. Used as the beanName to register the bean in the application context for this component. Configure the message producer's bean name.

Overrides:

id in class MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

Parameters:

id - the id.

Returns:

the spec.

phase

public TailAdapterSpec phase(int phase)

Overrides:

phase in class MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

Parameters:

phase - the phase.

Returns:

the spec.

See Also:

SmartLifecycle

autoStartup

public TailAdapterSpec autoStartup(boolean autoStartup)

Overrides:

autoStartup in class MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

Parameters:

autoStartup - the autoStartup.

Returns:

the spec.

See Also:

SmartLifecycle

outputChannel

public TailAdapterSpec outputChannel(org.springframework.messaging.MessageChannel outputChannel)

Description copied from class: MessageProducerSpec

Specify the outputChannel for the MessageProducer

Overrides:

outputChannel in class MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

Parameters:

outputChannel - the outputChannel.

Returns:

the spec.

See Also:

MessageProducerSupport.setOutputChannel(MessageChannel)

errorChannel

public TailAdapterSpec errorChannel(org.springframework.messaging.MessageChannel errorChannel)

Description copied from class: MessageProducerSpec

Configure the MessageChannel to which error messages will be sent.

Overrides:

errorChannel in class MessageProducerSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>

Parameters:

errorChannel - the errorChannel.

Returns:

the spec.

See Also:

MessageProducerSupport.setErrorChannel(MessageChannel)

doGet

protected org.springframework.integration.file.tail.FileTailingMessageProducerSupport doGet()

Overrides:

doGet in class IntegrationComponentSpec<TailAdapterSpec,org.springframework.integration.file.tail.FileTailingMessageProducerSupport>