Constructor and Description |
---|
AMQReader(File file)
Create the AMQReader to read a directory of amq data logs - or an
individual data log file
|
AMQReader(File file,
String selector)
Create the AMQReader to read a directory of amq data logs - or an
individual data log file
|
Modifier and Type | Method and Description |
---|---|
protected org.apache.activemq.console.command.store.amq.reader.MessageLocation |
getNextMessage(org.apache.activemq.console.command.store.amq.reader.MessageLocation lastLocation) |
Iterator<javax.jms.Message> |
iterator() |
static Set<File> |
listDataFiles(File directory)
List all the data files in a directory
|
public AMQReader(File file) throws javax.jms.InvalidSelectorException, IOException
file
- the directory - or fileIOException
javax.jms.InvalidSelectorException
IOException
javax.jms.InvalidSelectorException
public AMQReader(File file, String selector) throws IOException, javax.jms.InvalidSelectorException
file
- the directory - or fileselector
- the JMS selector or null to select allIOException
javax.jms.InvalidSelectorException
public static Set<File> listDataFiles(File directory) throws IOException
directory
- IOException
protected org.apache.activemq.console.command.store.amq.reader.MessageLocation getNextMessage(org.apache.activemq.console.command.store.amq.reader.MessageLocation lastLocation) throws IllegalStateException, IOException
IllegalStateException
IOException
Copyright © 2005–2016. All rights reserved.