Sha256: 11c2eff76a9365d34073879b10101d72b1f1291c0b86c9084e4d0287df183079

Contents?: true

Size: 566 Bytes

Versions: 88

Compression:

Stored size: 566 Bytes

Contents

package org.embulk.spi;

public class AbortTransactionResource
        implements AutoCloseable
{
    private Transactional tran;

    public AbortTransactionResource()
    {
        this(null);
    }

    public AbortTransactionResource(Transactional tran)
    {
        this.tran = tran;
    }

    public void abortThis(Transactional tran)
    {
        this.tran = tran;
    }

    public void dontAbort()
    {
        this.tran = null;
    }

    @Override
    public void close()
    {
        if (tran != null) {
            tran.abort();
        }
    }
}

Version data entries

88 entries across 88 versions & 1 rubygems

Version Path
embulk-0.8.39 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.39-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.38 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.38-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.37 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.37-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.36 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.36-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.35 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.35-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.34 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.34-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.33 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.33-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.32 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.32-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.31 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.31-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.30 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.30-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java