[jboss-svn-commits] JBL Code SVN: r37637 - in labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed: server and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Thu Oct 20 11:19:51 EDT 2011
Author: tomjenkinson
Date: 2011-10-20 11:19:51 -0400 (Thu, 20 Oct 2011)
New Revision: 37637
Modified:
labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/SimpleIsolatedServers.java
labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/RemoteServer.java
labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxySynchronization.java
labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxyXAResource.java
labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/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/tests/classes/com/arjuna/ats/jta/distributed/SimpleIsolatedServers.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/SimpleIsolatedServers.java 2011-10-20 15:07:30 UTC (rev 37636)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/SimpleIsolatedServers.java 2011-10-20 15:19:51 UTC (rev 37637)
@@ -122,18 +122,18 @@
// transactions so we pass in our node name instead and call recover in
// a single scan
// to put it another way, the test used to say:
- // lookupProvider.lookup(2000).propagateRecover(1000, TMSTARTSCAN);
- // lookupProvider.lookup(2000).propagateRecover(3000, TMSTARTSCAN);
- // lookupProvider.lookup(2000).propagateRecover(3000, TMENDSCAN);
- // lookupProvider.lookup(2000).propagateRecover(1000, TMENDSCAN);
+ // lookupProvider.lookup(2000).recoverFor(1000, TMSTARTSCAN);
+ // lookupProvider.lookup(2000).recoverFor(3000, TMSTARTSCAN);
+ // lookupProvider.lookup(2000).recoverFor(3000, TMENDSCAN);
+ // lookupProvider.lookup(2000).recoverFor(1000, TMENDSCAN);
// That second call to TMSTARTSCAN would fail
{
// Simulates a remote call *from* node 1000 *to* node 2000
- lookupProvider.lookup(2000).propagateRecover(1000);
+ lookupProvider.lookup(2000).recoverFor(1000);
}
{
// Simulates a remote call *from* node 3000 *to* node 2000
- lookupProvider.lookup(2000).propagateRecover(3000);
+ lookupProvider.lookup(2000).recoverFor(3000);
}
}
Modified: labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/RemoteServer.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/RemoteServer.java 2011-10-20 15:07:30 UTC (rev 37636)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/RemoteServer.java 2011-10-20 15:19:51 UTC (rev 37637)
@@ -29,16 +29,16 @@
public void setOffline(boolean offline);
- public int propagatePrepare(Xid xid) throws XAException, DummyRemoteException;
+ public int prepare(Xid xid) throws XAException, DummyRemoteException;
- public void propagateCommit(Xid xid, boolean onePhase) throws XAException, DummyRemoteException;
+ public void commit(Xid xid, boolean onePhase) throws XAException, DummyRemoteException;
- public void propagateRollback(Xid xid) throws XAException, DummyRemoteException;
+ public void rollback(Xid xid) throws XAException, DummyRemoteException;
- public Xid[] propagateRecover(Integer parentNodeName) throws XAException, DummyRemoteException;
+ public Xid[] recoverFor(Integer parentNodeName) throws XAException, DummyRemoteException;
- public void propagateForget(Xid xid) throws XAException, DummyRemoteException;
+ public void forget(Xid xid) throws XAException, DummyRemoteException;
- public void propagateBeforeCompletion(Xid xid) throws XAException, SystemException, DummyRemoteException;
+ public void beforeCompletion(Xid xid) throws XAException, SystemException, DummyRemoteException;
}
Modified: labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxySynchronization.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxySynchronization.java 2011-10-20 15:07:30 UTC (rev 37636)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxySynchronization.java 2011-10-20 15:19:51 UTC (rev 37637)
@@ -47,7 +47,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/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxyXAResource.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxyXAResource.java 2011-10-20 15:07:30 UTC (rev 37636)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ProxyXAResource.java 2011-10-20 15:19:51 UTC (rev 37637)
@@ -153,7 +153,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) {
@@ -166,7 +166,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);
@@ -191,7 +191,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);
@@ -242,7 +242,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);
}
@@ -289,7 +289,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/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ServerImpl.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ServerImpl.java 2011-10-20 15:07:30 UTC (rev 37636)
+++ labs/jbosstm/branches/JBOSSTS_4_15_0_Final/atsintegration/tests/classes/com/arjuna/ats/jta/distributed/server/impl/ServerImpl.java 2011-10-20 15:19:51 UTC (rev 37637)
@@ -346,7 +346,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());
@@ -358,7 +358,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());
@@ -369,7 +369,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());
@@ -380,7 +380,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());
@@ -392,7 +392,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());
@@ -404,7 +404,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