Package com.orientechnologies.orient.distributed.context

Interface ODistributedMessageLog

All Known Implementing Classes:
ODistributedMessageLogMemory
public interface ODistributedMessageLog

  • 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.

  • Method Details

    • log

      void log(ODistributedMessage message)
      Log received message for eventually re-send to other nodes
      Parameters:
      message - to log

    • recover

      List<ODistributedMessage> recover(List<OTransactionId> ids)
      Recover the messages with specified ids from the log. The current implementation just miss from the result the messages that cannot be found.
      Parameters:
      ids - of messages to search
      Returns:
      list of found messages

    • cleanFrom

      void cleanFrom(long[] status)
      Remove from the log all the messages up to the provided status
      Parameters:
      status - clean state to use as base