You are viewing a plain text version of this content. The canonical link for it is here.
Posted to scm@geronimo.apache.org by dj...@apache.org on 2004/01/19 07:29:08 UTC
cvs commit: incubator-geronimo/modules/core/src/java/org/apache/geronimo/transaction TransactionManagerProxy.java
djencks 2004/01/18 22:29:08
Modified: modules/core/src/java/org/apache/geronimo/connector/outbound/connectiontracking
ConnectionTrackingCoordinator.java
modules/core/src/java/org/apache/geronimo/transaction
TransactionManagerProxy.java
Log:
gbeanify
Revision Changes Path
1.4 +24 -1 incubator-geronimo/modules/core/src/java/org/apache/geronimo/connector/outbound/connectiontracking/ConnectionTrackingCoordinator.java
Index: ConnectionTrackingCoordinator.java
===================================================================
RCS file: /home/cvs/incubator-geronimo/modules/core/src/java/org/apache/geronimo/connector/outbound/connectiontracking/ConnectionTrackingCoordinator.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- ConnectionTrackingCoordinator.java 1 Jan 2004 09:55:08 -0000 1.3
+++ ConnectionTrackingCoordinator.java 19 Jan 2004 06:29:08 -0000 1.4
@@ -68,6 +68,10 @@
import org.apache.geronimo.connector.outbound.ConnectionInfo;
import org.apache.geronimo.connector.outbound.ConnectorTransactionContext;
import org.apache.geronimo.kernel.service.GeronimoMBeanInfo;
+import org.apache.geronimo.gbean.GBeanInfo;
+import org.apache.geronimo.gbean.GBeanInfoFactory;
+import org.apache.geronimo.gbean.GAttributeInfo;
+import org.apache.geronimo.gbean.GOperationInfo;
/**
* ConnectionTrackingCoordinator tracks connections that are in use by
@@ -87,6 +91,8 @@
*/
public class ConnectionTrackingCoordinator implements TrackedConnectionAssociator, ConnectionTracker {
+ private final static GBeanInfo GBEAN_INFO;
+
private final ThreadLocal currentConnectorComponentContexts = new ThreadLocal();
private final ThreadLocal currentConnectorTransactionContexts = new ThreadLocal();
private final ThreadLocal currentUnshareableResources = new ThreadLocal();
@@ -173,6 +179,23 @@
public ConnectorTransactionContext getConnectorTransactionContext() {
return (ConnectorTransactionContext) currentConnectorTransactionContexts.get();
+ }
+
+ static {
+ GBeanInfoFactory infoFactory = new GBeanInfoFactory(ConnectionTrackingCoordinator.class.getName());
+ infoFactory.addOperation(new GOperationInfo("enter", new String[] {ConnectorComponentContext.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("exit", new String[] {ConnectorComponentContext.class.getName(), Set.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("setConnectorTransactionContext", new String[] {ConnectorTransactionContext.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("setUnshareableResources", new String[] {Set.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("resetConnectorTransactionContext", new String[] {ConnectorTransactionContext.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("handleObtained", new String[] {ConnectionTrackingInterceptor.class.getName(), ConnectionInfo.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("handleReleased",new String[] {ConnectionTrackingInterceptor.class.getName(), ConnectionInfo.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("getConnectorTransactionContext"));
+ GBEAN_INFO = infoFactory.getBeanInfo();
+ }
+
+ public static GBeanInfo getGBeanInfo() {
+ return GBEAN_INFO;
}
public static GeronimoMBeanInfo getGeronimoMBeanInfo() {
1.4 +28 -4 incubator-geronimo/modules/core/src/java/org/apache/geronimo/transaction/TransactionManagerProxy.java
Index: TransactionManagerProxy.java
===================================================================
RCS file: /home/cvs/incubator-geronimo/modules/core/src/java/org/apache/geronimo/transaction/TransactionManagerProxy.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- TransactionManagerProxy.java 17 Nov 2003 00:46:09 -0000 1.3
+++ TransactionManagerProxy.java 19 Jan 2004 06:29:08 -0000 1.4
@@ -68,7 +68,9 @@
import javax.transaction.xa.XAException;
import javax.transaction.xa.Xid;
-import org.apache.geronimo.connector.work.GeronimoWorkManager;
+import org.apache.geronimo.gbean.GBeanInfo;
+import org.apache.geronimo.gbean.GBeanInfoFactory;
+import org.apache.geronimo.gbean.GOperationInfo;
import org.apache.geronimo.kernel.service.GeronimoMBeanInfo;
import org.apache.geronimo.transaction.manager.TransactionManagerImpl;
@@ -81,6 +83,9 @@
* @version $Revision$ $Date$
*/
public class TransactionManagerProxy implements TransactionManager, XATerminator {
+
+ private static final GBeanInfo GBEAN_INFO;
+
private final TransactionManager delegate;
private final ThreadLocal threadTx = new ThreadLocal();
@@ -199,7 +204,26 @@
public void rollback(Xid arg0) throws XAException {
throw new XAException("Not implemented.");
}
-
+
+ //for now we use the default constructor.
+ static {
+ GBeanInfoFactory infoFactory = new GBeanInfoFactory(TransactionManagerProxy.class.getName());
+ infoFactory.addOperation(new GOperationInfo("setTransactionTimeout", new String[] {Integer.TYPE.getName()}));
+ infoFactory.addOperation(new GOperationInfo("begin"));
+ infoFactory.addOperation(new GOperationInfo("getStatus"));
+ infoFactory.addOperation(new GOperationInfo("getTransaction"));
+ infoFactory.addOperation(new GOperationInfo("suspend"));
+ infoFactory.addOperation(new GOperationInfo("resume", new String[] {Transaction.class.getName()}));
+ infoFactory.addOperation(new GOperationInfo("commit"));
+ infoFactory.addOperation(new GOperationInfo("rollback"));
+ infoFactory.addOperation(new GOperationInfo("setRollbackOnly"));
+ GBEAN_INFO = infoFactory.getBeanInfo();
+ }
+
+ public static GBeanInfo getGBeanInfo() {
+ return GBEAN_INFO;
+ }
+
/**
* Provides the GeronimoMBean description for this class
* @return
@@ -211,5 +235,5 @@
rc.addOperationsDeclaredIn(XATerminator.class);
return rc;
}
-
+
}