|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.console.command.store.amq.reader.AMQReader
public class AMQReader
Reads and iterates through data log files for the AMQMessage Store
Constructor Summary | |
---|---|
AMQReader(java.io.File file)
Create the AMQReader to read a directory of amq data logs - or an individual data log file |
|
AMQReader(java.io.File file,
java.lang.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.console.command.store.amq.reader.MessageLocation |
getNextMessage(org.apache.activemq.console.command.store.amq.reader.MessageLocation lastLocation)
|
java.util.Iterator<javax.jms.Message> |
iterator()
|
static java.util.Set<java.io.File> |
listDataFiles(java.io.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(java.io.File file) throws javax.jms.InvalidSelectorException, java.io.IOException
file
- the directory - or file
java.io.IOException
javax.jms.InvalidSelectorException
java.io.IOException
javax.jms.InvalidSelectorException
public AMQReader(java.io.File file, java.lang.String selector) throws java.io.IOException, javax.jms.InvalidSelectorException
file
- the directory - or fileselector
- the JMS selector or null to select all
java.io.IOException
javax.jms.InvalidSelectorException
Method Detail |
---|
public static java.util.Set<java.io.File> listDataFiles(java.io.File directory) throws java.io.IOException
directory
-
java.io.IOException
public java.util.Iterator<javax.jms.Message> iterator()
iterator
in interface java.lang.Iterable<javax.jms.Message>
protected org.apache.activemq.console.command.store.amq.reader.MessageLocation getNextMessage(org.apache.activemq.console.command.store.amq.reader.MessageLocation lastLocation) throws java.lang.IllegalStateException, java.io.IOException
java.lang.IllegalStateException
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |