| 程序包 | 说明 |
|---|---|
| org.joyqueue.store | |
| org.joyqueue.store.transaction |
| 限定符和类型 | 方法和说明 |
|---|---|
Future<WriteResult> |
PartitionGroupStore.asyncWrite(WriteRequest... writeRequests)
异步写入消息,线程安全,保证ACI,D的保证取决于WriteQosLevel
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
PartitionGroupStore.asyncWrite(EventListener<WriteResult> eventListener,
WriteRequest... writeRequests)
异步写入消息,线程安全,保证ACI,D的保证取决于WriteQosLevel
|
| 限定符和类型 | 方法和说明 |
|---|---|
Future<WriteResult> |
TransactionStore.asyncWrite(int id,
ByteBuffer... messages)
异步写入消息,线程安全,保证ACID(写入磁盘)
|
Copyright © 2020 Joyqueue Community. All rights reserved.