Class ODistributedMessageLogMemory
java.lang.Object
com.orientechnologies.orient.distributed.context.ODistributedMessageLogMemory
- All Implemented Interfaces:
ODistributedMessageLog
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcleanFrom(long[] status) Remove from the log all the messages up to the provided statusvoidlog(ODistributedMessage message) Log received message for eventually re-send to other nodesrecover(List<OTransactionId> ids) Recover the messages with specified ids from the log.
-
Constructor Details
-
ODistributedMessageLogMemory
public ODistributedMessageLogMemory()
-
-
Method Details
-
log
Description copied from interface:ODistributedMessageLogLog received message for eventually re-send to other nodes- Specified by:
login interfaceODistributedMessageLog- Parameters:
message- to log
-
recover
Description copied from interface:ODistributedMessageLogRecover the messages with specified ids from the log. The current implementation just miss from the result the messages that cannot be found.- Specified by:
recoverin interfaceODistributedMessageLog- Parameters:
ids- of messages to search- Returns:
- list of found messages
-
cleanFrom
public void cleanFrom(long[] status) Description copied from interface:ODistributedMessageLogRemove from the log all the messages up to the provided status- Specified by:
cleanFromin interfaceODistributedMessageLog- Parameters:
status- clean state to use as base
-