com.rhi.architecture.parc
Interface InputAdapter

All Superinterfaces:

Adapter

All Known Implementing Classes:

AbstractInputAdapter

public interface InputAdapter

extends Adapter

The InputAdapter is responsible for selecting a set of work for processing and pushing it into the Channel for processing..

Since:

1.0

Author:

Pete McKinstry

Method Summary

void	addToErrorChannel(Record record) The concrete input adapter can use this method to add error records to the error channel while maintaining the correct audit entries for valid (returned from loadBatch() & pushed into the normal pipeline channel) & errors (added by calling addError() & pushed into the error channel.
int	push(Channel ch) Send a set of records requiring processing to the pipeline.
void	setErrorChannel(Channel errorChannel) set the error channel.

Methods inherited from interface com.rhi.architecture.parc.Adapter

cleanup, getAuditAgent, init, setAuditAgent

Method Detail

push

public int push(Channel ch)
         throws ProcessingException

Send a set of records requiring processing to the pipeline. The collection should contain objects of type Record.

Parameters:

ch - where input records should be sent.

Returns:

int

Throws:

ProcessingException - error occured selecting records.

Since:

1.0

setErrorChannel

public void setErrorChannel(Channel errorChannel)

set the error channel.

This method can be used by input adapters in cases where they have parsing errors or other non-fatal record level errors when loading a batch of records.

Parameters:

errorChannel -

Since:

1.0

addToErrorChannel

public void addToErrorChannel(Record record)

The concrete input adapter can use this method to add error records to the error channel while maintaining the correct audit entries for valid (returned from loadBatch() & pushed into the normal pipeline channel) & errors (added by calling addError() & pushed into the error channel.

Parameters:

record -

Since:

1.0