Package se.laz.casual.network.outbound

Interface ConversationMessageStorage

All Known Implementing Classes:
ConversationMessageStorageImpl
public interface ConversationMessageStorage

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    clear(UUID corrid)
     
    void
    clearAllConversations()
     
    Optional<se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request>>
    nextMessage(UUID corrid)
     
    int
    numberOfConversations()
     
    void
    put(UUID corrid, se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request> message)
     
    int
    size(UUID corrid)
     
    se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request>
    takeFirst(UUID corrid)
    Blocks until a message is available

  • Method Details

    • nextMessage

      Optional<se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request>> nextMessage(UUID corrid)

    • put

      void put(UUID corrid, se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request> message)

    • takeFirst

      se.laz.casual.api.network.protocol.messages.CasualNWMessage<se.laz.casual.network.protocol.messages.conversation.Request> takeFirst(UUID corrid)
      Blocks until a message is available
      Parameters:
      corrid - ??? Ask Mathias - I have not idea what these id is
      Returns:
      the first message available

    • size

      int size(UUID corrid)

    • clear

      void clear(UUID corrid)

    • numberOfConversations

      int numberOfConversations()

    • clearAllConversations

      void clearAllConversations()