| java.util.AbstractQueue
 com.caucho.jms.queue.AbstractDestination
com.caucho.jms.queue.AbstractQueue
com.caucho.jms.file.FileQueue
| FileQueue | | public class FileQueue extends AbstractQueue implements Topic(Code) | | A JMS queue backed by a file-based database.
The URL looks like
file:name=my-name;path=file:/var/www/webapps/test/WEB-INFjms
It is configured as:
<jms-queue jndi-name="jms/my-name" uri="file:path=WEB-INF/jms"/>
|
| FileQueue | | public FileQueue()(Code) | | |
| acknowledge | | public void acknowledge(String msgId)(Code) | | Rollsback the message from the store.
|
| getPath | | public Path getPath()(Code) | | |
| getQueueSize | | public int getQueueSize()(Code) | | |
| getUrl | | public String getUrl()(Code) | | Returns the JMS configuration url.
|
| init | | public void init()(Code) | | Initialize the queue
|
| receive | | public MessageImpl receive(boolean isAutoAck)(Code) | | Polls the next message from the store. If no message is available,
wait for the timeout.
|
| rollback | | public void rollback(String msgId)(Code) | | Rollsback the message from the store.
|
| send | | public void send(JmsSession session, MessageImpl msg, long expires)(Code) | | Adds the message to the persistent store. Called if there are no
active listeners.
Parameters:
msg - the message to store
Parameters:
expires - the expires time |
| setPath | | public void setPath(Path path)(Code) | | Sets the path to the backing database
|
| setTablePrefix | | public void setTablePrefix(String prefix)(Code) | | |
|
|