Mail Archive Home | gotm-commits List | August 2005 Index
| <-- Date Index --> | <-- Thread Index --> |
Date: Tuesday, August 16, 2005 @ 15:36:19
Author: rouvoy
Path: /cvsroot/gotm/gotm-jts
Added: src/fractal/org/objectweb/gotm/lib/CurrentManager2PC.fractal
Modified: examples/benchmark/build.xml
examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java
examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java
examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java
src/java/org/objectweb/gotm/lib/JtsFactory.java
src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java
src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java
* cleanup of project source code,
* correcting bad definition name in the HOWL logger component definition,
* removing fractal lifecycle interceptor generation,
* moving event bus subscription from initFc() callback to startFc() callback,
* updating benchmark parameters,
* cosmetic updates
---------------------------------------------------------------------------+
examples/benchmark/build.xml |
4
examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java |
14 +-
examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java |
14 +-
examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java |
14 +-
src/fractal/org/objectweb/gotm/lib/CurrentManager2PC.fractal |
21 ++++
src/java/org/objectweb/gotm/lib/JtsFactory.java |
15 ++
src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java |
52 +++++-----
src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java |
30 ++---
8 files changed, 97 insertions(+), 67 deletions(-)
Index: gotm-jts/examples/benchmark/build.xml
diff -u gotm-jts/examples/benchmark/build.xml:1.4
gotm-jts/examples/benchmark/build.xml:1.5
--- gotm-jts/examples/benchmark/build.xml:1.4 Fri Aug 12 14:31:26 2005
+++ gotm-jts/examples/benchmark/build.xml Tue Aug 16 15:36:19 2005
@@ -21,7 +21,7 @@
<!-- Initial developer(s): Romain Rouvoy. -->
<!-- Contributor(s): ______________________________________. -->
-<!-- $Id: build.xml,v 1.4 2005/08/12 12:31:26 rouvoy Exp $ -->
+<!-- $Id: build.xml,v 1.5 2005/08/16 13:36:19 rouvoy Exp $ -->
<!-- ==================================================================== -->
<project name="JTS Benchmark" default="all">
@@ -76,8 +76,8 @@
<target name="execute" depends="import"
description="execute All Benchmarks">
<property name="imported" value="true"/>
- <antcall target="execute-2pc"/>
<antcall target="execute-apc"/>
+ <antcall target="execute-2pc"/>
<antcall target="execute-jts"/>
</target>
Index:
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java
diff -u
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java:1.2
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java:1.3
---
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java:1.2
Fri Aug 12 14:31:26 2005
+++
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/Benchmark2PC.java
Tue Aug 16 15:36:19 2005
@@ -22,7 +22,7 @@
Contributor(s): ______________________________________.
---------------------------------------------------------------------
- $Id: Benchmark2PC.java,v 1.2 2005/08/12 12:31:26 rouvoy Exp $
+ $Id: Benchmark2PC.java,v 1.3 2005/08/16 13:36:19 rouvoy Exp $
====================================================================*/
package org.objectweb.benchmark.jts;
@@ -46,8 +46,8 @@
/**
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 3 janv. 2005
- * @modified $Date: 2005/08/12 12:31:26 $
- * @version $Revision: 1.2 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.3 $
* @fractal.itf name="runnable" signature="java.lang.Runnable"
*/
public class Benchmark2PC
@@ -56,13 +56,13 @@
/** <code>MIN</code> . */
public static int MIN = 0 ;
/** <code>MAX</code> . */
- public static int MAX = 60 ;
+ public static int MAX = 50 ;
/** <code>STEP</code> . */
- public static int STEP = 2 ;
+ public static int STEP = 1 ;
/** <code>WARM</code> . */
- public static int WARM = 1 ;
+ public static int WARM = 2 ;
/** <code>BENCH</code> . */
- public static int BENCH = 10 ;
+ public static int BENCH = 20 ;
/*
Index:
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java
diff -u
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java:1.2
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java:1.3
---
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java:1.2
Fri Aug 12 14:31:26 2005
+++
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkAPC.java
Tue Aug 16 15:36:19 2005
@@ -22,7 +22,7 @@
Contributor(s): ______________________________________.
---------------------------------------------------------------------
- $Id: BenchmarkAPC.java,v 1.2 2005/08/12 12:31:26 rouvoy Exp $
+ $Id: BenchmarkAPC.java,v 1.3 2005/08/16 13:36:19 rouvoy Exp $
====================================================================*/
package org.objectweb.benchmark.jts;
@@ -46,21 +46,21 @@
/**
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 3 janv. 2005
- * @modified $Date: 2005/08/12 12:31:26 $
- * @version $Revision: 1.2 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.3 $
* @fractal.itf name="runnable" signature="java.lang.Runnable"
*/
public class BenchmarkAPC
extends LoggablePrimitive
implements Runnable {
/** <code>MIN</code> . */
- public static int ITER = 150 ;
+ public static int ITER = 200 ;
/** <code>STEP</code> . */
- public static int STEP = 15 ;
+ public static int STEP = 10 ;
/** <code>WARM</code> . */
- public static int WARM = 0 ;
+ public static int WARM = 1 ;
/** <code>BENCH</code> . */
- public static int BENCH = 2 ;
+ public static int BENCH = 4 ;
/*
* (non-Javadoc)
Index:
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java
diff -u
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java:1.2
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java:1.3
---
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java:1.2
Fri Aug 12 14:31:26 2005
+++
gotm-jts/examples/benchmark/src/java/org/objectweb/benchmark/jts/BenchmarkJTS.java
Tue Aug 16 15:36:19 2005
@@ -22,7 +22,7 @@
Contributor(s): ______________________________________.
---------------------------------------------------------------------
- $Id: BenchmarkJTS.java,v 1.2 2005/08/12 12:31:26 rouvoy Exp $
+ $Id: BenchmarkJTS.java,v 1.3 2005/08/16 13:36:19 rouvoy Exp $
====================================================================*/
package org.objectweb.benchmark.jts;
@@ -50,8 +50,8 @@
/**
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 3 janv. 2005
- * @modified $Date: 2005/08/12 12:31:26 $
- * @version $Revision: 1.2 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.3 $
* @fractal.itf name="runnable" signature="java.lang.Runnable"
*/
public class BenchmarkJTS
@@ -64,9 +64,9 @@
/** <code>STEP</code> . */
public static int STEP = 1 ;
/** <code>WARM</code> . */
- public static int WARM = 10 ;
+ public static int WARM = 1000 ;
/** <code>BENCH</code> . */
- public static int BENCH = 1000 ;
+ public static int BENCH = 3000 ;
/*
@@ -98,10 +98,10 @@
new TransactionScenarioCommit("commit"),
new TransactionScenarioRollback("abort")});
scenario = new Benchmark(scenario, new VisitorAvg(), WARM, BENCH);
- scenario = new ConfigurationIterator(scenario, new
SynchronizationIteratable(
- MIN, MAX, STEP));
scenario = new ConfigurationIterator(scenario, tmi, new
VisitorRename(
(Rename) tmi));
+ scenario = new ConfigurationIterator(scenario, new
SynchronizationIteratable(
+ MIN, MAX, STEP));
System.out.println("[JTS] Running Scenarios...");
try {
Index: gotm-jts/src/fractal/org/objectweb/gotm/lib/CurrentManager2PC.fractal
diff -u /dev/null
gotm-jts/src/fractal/org/objectweb/gotm/lib/CurrentManager2PC.fractal:1.1
--- /dev/null Tue Aug 16 15:36:19 2005
+++ gotm-jts/src/fractal/org/objectweb/gotm/lib/CurrentManager2PC.fractal
Tue Aug 16 15:36:19 2005
@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="ISO-8859-1" ?>
+<!DOCTYPE definition PUBLIC
+ "-//objectweb.org//DTD Fractal ADL 2.0//EN"
+ "classpath://org/objectweb/fractal/adl/xml/standard.dtd">
+
+<definition name="org.objectweb.gotm.lib.AdaptiveCurrentManager"
+ extends="org.objectweb.gotm.lib.current.CurrentManager">
+ <interface name="configuration" role="client" signature="java.util.Map"/>
+
+ <component name="FcCurrent"
+
definition="org.objectweb.gotm.lib.current.CurrentManagerAdaptive(org.objectweb.gotm.lib.JtsTransaction)"/>
+ <component name="Fc2PcProbe"
+
definition="org.objectweb.gotm.lib.coordination.FcProbeCommitProtocol"/>
+
+ <binding client="this.current-manager"
+ server="FcCurrent.current-manager"/>
+ <binding client="FcCurrent.probe"
+ server="Fc2PcProbe.probe"/>
+ <binding client="FcCurrent.configuration"
+ server="this.configuration"/>
+</definition>
\ No newline at end of file
Index: gotm-jts/src/java/org/objectweb/gotm/lib/JtsFactory.java
diff -u gotm-jts/src/java/org/objectweb/gotm/lib/JtsFactory.java:1.3
gotm-jts/src/java/org/objectweb/gotm/lib/JtsFactory.java:1.4
--- gotm-jts/src/java/org/objectweb/gotm/lib/JtsFactory.java:1.3 Fri
Aug 12 14:31:26 2005
+++ gotm-jts/src/java/org/objectweb/gotm/lib/JtsFactory.java Tue Aug 16
15:36:19 2005
@@ -23,7 +23,7 @@
Contributor(s): .
---------------------------------------------------------------------
-$Id: JtsFactory.java,v 1.3 2005/08/12 12:31:26 rouvoy Exp $
+$Id: JtsFactory.java,v 1.4 2005/08/16 13:36:19 rouvoy Exp $
====================================================================*/
package org.objectweb.gotm.lib;
@@ -37,8 +37,8 @@
/**
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 11 juil. 2005
- * @modified $Date: 2005/08/12 12:31:26 $
- * @version $Revision: 1.3 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.4 $
*/
public class JtsFactory {
/** <code>DEFAULT_ADL</code> . */
@@ -64,6 +64,15 @@
}
/**
+ * @param context
+ * @param itf
+ * @return an instance of transaction manager.
+ */
+ public static final Object create(Map context, String itf) {
+ return GotmFactory.create(DEFAULT_ADL, context, itf);
+ }
+
+ /**
* Stops the transaction manager.
* @param tm the transaction manager to stop.
*/
Index: gotm-jts/src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java
diff -u
gotm-jts/src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java:1.12
gotm-jts/src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java:1.13
--- gotm-jts/src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java:1.12
Mon Aug 8 15:30:05 2005
+++ gotm-jts/src/java/org/objectweb/gotm/lib/jta/TransactionImpl.java Tue
Aug 16 15:36:19 2005
@@ -22,7 +22,7 @@
Contributor(s): ______________________________________.
---------------------------------------------------------------------
- $Id: TransactionImpl.java,v 1.12 2005/08/08 13:30:05 rouvoy Exp $
+ $Id: TransactionImpl.java,v 1.13 2005/08/16 13:36:19 rouvoy Exp $
====================================================================*/
package org.objectweb.gotm.lib.jta;
@@ -57,8 +57,8 @@
* Adapter for the Java Transaction API (JTA).
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 24 déc. 2004
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.12 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.13 $
* @fractal.itf name="transaction" signature="javax.transaction.Transaction"
* @fractal.itf name="user-transaction"
signature="javax.transaction.UserTransaction"
* @fractal.itf name="commit" role="client"
signature="org.objectweb.transaction.api.coordination.CoordinationFeature"
@@ -105,28 +105,28 @@
/**
* @return the commit coordination process.
*/
- protected final CoordinationFeature getTxCommit() {
+ protected final CoordinationFeature fcCommit() {
return (CoordinationFeature) fcBindings.get(COMMIT);
}
/**
* @return the commit coordination process.
*/
- protected final CoordinationFeature getTxCommitOne() {
+ protected final CoordinationFeature fcCommitOne() {
return (CoordinationFeature) fcBindings.get(COMMIT_ONE);
}
/**
* @return the rollback coordination process.
*/
- protected final CoordinationFeature getTxRollback() {
+ protected final CoordinationFeature fcRollback() {
return (CoordinationFeature) fcBindings.get(ROLLBACK);
}
/**
* @return Returns the txState.
*/
- protected final TransactionState getTxState() {
+ protected final TransactionState fcTxState() {
return (TransactionState) fcBindings
.get(TransactionState.TRANSACTION_STATE);
}
@@ -134,25 +134,25 @@
/**
* @return Returns the syncEnlist.
*/
- protected final ResourceManager getSynchronization() {
+ protected final ResourceManager fcSynchronization() {
return (ResourceManager) fcBindings.get(SYNCHRONIZATION);
}
/**
* @return Returns the resEnlist.
*/
- protected final ResourceManager getResource() {
+ protected final ResourceManager fcResource() {
return (ResourceManager) fcBindings.get(RESOURCE);
}
/**
* @return Returns the event converter.
*/
- protected final EventConverter getStatusConverter() {
+ protected final EventConverter fcStatusHelper() {
return (EventConverter) fcBindings.get(STATUS_CONVERTER);
}
- protected final TimeoutAttribute getTimeout() {
+ protected final TimeoutAttribute timeout() {
return (TimeoutAttribute) fcBindings
.get(TimeoutAttribute.TIMEOUT_ATTRIBUTE);
}
@@ -162,7 +162,7 @@
*/
public void commit() throws SecurityException, IllegalStateException,
RollbackException, HeuristicRollbackException {
try {
- getTxCommit().process(new HashMap());
+ fcCommit().execute(new HashMap());
} catch (InvalidTransitionException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -172,7 +172,7 @@
getLogger().log(ERROR, e.getMessage());
throw new IllegalStateException(e);
}
- if (getTxState().checkStatus(TransactionStatusRolledBack.status))
+ if (fcTxState().checkStatus(TransactionStatusRolledBack.status))
throw new HeuristicRollbackException("Transaction has rolled
back.");
}
@@ -182,7 +182,7 @@
public boolean delistResource(XAResource arg0, int arg1)
throws IllegalStateException, SystemException {
try {
- getResource().delResource(arg0);
+ fcResource().delResource(arg0);
return true;
} catch (InvalidStateException e) {
if (getLogger().isLoggable(ERROR))
@@ -201,7 +201,7 @@
public boolean enlistResource(XAResource arg0)
throws IllegalStateException, SystemException, RollbackException
{
try {
- getResource().addResource(arg0);
+ fcResource().addResource(arg0);
return true;
} catch (InvalidStateException e) {
if (getLogger().isLoggable(ERROR))
@@ -210,7 +210,7 @@
TransactionStatusMarkedRollback.status,
TransactionStatusRolledBack.status,
TransactionStatusRollingBack.status };
- if (getTxState().checkStatus(rollback))
+ if (fcTxState().checkStatus(rollback))
throw new RollbackException(
"Transaction is marked for Rollback.");
throw new IllegalStateException(e);
@@ -226,7 +226,7 @@
*/
public int getStatus() throws SystemException {
try {
- return getStatusConverter().toValue(getTxState().getStatus());
+ return fcStatusHelper().toValue(fcTxState().getStatus());
} catch (InvalidTransitionException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -240,7 +240,7 @@
public void registerSynchronization(Synchronization arg0)
throws IllegalStateException, RollbackException, SystemException
{
try {
- getSynchronization().addResource(arg0);
+ fcSynchronization().addResource(arg0);
} catch (InvalidStateException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -248,7 +248,7 @@
TransactionStatusMarkedRollback.status,
TransactionStatusRolledBack.status,
TransactionStatusRollingBack.status };
- if (getTxState().checkStatus(rollback))
+ if (fcTxState().checkStatus(rollback))
throw new RollbackException(
"Transaction is marked for Rollback.");
throw new IllegalStateException(e);
@@ -264,7 +264,7 @@
*/
public void rollback() throws IllegalStateException {
try {
- getTxRollback().process(new HashMap());
+ fcRollback().execute(new HashMap());
} catch (InvalidTransitionException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -277,7 +277,7 @@
*/
public void setRollbackOnly() throws IllegalStateException {
try {
- getTxState().setStatus(TransactionStatusMarkedRollback.status);
+ fcTxState().setStatus(TransactionStatusMarkedRollback.status);
} catch (InvalidTransitionException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -290,7 +290,7 @@
*/
public void begin() throws NotSupportedException {
try {
-
getTxState().setStatus(TransactionStatusTransactionActive.status);
+ fcTxState().setStatus(TransactionStatusTransactionActive.status);
} catch (InvalidTransitionException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -303,7 +303,7 @@
*/
public void setTransactionTimeout(int arg0) throws SystemException {
try {
- getTimeout().setTimeout(arg0);
+ timeout().setTimeout(arg0);
} catch (InvalidStateException e) {
if (getLogger().isLoggable(ERROR))
getLogger().log(ERROR, e.getMessage());
@@ -319,8 +319,8 @@
public void suspend() {
if (getLogger().isLoggable(DEBUG))
getLogger().log(DEBUG, "Suspending the transaction...");
- tx_status = getTxState().getStatus();
- getTxState().setStatus(TransactionStatusTransactionInactive.status);
+ tx_status = fcTxState().getStatus();
+ fcTxState().setStatus(TransactionStatusTransactionInactive.status);
}
/* (non-Javadoc)
@@ -329,7 +329,7 @@
public void resume() {
if (getLogger().isLoggable(DEBUG))
getLogger().log(DEBUG, "Resuming the transaction...");
- getTxState().setStatus(tx_status);
+ fcTxState().setStatus(tx_status);
tx_status = null;
}
}
\ No newline at end of file
Index:
gotm-jts/src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java
diff -u
gotm-jts/src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java:1.4
gotm-jts/src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java:1.5
---
gotm-jts/src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java:1.4
Mon Aug 8 15:30:05 2005
+++
gotm-jts/src/java/org/objectweb/gotm/lib/jta/xa/XAResourceActionProvider.java
Tue Aug 16 15:36:19 2005
@@ -22,7 +22,7 @@
Contributor(s): ______________________________________.
---------------------------------------------------------------------
- $Id: XAResourceActionProvider.java,v 1.4 2005/08/08 13:30:05 rouvoy Exp $
+ $Id: XAResourceActionProvider.java,v 1.5 2005/08/16 13:36:19 rouvoy Exp $
====================================================================*/
package org.objectweb.gotm.lib.jta.xa;
@@ -58,8 +58,8 @@
* Implementation of the XA Resource specification.
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 3 janv. 2005
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.4 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.5 $
* @fractal.itf name="xa-action-provider"
* signature="org.objectweb.gotm.lib.resource.ActionProvider"
* @fractal.itf name="xid-provider" role="client"
@@ -143,8 +143,8 @@
* Implementation of the XA Start Action.
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 1 août 2005
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.4 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.5 $
* @fractal.itf
*/
private final class StartAction
@@ -177,8 +177,8 @@
* Implementation of the XA End Action.
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 1 août 2005
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.4 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.5 $
* @fractal.itf
*/
private final class EndAction
@@ -207,8 +207,8 @@
* Implementation of the XA Prepare Action.
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 1 août 2005
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.4 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.5 $
* @fractal.itf
*/
private final class PrepareAction
@@ -249,8 +249,8 @@
* Implementation of the XA Commit Action.
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 1 août 2005
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.4 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.5 $
* @fractal.itf
*/
private final class CommitAction
@@ -266,7 +266,7 @@
((XAResource) resource).commit(getXid(), true);
else
((XAResource) resource).commit(getXid(), false);
-
getCommitAckLog().log((resource.toString()+TransactionStatusCommitted.status.getLabel()).getBytes());
+
getCommitAckLog().log((resource.toString()+TransactionStatusCommitted.status.label()).getBytes());
}
}
@@ -274,8 +274,8 @@
* Implementation of the XA Rollback Action.
* @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
* @created 1 août 2005
- * @modified $Date: 2005/08/08 13:30:05 $
- * @version $Revision: 1.4 $
+ * @modified $Date: 2005/08/16 13:36:19 $
+ * @version $Revision: 1.5 $
* @fractal.itf
*/
private final class RollbackAction
@@ -288,7 +288,7 @@
*/
public void execute(Map context, Object resource) throws Exception {
((XAResource) resource).rollback(getXid());
-
getAbortAckLog().log((resource.toString()+TransactionStatusRolledBack.status.getLabel()).getBytes());
+
getAbortAckLog().log((resource.toString()+TransactionStatusRolledBack.status.label()).getBytes());
}
}
}
| <-- Date Index --> | <-- Thread Index --> |
Powered by MHonArc.
Copyright © 2006-2007, OW2 Consortium | contact | webmaster.