Package com.orientechnologies.orient.distributed.context

Class ODistributedMessageLogMemory

java.lang.Object

com.orientechnologies.orient.distributed.context.ODistributedMessageLogMemory

All Implemented Interfaces:

ODistributedMessageLog

public class ODistributedMessageLogMemory
extends Object
implements ODistributedMessageLog

Constructor Summary

Constructors

Constructor	Description
ODistributedMessageLogMemory()

Method Summary

Modifier and Type	Method	Description
void	cleanFrom(long[] status)	Remove from the log all the messages up to the provided status
void	log(ODistributedMessage message)	Log received message for eventually re-send to other nodes
List<ODistributedMessage>	recover(List<OTransactionId> ids)	Recover the messages with specified ids from the log.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ODistributedMessageLogMemory

public ODistributedMessageLogMemory()

Method Details

log

public void log(ODistributedMessage message)

Description copied from interface: ODistributedMessageLog

Log received message for eventually re-send to other nodes

Specified by:

log in interface ODistributedMessageLog

Parameters:

message - to log

recover

public List<ODistributedMessage> recover(List<OTransactionId> ids)

Description copied from interface: ODistributedMessageLog

Recover the messages with specified ids from the log. The current implementation just miss from the result the messages that cannot be found.

Specified by:

recover in interface ODistributedMessageLog

Parameters:

ids - of messages to search

Returns:

list of found messages

cleanFrom

public void cleanFrom(long[] status)

Description copied from interface: ODistributedMessageLog

Remove from the log all the messages up to the provided status

Specified by:

cleanFrom in interface ODistributedMessageLog

Parameters:

status - clean state to use as base