public AMQReader(File file) throws InvalidSelectorException, IOException 
{
        this(file,null);
}

Create the AMQReader to read a directory of amq data logs - or an individual data log file

Parameters:

file - the directory - or file

Throws:

IOException -

InvalidSelectorException -

IOException -

InvalidSelectorException -

 public AMQReader(File file,
    String selector) throws IOException, InvalidSelectorException 
{
        String str = selector != null ? selector.trim() : null;
        if (str != null && str.length()  > 0) {
            this.expression=SelectorParser.parse(str);
        }
        dataManager = new AsyncDataManager();
        dataManager.setArchiveDataLogs(false);
        if (file.isDirectory()) {
            dataManager.setDirectory(file);
        } else {
            dataManager.setDirectory(file.getParentFile());
            dataManager.setDirectoryArchive(file);
            this.file = file;
        }
        dataManager.start();
}

Create the AMQReader to read a directory of amq data logs - or an individual data log file

Parameters:

file - the directory - or file

selector - the JMS selector or null to select all

Throws:

IOException -

InvalidSelectorException -

 protected MessageLocation getNextMessage(MessageLocation lastLocation) throws IllegalStateException, IOException 
{
        if (this.file != null) {
            return getInternalNextMessage(this.file, lastLocation);
        }
        return getInternalNextMessage(lastLocation);
}

 public Iterator<Message> iterator() 
{
        return new AMQIterator(this,this.expression);
}

 public static Set<File> listDataFiles(File directory) throws IOException 
{
        Set< File >result = new HashSet< File >();
        if (directory == null || !directory.exists() || !directory.isDirectory()) {
            throw new IOException("Invalid Directory " + directory);
        }
        AsyncDataManager dataManager = new AsyncDataManager();
        dataManager.setDirectory(directory);
        dataManager.start();
        Set< File > set = dataManager.getFiles();
        if (set != null) {
            result.addAll(set);
        }
        dataManager.close();
        return result;
}

List all the data files in a directory