com.caucho.jms.file
Class FileQueueStore

java.lang.Object
  com.caucho.jms.file.FileQueueStore

public class FileQueueStore
extends java.lang.Object

Implements a file queue.

Constructor Summary

FileQueueStore(MessageFactory messageFactory)

Method Summary

java.lang.String	getName()
Path	getPath() Returns the path to the backing database
void	init()
MessageImpl	readMessage(long id, MessageType type) Retrieves a message from the persistent store.
MessageImpl	receive() Retrieves a message from the persistent store.
void	remove(java.lang.String id) Retrieves a message from the persistent store.
long	send(MessageImpl msg, int priority, long expireTime) Adds a new message to the persistent store.
void	setName(java.lang.String name)
void	setPath(Path path) Sets the path to the database
void	setTablePrefix(java.lang.String prefix)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FileQueueStore

public FileQueueStore(MessageFactory messageFactory)

Method Detail

setName

public void setName(java.lang.String name)

getName

public java.lang.String getName()

setPath

public void setPath(Path path)

Sets the path to the database

getPath

public Path getPath()

Returns the path to the backing database

setTablePrefix

public void setTablePrefix(java.lang.String prefix)

init

public void init()

send

public long send(MessageImpl msg,
                 int priority,
                 long expireTime)

Adds a new message to the persistent store.

readMessage

public MessageImpl readMessage(long id,
                               MessageType type)

Retrieves a message from the persistent store.

receive

public MessageImpl receive()

Retrieves a message from the persistent store.

remove

public void remove(java.lang.String id)

Retrieves a message from the persistent store.