User: jayeshpk
Date: 01/09/04 08:06:51
Modified: src/main/org/jboss/mq/pm/jdbc PersistenceManager.java
Log:
Added a constructor
Revision Changes Path
1.7 +22 -16 jbossmq/src/main/org/jboss/mq/pm/jdbc/PersistenceManager.java
Index: PersistenceManager.java
===================================================================
RCS file:
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/pm/jdbc/PersistenceManager.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- PersistenceManager.java 2001/09/01 03:03:05 1.6
+++ PersistenceManager.java 2001/09/04 15:06:51 1.7
@@ -40,7 +40,7 @@
*
* @author: Jayesh Parayali ([EMAIL PROTECTED])
*
- * @version $Revision: 1.6 $
+ * @version $Revision: 1.7 $
*/
public class PersistenceManager extends ServiceMBeanSupport implements
PersistenceManagerMBean, org.jboss.mq.pm.PersistenceManager {
@@ -53,6 +53,12 @@
// Maps (Long)txIds to LinkedList of AddFile tasks
HashMap transactedTasks= new HashMap();
+
+ public PersistenceManager() throws javax.jms.JMSException
+ {
+ txManager = new TxManager(this);
+ }
+
static class LogInfo {
MessageLog log;
SpyDestination destination;
@@ -94,11 +100,11 @@
*/
public java.lang.String getJmsDBPoolName() {
return jmsDBPoolName;
- }
+ }
public String getName() {
return "JBossMQ-PersistenceManager";
- }
+ }
public void initService() throws Exception {
@@ -107,7 +113,7 @@
});
server.setPersistenceManager(this);
- }
+ }
/**
* Insert the method's description here.
@@ -116,7 +122,7 @@
*/
public void setJmsDBPoolName(java.lang.String newJmsDBPoolName) {
jmsDBPoolName= newJmsDBPoolName;
- }
+ }
public void startService() throws Exception {
@@ -136,7 +142,7 @@
});
restore(server);
- }
+ }
public void destroyQueue(SpyDestination dest) throws javax.jms.JMSException {
@@ -163,12 +169,12 @@
throw newE;
}
- }
+ }
public void initQueue(SpyDestination dest) throws javax.jms.JMSException {
try {
- MessageLog log= new MessageLog(dest.toString());
+ MessageLog log= new MessageLog(datasource, dest.toString());
LogInfo info= new LogInfo(log, dest);
synchronized (messageLogs) {
@@ -183,7 +189,7 @@
throw newE;
}
- }
+ }
public void add(org.jboss.mq.SpyMessage message, org.jboss.mq.pm.Tx txId) throws
javax.jms.JMSException {
LogInfo logInfo;
@@ -209,7 +215,7 @@
}
}
- }
+ }
public void commitPersistentTx(org.jboss.mq.pm.Tx txId) throws
javax.jms.JMSException {
@@ -226,7 +232,7 @@
}
txLog.commitTx(txId);
- }
+ }
public org.jboss.mq.pm.Tx createPersistentTx() throws javax.jms.JMSException {
org.jboss.mq.pm.Tx txId= txLog.createTx();
@@ -234,14 +240,14 @@
transactedTasks.put(txId, new LinkedList());
}
return txId;
- }
+ }
/**
* getTxManager method comment.
*/
public org.jboss.mq.pm.TxManager getTxManager() {
return txManager;
- }
+ }
public void remove(org.jboss.mq.SpyMessage message, org.jboss.mq.pm.Tx txId)
throws javax.jms.JMSException {
LogInfo logInfo;
@@ -267,7 +273,7 @@
}
}
- }
+ }
public void restore(org.jboss.mq.server.JMSServer server) throws
javax.jms.JMSException {
@@ -294,7 +300,7 @@
}
}
- }
+ }
public void rollbackPersistentTx(org.jboss.mq.pm.Tx txId) throws
javax.jms.JMSException {
@@ -311,5 +317,5 @@
}
txLog.rollbackTx(txId);
- }
+ }
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
