public class AMQReader extends java.lang.Object implements java.lang.Iterable<javax.jms.Message>
Constructor and Description |
---|
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
|
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) |
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
|
public AMQReader(java.io.File file) throws javax.jms.InvalidSelectorException, java.io.IOException
file
- the directory - or filejava.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 alljava.io.IOException
javax.jms.InvalidSelectorException
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
Copyright © 2005-2017. All Rights Reserved.