|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.store.amq.reader.AMQReader
public class AMQReader
Reads and iterates through data log files for the AMQMessage Store
Constructor Summary | |
---|---|
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 |
Method Summary | |
---|---|
protected org.apache.activemq.store.amq.reader.MessageLocation |
getNextMessage(org.apache.activemq.store.amq.reader.MessageLocation lastLocation)
|
Iterator<Message> |
iterator()
|
static Set<File> |
listDataFiles(File directory)
List all the data files in a directory |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public AMQReader(File file) throws InvalidSelectorException, IOException
file
- the directory - or file
IOException
InvalidSelectorException
IOException
InvalidSelectorException
public AMQReader(File file, String selector) throws IOException, InvalidSelectorException
file
- the directory - or fileselector
- the JMS selector or null to select all
IOException
InvalidSelectorException
Method Detail |
---|
public static Set<File> listDataFiles(File directory) throws IOException
directory
-
IOException
public Iterator<Message> iterator()
iterator
in interface Iterable<Message>
protected org.apache.activemq.store.amq.reader.MessageLocation getNextMessage(org.apache.activemq.store.amq.reader.MessageLocation lastLocation) throws IllegalStateException, IOException
IllegalStateException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |