1 18 package org.apache.activemq.store; 19 20 import java.io.IOException ; 21 22 import org.apache.activemq.Service; 23 import org.apache.activemq.command.TransactionId; 24 25 26 32 public interface TransactionStore extends Service { 33 34 public void prepare(TransactionId txid) throws IOException ; 35 public void commit(TransactionId txid, boolean wasPrepared) throws IOException ; 36 public void rollback(TransactionId txid) throws IOException ; 37 public void recover(TransactionRecoveryListener listener) throws IOException ; 38 39 } 40 | Popular Tags |