Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
JerryShea committed Dec 7, 2017
1 parent 8a07be3 commit 1263c2e
Showing 1 changed file with 4 additions and 4 deletions.
Expand Up @@ -738,7 +738,7 @@ class StoreAppenderContext implements DocumentContext {
boolean deferredHeader; boolean deferredHeader;
boolean padToCacheAlign = true; boolean padToCacheAlign = true;
private boolean metaData = false; private boolean metaData = false;
private boolean shouldRollback = false; private boolean rollbackOnClose = false;
@Nullable @Nullable
private Wire wire; private Wire wire;


Expand Down Expand Up @@ -778,8 +778,8 @@ public boolean isClosed() {
* rolled back when it is closed, rather than committed * rolled back when it is closed, rather than committed
*/ */
//@Override - uncomment when Wire released //@Override - uncomment when Wire released
public void setRollback() { public void rollbackOnClose() {
this.shouldRollback = true; this.rollbackOnClose = true;
} }


@Override @Override
Expand All @@ -791,7 +791,7 @@ public void close() {
} }


final boolean interrupted = Thread.currentThread().isInterrupted(); final boolean interrupted = Thread.currentThread().isInterrupted();
if (shouldRollback || interrupted) { if (rollbackOnClose || interrupted) {
if (interrupted) if (interrupted)
LOG.warn("Thread is interrupted. Can't guarantee complete message, so not committing"); LOG.warn("Thread is interrupted. Can't guarantee complete message, so not committing");
// zero out all contents... // zero out all contents...
Expand Down

0 comments on commit 1263c2e

Please sign in to comment.