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.29 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.29-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.28 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.28-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.27 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.27-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.26 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.26-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.25 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.25-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.24 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.24-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.23 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.23-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.22 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.22-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.21 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.21-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.20 embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java
embulk-0.8.20-java embulk-core/src/main/java/org/embulk/spi/AbortTransactionResource.java