A C D E F G I L M O P R S U V W

A

AbstractConsumer - Class in org.ikasan.component.endpoint.util.consumer

This abstract consumer provides a convenience base for any standard consumer extending classes.

AbstractConsumer() - Constructor for class org.ikasan.component.endpoint.util.consumer.AbstractConsumer

C

check(Object) - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

check(Object) - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRule

check(TRIGGER) - Method in interface org.ikasan.component.endpoint.rulecheck.Rule

Has the rule been breached.

configurationService - Variable in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

createBreachException(String) - Method in interface org.ikasan.component.endpoint.rulecheck.DailyEventRuleStrategy

D

DailyEventRuleConfiguration - Class in org.ikasan.component.endpoint.rulecheck

DailyEventRuleConfiguration() - Constructor for class org.ikasan.component.endpoint.rulecheck.DailyEventRuleConfiguration

DailyEventRuleRule<PAYLOAD_TYPE,BREACH_EXCEPTION_TYPE extends RuleBreachException> - Class in org.ikasan.component.endpoint.rulecheck

DailyEventRuleRule(ConfigurationService<DailyEventRuleRule>, DailyEventRuleStrategy<PAYLOAD_TYPE, BREACH_EXCEPTION_TYPE>, String) - Constructor for class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

DailyEventRuleStrategy<EVENT_TYPE,FAILURE_EXCEPTION extends RuleBreachException> - Interface in org.ikasan.component.endpoint.rulecheck

dateEventIsFor(EVENT_TYPE) - Method in interface org.ikasan.component.endpoint.rulecheck.DailyEventRuleStrategy

dateFormatter() - Method in interface org.ikasan.component.endpoint.rulecheck.DailyEventRuleStrategy

DevNull<T> - Class in org.ikasan.component.endpoint.util.producer

Implementation of a producer for dev/null.

DevNull() - Constructor for class org.ikasan.component.endpoint.util.producer.DevNull

E

ErrorReportingAwareScheduledRuleCheckBroker<EVENT,RULE extends IsErrorReportingServiceAware> - Class in org.ikasan.component.endpoint.rulecheck.broker

ErrorReportingAwareScheduledRuleCheckBroker(Scheduler, Rule) - Constructor for class org.ikasan.component.endpoint.rulecheck.broker.ErrorReportingAwareScheduledRuleCheckBroker

EventGeneratingConsumer - Class in org.ikasan.component.endpoint.util.consumer

This consumer implementation provides a simple event generator to provision testing of flows quickly and easily.

EventGeneratingConsumer() - Constructor for class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

EventGeneratingConsumer.EventGenerator - Class in org.ikasan.component.endpoint.util.consumer

Simple event generator class implementation.

EventGeneratingConsumer.EventGenerator() - Constructor for class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer.EventGenerator

EventGeneratingConsumerConfiguration - Class in org.ikasan.component.endpoint.util.consumer

This configuration class for the EventGeneratingConsumer implementation.

EventGeneratingConsumerConfiguration() - Constructor for class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

eventListener - Variable in class org.ikasan.component.endpoint.util.consumer.AbstractConsumer

consumer event listener

execute(JobExecutionContext) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

F

FileConsumerConfiguration - Class in org.ikasan.component.endpoint.filesystem.messageprovider

File consumer configuration bean.

FileConsumerConfiguration() - Constructor for class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

FileLineEventIdentifierServiceImpl - Class in org.ikasan.component.endpoint.filesystem.messageprovider

Implementation of the ManagedIdentifierService for FileLine events.

FileLineEventIdentifierServiceImpl(String) - Constructor for class org.ikasan.component.endpoint.filesystem.messageprovider.FileLineEventIdentifierServiceImpl

Constructor

FileMatcher - Class in org.ikasan.component.endpoint.filesystem.messageprovider

FileMatcher which walks the directory tree and uses regular expressions to locate any matching file paths.

FileMessageProvider - Class in org.ikasan.component.endpoint.filesystem.messageprovider

Implementation of a MessageProvider based on returning a list of File references.

FileMessageProvider() - Constructor for class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

FileMessageProviderPostProcessorImpl - Class in org.ikasan.component.endpoint.filesystem.messageprovider

File Message Provider Post Processor implementation of the MessageProvidePostProcessor.

FileMessageProviderPostProcessorImpl() - Constructor for class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProviderPostProcessorImpl

FileProducer<T> - Class in org.ikasan.component.endpoint.filesystem.producer

File producer.

FileProducer() - Constructor for class org.ikasan.component.endpoint.filesystem.producer.FileProducer

FileProducerConfiguration - Class in org.ikasan.component.endpoint.filesystem.producer

File producer configuration bean.

FileProducerConfiguration() - Constructor for class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

flowEventFactory - Variable in class org.ikasan.component.endpoint.util.consumer.AbstractConsumer

consumer event factory

G

getBatchsize() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

getConfiguration() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

getConfiguration() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProviderPostProcessorImpl

getConfiguration() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

getConfiguration() - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

getConfiguration() - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

getConfiguration() - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRule

getConfiguration() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Getter for configuration

getConfiguredResourceId() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

getConfiguredResourceId() - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

getConfiguredResourceId() - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

getConfiguredResourceId() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Getter for configured resourceId

getCronExpression() - Method in class org.ikasan.component.endpoint.rulecheck.RuleCheckConfiguration

getCronTrigger(JobKey, String) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

Method factory for creating a cron trigger

getDirectoryDepth() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

getEncoding() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

getEncoding() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

getEventFactory() - Method in class org.ikasan.component.endpoint.util.consumer.AbstractConsumer

getEventGenerationInterval() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

getEventIdentifier(List<File>) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileLineEventIdentifierServiceImpl

getEventLimit() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

getFileMatcher(String) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

getFilename() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

getFilenames() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

getIdentifier() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

getLastDateProcessed() - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleConfiguration

getLastEventTimestampOverride() - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

getLineEnding() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

getPayload() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

getTempFilename() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

getTimeInterval() - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

I

invoke() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMatcher

Invoke the walk dir for this fileMatcher instance.

invoke(JobExecutionContext) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

invoke(List<File>) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProviderPostProcessorImpl

Invoke

invoke(T) - Method in interface org.ikasan.component.endpoint.filesystem.messageprovider.MessageProviderPostProcessor

Invoke the post processor process

invoke(T) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

invoke(EVENT) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

invoke(T) - Method in class org.ikasan.component.endpoint.util.producer.DevNull

invoke(T) - Method in class org.ikasan.component.endpoint.util.producer.LogProducer

isActive() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

isCriticalOnStartup() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

isCriticalOnStartup() - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

isIgnoreFileRenameWhilstScanning() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

isIncludeHeader() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

isIncludeTrailer() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

isLogMatchedFilenames() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

isOverwrite() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

isResetLastEventTimestampOnStartToNow() - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

isRunning() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Is the underlying event generator actively running

isSortAscending() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

isSortByModifiedDateTime() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

isUseTempFile() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

isWriteChecksum() - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

L

LogProducer<T> - Class in org.ikasan.component.endpoint.util.producer

Implementation of a producer as a logger.

LogProducer(String, String) - Constructor for class org.ikasan.component.endpoint.util.producer.LogProducer

Constructor

LogProducer() - Constructor for class org.ikasan.component.endpoint.util.producer.LogProducer

Constructor

M

managedResourceRecoveryManager - Variable in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

Recovery manager for this Managed Resource and any extending implementations of it

MessageProviderPostProcessor<T> - Interface in org.ikasan.component.endpoint.filesystem.messageprovider

Contract for a MessageProvidePostProcessor.

O

onException(IOException) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

onMessage(String) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

org.ikasan.component.endpoint.filesystem.messageprovider - package org.ikasan.component.endpoint.filesystem.messageprovider

org.ikasan.component.endpoint.filesystem.producer - package org.ikasan.component.endpoint.filesystem.producer

org.ikasan.component.endpoint.rulecheck - package org.ikasan.component.endpoint.rulecheck

org.ikasan.component.endpoint.rulecheck.broker - package org.ikasan.component.endpoint.rulecheck.broker

org.ikasan.component.endpoint.util.consumer - package org.ikasan.component.endpoint.util.consumer

org.ikasan.component.endpoint.util.producer - package org.ikasan.component.endpoint.util.producer

P

preVisitDirectory(Path, BasicFileAttributes) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMatcher

Walk dir callback for directories

process(Object) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

R

rebase() - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

rebase() - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRule

rebase() - Method in interface org.ikasan.component.endpoint.rulecheck.Rule

Allow the rule to be rebased to reset any rule state

RelativeTimeIntervalRule - Class in org.ikasan.component.endpoint.rulecheck

Simple rule checks for an event within a relative time interval.

RelativeTimeIntervalRule() - Constructor for class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRule

RelativeTimeIntervalRuleConfiguration - Class in org.ikasan.component.endpoint.rulecheck

Scheduled rule check configuration bean based on a time interval threshold.

RelativeTimeIntervalRuleConfiguration() - Constructor for class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

Rule<EVENT,TRIGGER> - Interface in org.ikasan.component.endpoint.rulecheck

Rule contract.

RuleBreachException - Exception in org.ikasan.component.endpoint.rulecheck

Exception for a rule breach.

RuleBreachException(String) - Constructor for exception org.ikasan.component.endpoint.rulecheck.RuleBreachException

Constructor

RuleCheckConfiguration - Class in org.ikasan.component.endpoint.rulecheck

Scheduled rule check configuration bean.

RuleCheckConfiguration() - Constructor for class org.ikasan.component.endpoint.rulecheck.RuleCheckConfiguration

run() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer.EventGenerator

S

ScheduledRuleCheckBroker<EVENT> - Class in org.ikasan.component.endpoint.rulecheck.broker

Simple scheduled rule invoker.

ScheduledRuleCheckBroker(Scheduler, Rule) - Constructor for class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

Constructor

setBatchsize(int) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

setConfiguration(FileConsumerConfiguration) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

setConfiguration(FileConsumerConfiguration) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProviderPostProcessorImpl

setConfiguration(FileProducerConfiguration) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

setConfiguration(RuleCheckConfiguration) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

setConfiguration(DailyEventRuleConfiguration) - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

setConfiguration(RelativeTimeIntervalRuleConfiguration) - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRule

setConfiguration(EventGeneratingConsumerConfiguration) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Setter for configuration

setConfiguredResourceId(String) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

setConfiguredResourceId(String) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

setConfiguredResourceId(String) - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

setConfiguredResourceId(String) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Setter for configured resource Id

setCriticalOnStartup(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

setCriticalOnStartup(boolean) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

setCronExpression(String) - Method in class org.ikasan.component.endpoint.rulecheck.RuleCheckConfiguration

setDirectoryDepth(int) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setEncoding(String) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setEncoding(String) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

setErrorReportingService(ErrorReportingService) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ErrorReportingAwareScheduledRuleCheckBroker

setErrorReportingService(ErrorReportingService) - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

setEventFactory(EventFactory) - Method in class org.ikasan.component.endpoint.util.consumer.AbstractConsumer

Setter for eventFactory

setEventGenerationInterval(long) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

setEventIdentifier(String, List<File>) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileLineEventIdentifierServiceImpl

setEventLimit(int) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

setFilename(String) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

setFilenames(List<String>) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setIdentifier(String) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

setIgnoreFileRenameWhilstScanning(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setIncludeHeader(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setIncludeTrailer(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setJobDetail(JobDetail) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

setLastDateProcessed(String) - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleConfiguration

setLastEventTimestampOverride(long) - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

setLineEnding(String) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

setListener(EventListener) - Method in class org.ikasan.component.endpoint.util.consumer.AbstractConsumer

Set the consumer event listener

setLogMatchedFilenames(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setManagedResourceRecoveryManager(ManagedResourceRecoveryManager) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

setManagedResourceRecoveryManager(ManagedResourceRecoveryManager) - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

setMessageProviderPostProcessor(MessageProviderPostProcessor) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

setOverwrite(boolean) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

setPayload(String) - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumerConfiguration

setResetLastEventTimestampOnStartToNow(boolean) - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

setSortAscending(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setSortByModifiedDateTime(boolean) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileConsumerConfiguration

setTempFilename(String) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

setTimeInterval(long) - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRuleConfiguration

setUseTempFile(boolean) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

setWriteChecksum(boolean) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducerConfiguration

start() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Start the underlying event generator

startManagedResource() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

startManagedResource() - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

Start the scheduled job and triggers

stop() - Method in class org.ikasan.component.endpoint.util.consumer.EventGeneratingConsumer

Stop the event generator

stopManagedResource() - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMessageProvider

stopManagedResource() - Method in class org.ikasan.component.endpoint.rulecheck.broker.ScheduledRuleCheckBroker

Stop the scheduled job and triggers

U

update(PAYLOAD_TYPE) - Method in class org.ikasan.component.endpoint.rulecheck.DailyEventRuleRule

update(Object) - Method in class org.ikasan.component.endpoint.rulecheck.RelativeTimeIntervalRule

update(EVENT) - Method in interface org.ikasan.component.endpoint.rulecheck.Rule

Event hitting the rule at runtime

V

visitFile(Path, BasicFileAttributes) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMatcher

walk dir callback for files

visitFileFailed(Path, IOException) - Method in class org.ikasan.component.endpoint.filesystem.messageprovider.FileMatcher

Walk dir callback on failure encountered with a directory or file.

W

writeFile(File, Object) - Method in class org.ikasan.component.endpoint.filesystem.producer.FileProducer

Write the payload to the file based on the incoming payload type.

A C D E F G I L M O P R S U V W