public void setItemReaderList( List<AbstractCursorItemReader<?>> itemReaderList )
    {
        this.itemReaderList = itemReaderList;
    }

    /**
     * setter method for DI.
     * 
     * @param returnType
     */
    public void setReturnType( String returnType )
    {
        this.returnType = returnType;
    }

    @Override
    public void open( ExecutionContext executionContext ) throws ItemStreamException
    {
        for ( ItemStream itemStream : itemReaderList )
        {
            itemStream.open( executionContext );
        }
    }

    @Override
    public void close() throws ItemStreamException
    {
        for ( ItemStream itemStream : itemReaderList )
        {
            itemStream.close();
        }
    }

    @Override
    public void update( ExecutionContext executionContext )
    {
        for ( ItemStream itemStream : itemReaderList )
        {
            itemStream.update( executionContext );
        }
    }

    @Override
    public T read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException
    {
        Object[] items = new Object[itemReaderList.size()];

        int count = 0;
        int flagCount = 0;
        if ( returnType.toUpperCase().equals( "READER" ) )
        {
            for ( AbstractCursorItemReader<?> itemReader : itemReaderList )