svn commit: r365402 - /webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/j2ee/Mediator.java

[dasarath]

Author: dasarath
Date: Mon Jan  2 11:18:52 2006
New Revision: 365402

URL: http://svn.apache.org/viewcvs?rev=365402&view=rev
Log: (empty)

Modified:
    
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/j2ee/Mediator.java

Modified: 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/j2ee/Mediator.java
URL: 
http://svn.apache.org/viewcvs/webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/j2ee/Mediator.java?rev=365402&r1=365401&r2=365402&view=diff
==============================================================================
--- 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/j2ee/Mediator.java
 (original)
+++ 
webservices/kandula/branches/Kandula_1/src/java/org/apache/ws/transaction/j2ee/Mediator.java
 Mon Jan  2 11:18:52 2006
@@ -17,13 +17,13 @@
 import org.apache.geronimo.transaction.manager.TransactionManagerImpl;
 import org.apache.ws.transaction.coordinator.CoordinationContext;
 import org.apache.ws.transaction.coordinator.at.AT2PCStatus;
-import org.apache.ws.transaction.coordinator.at.BasicParticipant;
+import org.apache.ws.transaction.coordinator.at.AbstractParticipant;
 
 /**
  * @author Dasarath Weeratunge
  *  
  */
-public class Mediator extends BasicParticipant implements NamedXAResource {
+public class Mediator extends AbstractParticipant implements NamedXAResource {
 
        private int timeout = Integer.MAX_VALUE;
 
@@ -31,15 +31,15 @@
 
        private Transaction tx;
 
-       private Bridge bridge = Bridge.getInstance();
+       private static Bridge bridge = Bridge.getInstance();
 
-       private TransactionManagerImpl tm = (TransactionManagerImpl) 
bridge.getTM();
+       private static TransactionManagerImpl tm = (TransactionManagerImpl) 
bridge.getTM();
 
        private boolean bridged = true;
 
        public Mediator(Transaction tx, CoordinationContext ctx)
                        throws RemoteException {
-               super(true, ctx);
+               register(true, ctx);
                id = ctx.getIdentifier().toString();
                this.tx = tx;
                try {
@@ -111,27 +111,27 @@
        public void start(Xid arg0, int arg1) throws XAException {
        }
 
-       protected int prepare() throws XAException {
+       public int prepare() throws XAException {
                forget();
                return tm.prepare(tx);
        }
 
-       protected void commit() throws XAException {
+       public void commit() throws XAException {
                tm.commit(tx, false);
        }
 
-       protected void rollback() throws XAException {
+       public void rollback() throws XAException {
                tm.rollback(tx);
        }
 
-       protected void forget() {
+       public void forget() {
                if (bridged) {
                        bridge.forget(id);
                        bridged = false;
                }
        }
 
-       protected int getStatus() {
+       public int getStatus() {
                try {
                        switch (tm.getStatus()) {
                        case Status.STATUS_ACTIVE:
@@ -164,4 +164,5 @@
                        throw new RuntimeException(e);
                }
        }
+
 }



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]