org.joyqueue.store.transaction

接口 TransactionStore

public interface TransactionStore

缓存事务消息的可靠存储

方法概要

限定符和类型	方法和说明
Future<WriteResult>	asyncWrite(int id, ByteBuffer... messages) 异步写入消息，线程安全，保证ACID(写入磁盘)
int[]	list() 列出所有进行中的事务ID
int	next() 获取下一个事务ID
Iterator<ByteBuffer>	readIterator(int id) 获取读取的迭代器。
boolean	remove(int id) 删除事务

方法详细资料

next

int next()

获取下一个事务ID

list

int[] list()

列出所有进行中的事务ID

返回:

返回从小到大有序的事务ID

remove

boolean remove(int id)

删除事务

asyncWrite

Future<WriteResult> asyncWrite(int id,
                               ByteBuffer... messages)

异步写入消息，线程安全，保证ACID(写入磁盘)

参数:

id - 事务id

messages - 消息

返回:

以Future形式返回结果

另请参阅:

WriteResult

readIterator

Iterator<ByteBuffer> readIterator(int id)
                           throws IOException

获取读取的迭代器。 迭代器内包含获取迭代器时store包含的消息。 注意：迭代器无法读取到获取迭代器之后新写入的消息。

参数:

id - 事务ID

返回:

事务迭代器，如果事务不存在则返回null

抛出:

IOException