You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@batchee.apache.org by rm...@apache.org on 2014/07/23 18:18:25 UTC
git commit: BATCHEE-47 patch from Michael Edgar,
wrong logic in TransactionalWriter
Repository: incubator-batchee
Updated Branches:
refs/heads/master 0ae8e5289 -> ee06d5cef
BATCHEE-47 patch from Michael Edgar, wrong logic in TransactionalWriter
Project: http://git-wip-us.apache.org/repos/asf/incubator-batchee/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-batchee/commit/ee06d5ce
Tree: http://git-wip-us.apache.org/repos/asf/incubator-batchee/tree/ee06d5ce
Diff: http://git-wip-us.apache.org/repos/asf/incubator-batchee/diff/ee06d5ce
Branch: refs/heads/master
Commit: ee06d5cef2c619fafe904af76c690ba87f68ebdd
Parents: 0ae8e52
Author: Romain Manni-Bucau <rm...@gmail.com>
Authored: Wed Jul 23 18:18:10 2014 +0200
Committer: Romain Manni-Bucau <rm...@gmail.com>
Committed: Wed Jul 23 18:18:10 2014 +0200
----------------------------------------------------------------------
.../org/apache/batchee/extras/transaction/TransactionalWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-batchee/blob/ee06d5ce/extensions/extras/src/main/java/org/apache/batchee/extras/transaction/TransactionalWriter.java
----------------------------------------------------------------------
diff --git a/extensions/extras/src/main/java/org/apache/batchee/extras/transaction/TransactionalWriter.java b/extensions/extras/src/main/java/org/apache/batchee/extras/transaction/TransactionalWriter.java
index fa1d703..494d949 100644
--- a/extensions/extras/src/main/java/org/apache/batchee/extras/transaction/TransactionalWriter.java
+++ b/extensions/extras/src/main/java/org/apache/batchee/extras/transaction/TransactionalWriter.java
@@ -106,7 +106,7 @@ public class TransactionalWriter extends Writer {
private StringBuilder buffer() {
StringBuilder buffer = StringBuilder.class.cast(Synchronizations.get(bufferKey));
- if (buffer != null) {
+ if (buffer == null) {
buffer = new StringBuilder();
Synchronizations.put(bufferKey, buffer);
Synchronizations.registerSynchronization(new SynchronizationService.OnCommit() {