[jboss-svn-commits] JBL Code SVN: r37638 - in labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server: impl and 1 other directory.

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Thu Oct 20 11:21:15 EDT 2011


Author: tomjenkinson
Date: 2011-10-20 11:21:15 -0400 (Thu, 20 Oct 2011)
New Revision: 37638

Modified:
   labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/RemoteServer.java
   labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxySynchronization.java
   labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxyXAResource.java
   labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ServerImpl.java
Log:
JBTM-895 Renamed the methods on the RemoteServer interface to remove the word propagate

Modified: labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/RemoteServer.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/RemoteServer.java	2011-10-20 15:19:51 UTC (rev 37637)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/RemoteServer.java	2011-10-20 15:21:15 UTC (rev 37638)
@@ -52,7 +52,7 @@
 	 * @throws XAException
 	 * @throws DummyRemoteException
 	 */
-	public Xid[] propagateRecover(Integer callingServerNodeName) throws XAException, DummyRemoteException;
+	public Xid[] recoverFor(Integer callingServerNodeName) throws XAException, DummyRemoteException;
 
 	/**
 	 * Relay the propagate completion.
@@ -62,7 +62,7 @@
 	 * @throws SystemException
 	 * @throws DummyRemoteException
 	 */
-	public void propagateBeforeCompletion(Xid xid) throws XAException, SystemException, DummyRemoteException;
+	public void beforeCompletion(Xid xid) throws XAException, SystemException, DummyRemoteException;
 
 	/**
 	 * Relay a prepare to the remote side for a specific Xid.
@@ -72,7 +72,7 @@
 	 * @throws XAException
 	 * @throws DummyRemoteException
 	 */
-	public int propagatePrepare(Xid xid) throws XAException, DummyRemoteException;
+	public int prepare(Xid xid) throws XAException, DummyRemoteException;
 
 	/**
 	 * Relay the commit.
@@ -82,7 +82,7 @@
 	 * @throws XAException
 	 * @throws DummyRemoteException
 	 */
-	public void propagateCommit(Xid xid, boolean onePhase) throws XAException, DummyRemoteException;
+	public void commit(Xid xid, boolean onePhase) throws XAException, DummyRemoteException;
 
 	/**
 	 * Relay the rollback
@@ -91,7 +91,7 @@
 	 * @throws XAException
 	 * @throws DummyRemoteException
 	 */
-	public void propagateRollback(Xid xid) throws XAException, DummyRemoteException;
+	public void rollback(Xid xid) throws XAException, DummyRemoteException;
 
 	/**
 	 * Relay the forget.
@@ -100,6 +100,6 @@
 	 * @throws XAException
 	 * @throws DummyRemoteException
 	 */
-	public void propagateForget(Xid xid) throws XAException, DummyRemoteException;
+	public void forget(Xid xid) throws XAException, DummyRemoteException;
 
 }

Modified: labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxySynchronization.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxySynchronization.java	2011-10-20 15:19:51 UTC (rev 37637)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxySynchronization.java	2011-10-20 15:21:15 UTC (rev 37638)
@@ -52,7 +52,7 @@
 	public void beforeCompletion() {
 		System.out.println("ProxySynchronization (" + localServerName + ":" + remoteServerName + ") beforeCompletion");
 		try {
-			lookupProvider.lookup(remoteServerName).propagateBeforeCompletion(toRegisterAgainst);
+			lookupProvider.lookup(remoteServerName).beforeCompletion(toRegisterAgainst);
 		} catch (XAException e) {
 			e.printStackTrace();
 		} catch (SystemException e) {

Modified: labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxyXAResource.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxyXAResource.java	2011-10-20 15:19:51 UTC (rev 37637)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ProxyXAResource.java	2011-10-20 15:21:15 UTC (rev 37638)
@@ -148,7 +148,7 @@
 		}
 
 		try {
-			int propagatePrepare = lookupProvider.lookup(remoteServerName).propagatePrepare(xid);
+			int propagatePrepare = lookupProvider.lookup(remoteServerName).prepare(xid);
 			System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_PREPARED");
 			return propagatePrepare;
 		} catch (DummyRemoteException ce) {
@@ -161,7 +161,7 @@
 		System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_COMMIT  [" + xid + "]");
 
 		try {
-			lookupProvider.lookup(remoteServerName).propagateCommit(xid, onePhase);
+			lookupProvider.lookup(remoteServerName).commit(xid, onePhase);
 			System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_COMMITED");
 		} catch (DummyRemoteException ce) {
 			throw new XAException(XAException.XA_RETRY);
@@ -183,7 +183,7 @@
 		System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_ROLLBACK[" + xid + "]");
 
 		try {
-			lookupProvider.lookup(remoteServerName).propagateRollback(xid);
+			lookupProvider.lookup(remoteServerName).rollback(xid);
 			System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_ROLLBACKED");
 		} catch (DummyRemoteException ce) {
 			throw new XAException(XAException.XA_RETRY);
@@ -231,7 +231,7 @@
 		List<Xid> toReturn = new ArrayList<Xid>();
 		Xid[] recovered = null;
 		try {
-			recovered = lookupProvider.lookup(remoteServerName).propagateRecover(localServerName);
+			recovered = lookupProvider.lookup(remoteServerName).recoverFor(localServerName);
 		} catch (DummyRemoteException ce) {
 			throw new XAException(XAException.XA_RETRY);
 		}
@@ -278,7 +278,7 @@
 	public void forget(Xid xid) throws XAException {
 		System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_FORGET  [" + xid + "]");
 		try {
-			lookupProvider.lookup(remoteServerName).propagateForget(xid);
+			lookupProvider.lookup(remoteServerName).forget(xid);
 			System.out.println("     ProxyXAResource (" + localServerName + ":" + remoteServerName + ") XA_FORGETED[" + xid + "]");
 		} catch (DummyRemoteException ce) {
 			throw new XAException(XAException.XA_RETRY);

Modified: labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ServerImpl.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ServerImpl.java	2011-10-20 15:19:51 UTC (rev 37637)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/examples/classes/com/arjuna/jta/distributed/example/server/impl/ServerImpl.java	2011-10-20 15:21:15 UTC (rev 37638)
@@ -238,7 +238,7 @@
 	}
 
 	@Override
-	public int propagatePrepare(Xid xid) throws XAException, DummyRemoteException {
+	public int prepare(Xid xid) throws XAException, DummyRemoteException {
 		ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
 		try {
 			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
@@ -250,7 +250,7 @@
 	}
 
 	@Override
-	public void propagateCommit(Xid xid, boolean onePhase) throws XAException, DummyRemoteException {
+	public void commit(Xid xid, boolean onePhase) throws XAException, DummyRemoteException {
 		ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
 		try {
 			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
@@ -261,7 +261,7 @@
 	}
 
 	@Override
-	public void propagateRollback(Xid xid) throws XAException, DummyRemoteException {
+	public void rollback(Xid xid) throws XAException, DummyRemoteException {
 		ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
 		try {
 			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
@@ -272,7 +272,7 @@
 	}
 
 	@Override
-	public Xid[] propagateRecover(Integer parentNodeName) throws XAException, DummyRemoteException {
+	public Xid[] recoverFor(Integer parentNodeName) throws XAException, DummyRemoteException {
 		ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
 		try {
 			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
@@ -285,7 +285,7 @@
 	}
 
 	@Override
-	public void propagateForget(Xid xid) throws XAException, DummyRemoteException {
+	public void forget(Xid xid) throws XAException, DummyRemoteException {
 		ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
 		try {
 			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());
@@ -297,7 +297,7 @@
 	}
 
 	@Override
-	public void propagateBeforeCompletion(Xid xid) throws XAException, SystemException, DummyRemoteException {
+	public void beforeCompletion(Xid xid) throws XAException, SystemException, DummyRemoteException {
 		ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
 		try {
 			Thread.currentThread().setContextClassLoader(this.getClass().getClassLoader());



More information about the jboss-svn-commits mailing list