JDBCPersistenceManager (JBoss Messaging 1.3.0.GA)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.messaging.core.plugin
Class JDBCPersistenceManager

java.lang.Object
  org.jboss.messaging.core.plugin.JDBCSupport
      org.jboss.messaging.core.plugin.JDBCPersistenceManager

All Implemented Interfaces:: MessagingComponent, PersistenceManager

public class JDBCPersistenceManager
extends JDBCSupport
implements PersistenceManager

JDBC implementation of PersistenceManager.

Version:: 1.1 JDBCPersistenceManager.java,v 1.1 2006/02/22 17:33:41 timfox Exp
Author:: Ovidiu Feodorov, Tim Fox, Adrian Brock, Juha Lindfors

Nested Class Summary

Nested classes inherited from class org.jboss.messaging.core.plugin.JDBCSupport

JDBCSupport.TransactionWrapper

Nested classes inherited from class org.jboss.messaging.core.plugin.contract.PersistenceManager

PersistenceManager.InitialLoadInfo, PersistenceManager.MessageChannelPair, PersistenceManager.ReferenceInfo

Field Summary

Fields inherited from class org.jboss.messaging.core.plugin.JDBCSupport

ds, sqlProperties

Constructor Summary
`JDBCPersistenceManager(javax.sql.DataSource ds, TransactionManager tm, java.util.Properties sqlProperties, boolean createTablesOnStartup, boolean usingBatchUpdates, boolean usingBinaryStream, boolean usingTrailingByte, int maxParams)`

Method Summary
`protected void`	`addReference(long channelID, MessageReference ref, java.sql.PreparedStatement ps, boolean paged)`
`void`	`addReference(long channelID, MessageReference ref, Transaction tx)`
`protected void`	`addTXRecord(java.sql.Connection conn, Transaction tx)`
`protected java.util.HashMap`	`bytesToMap(byte[] bytes)`
`protected void`	`commitPreparedTransaction(Transaction tx, java.sql.Connection conn)`
`protected void`	`decrementChannelCount(Message m, java.sql.PreparedStatement ps)`
`protected byte[]`	`getBytes(java.sql.ResultSet rs, int columnIndex)`
`protected org.jboss.messaging.core.plugin.JDBCPersistenceManager.TransactionCallback`	`getCallback(Transaction tx)`
`protected java.util.Map`	`getDefaultDDLStatements()`
`protected java.util.Map`	`getDefaultDMLStatements()`
`protected void`	`getLocks(java.util.List refs)`
`java.util.List`	`getMessageChannelPairAcksForTx(long transactionId)`
`java.util.List`	`getMessageChannelPairRefsForTx(long transactionId)`
`java.util.List`	`getMessages(java.util.List messageIds)`
`java.util.List`	`getPagedReferenceInfos(long channelID, long orderStart, int number)`
`protected byte[]`	`getVarBinaryColumn(java.sql.ResultSet rs, int columnIndex)`
`protected void`	`handleBeforeCommit1PC(java.util.List refsToAdd, java.util.List refsToRemove, Transaction tx)`
`protected void`	`handleBeforeCommit2PC(java.util.List refsToRemove, Transaction tx)`
`protected void`	`handleBeforePrepare(java.util.List refsToAdd, java.util.List refsToRemove, Transaction tx)`
`protected void`	`handleBeforeRollback(java.util.List refsToAdd, Transaction tx)`
`protected void`	`incrementChannelCount(Message m, java.sql.PreparedStatement ps)`
`PersistenceManager.InitialLoadInfo`	`loadFromStart(long channelID, int number)`
`protected void`	`logBatchUpdate(java.lang.String name, int[] rows, java.lang.String action)`
`protected byte[]`	`mapToBytes(java.util.Map map)`
`PersistenceManager.InitialLoadInfo`	`mergeAndLoad(long fromChannelID, long toChannelID, int numberToLoad, long firstPagingOrder, long nextPagingOrder)`
`protected void`	`orderReferences(java.util.List references)` We order the list of references in ascending message order thus preventing deadlock when 2 or more channels are updating the same messages in different transactions.
`void`	`pageReferences(long channelID, java.util.List references, boolean paged)`
`protected void`	`prepareToAddReference(long channelID, MessageReference ref, Transaction tx, java.sql.PreparedStatement ps)`
`protected void`	`prepareToRemoveReference(long channelID, MessageReference ref, Transaction tx, java.sql.PreparedStatement ps)`
`boolean`	`referenceExists(long messageID)`
`boolean`	`referenceExists(long channelID, long messageID)`
`protected void`	`releaseLocks(java.util.List refs)`
`void`	`removeDepagedReferences(long channelID, java.util.List references)`
`protected void`	`removeMessage(Message message, java.sql.PreparedStatement ps)` Removes the message from the MESSAGE table.
`protected void`	`removeReference(long channelID, MessageReference ref, java.sql.PreparedStatement ps)`
`void`	`removeReference(long channelID, MessageReference ref, Transaction tx)`
`protected void`	`removeTXRecord(java.sql.Connection conn, Transaction tx)`
`long`	`reserveIDBlock(java.lang.String counterName, int size)`
`java.util.List`	`retrievePreparedTransactions()`
`protected void`	`rollbackPreparedTransaction(Transaction tx, java.sql.Connection conn)`
`protected void`	`setBytes(java.sql.PreparedStatement ps, int columnIndex, byte[] bytes)`
`protected void`	`setVarBinaryColumn(int column, java.sql.PreparedStatement ps, byte[] bytes)`
`void`	`start()`
`void`	`stop()`
`protected void`	`storeMessage(Message m, java.sql.PreparedStatement ps)` Stores the message in the MESSAGE table.
`java.lang.String`	`toString()`
`void`	`updateDeliveryCount(long channelID, MessageReference ref)`
`void`	`updatePageOrder(long channelID, java.util.List references)`
`void`	`updateReferencesNotPagedInRange(long channelID, long orderStart, long orderEnd, long num)`
`protected int`	`updateWithRetry(java.sql.PreparedStatement ps)`
`protected int[]`	`updateWithRetryBatch(java.sql.PreparedStatement ps)`

Methods inherited from class org.jboss.messaging.core.plugin.JDBCSupport

closeConnection, closeResultSet, closeStatement, getSQLStatement, ignoreVerificationOnStartup

Methods inherited from class java.lang.Object

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

Constructor Detail