com.caucho.jms.jdbc
Class JdbcDestination

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue
          com.caucho.jms.queue.AbstractDestination
              com.caucho.jms.jdbc.JdbcDestination

All Implemented Interfaces:

HandleAware, java.io.Serializable, java.lang.Iterable, java.util.Collection, java.util.concurrent.BlockingQueue, java.util.Queue, Destination

public abstract class JdbcDestination
extends AbstractDestination

Represents a JDBC destination.

See Also:

Serialized Form

Field Summary

protected JdbcManager

_jdbcManager

Fields inherited from class com.caucho.jms.queue.AbstractDestination

_messageFactory

Constructor Summary

JdbcDestination()

Method Summary

protected int	createDestination(java.lang.String name, boolean isTopic) Creates a queue.
JdbcManager	getJdbcManager() Gets the JDBC manager.
java.lang.String	getName() Gets the name.
void	init() Initializes the JdbcDestination
boolean	isTopic() Returns true for a topic.
protected void	purgeExpiredMessages() Purges expired messages.
void	setDataSource(javax.sql.DataSource dataSource) Sets the data source.
void	setJdbcManager(JdbcManager jdbcManager) Sets the jdbc manager
void	setName(java.lang.String name) Sets the name.
void	setTablespace(java.lang.String tablespace) Sets the tablespace for Oracle.

Methods inherited from class com.caucho.jms.queue.AbstractDestination

acknowledge, addMessageAvailableListener, close, drainTo, drainTo, generateMessageID, generateMessageID, getJMSDestination, getQueueName, getReadConsumer, getTopicName, getUrl, getWriteSession, hasMessage, iterator, offer, offer, peek, poll, poll, put, receive, remainingCapacity, removeMessageAvailableListener, rollback, send, setSerializationHandle, size, take, toString

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, remove

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, removeAll, retainAll, toArray, toArray

Field Detail

_jdbcManager

protected JdbcManager _jdbcManager

Constructor Detail

JdbcDestination

public JdbcDestination()

Method Detail

setName

public void setName(java.lang.String name)

Sets the name.

Overrides:

setName in class AbstractDestination

getName

public java.lang.String getName()

Gets the name.

Overrides:

getName in class AbstractDestination

isTopic

public boolean isTopic()

Returns true for a topic.

setJdbcManager

public void setJdbcManager(JdbcManager jdbcManager)

Sets the jdbc manager

getJdbcManager

public JdbcManager getJdbcManager()

Gets the JDBC manager.

setDataSource

public void setDataSource(javax.sql.DataSource dataSource)

Sets the data source.

setTablespace

public void setTablespace(java.lang.String tablespace)

Sets the tablespace for Oracle.

init

public void init()
          throws ConfigException,
                 java.sql.SQLException

Initializes the JdbcDestination

Throws:

ConfigException

java.sql.SQLException

createDestination

protected int createDestination(java.lang.String name,
                                boolean isTopic)
                         throws java.sql.SQLException

Creates a queue.

Throws:

java.sql.SQLException

purgeExpiredMessages

protected void purgeExpiredMessages()

Purges expired messages.