Package tigase.archive.unified.db

Class JDBCFlexibleOfflineMessageRetrievalRepository

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  JDBCFlexibleOfflineMessageRetrievalRepository.MSG_TYPES  

      • Nested classes/interfaces inherited from class tigase.server.amp.MsgRepository

        tigase.server.amp.MsgRepository.BroadcastMsg, tigase.server.amp.MsgRepository.MsgDBItem, tigase.server.amp.MsgRepository.OfflineMessagesProcessor

      • Nested classes/interfaces inherited from interface tigase.db.Repository

        tigase.db.Repository.Meta

    • Field Summary

      • Fields inherited from class tigase.server.amp.MsgRepository

        broadcastMessages, broadcastMessagesLastCleanup, earliestOffline, expiredQueue, MAX_QUEUE_SIZE, MSGS_STORE_LIMIT_KEY, OFFLINE_MSGS_KEY, parser

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int deleteMessagesToJID​(java.util.List<java.lang.String> db_ids, tigase.xmpp.XMPPResourceConnection session)  
      java.util.Map<java.lang.Enum,​java.lang.Long> getMessagesCount​(tigase.xmpp.JID to)  
      java.util.List<tigase.xml.Element> getMessagesList​(tigase.xmpp.JID to)  
      void initRepository​(java.lang.String conn_str, java.util.Map<java.lang.String,​java.lang.String> map)  
      protected void initRepository​(tigase.db.DataRepository data_repo)  
      java.util.Queue<tigase.xml.Element> loadMessagesToJID​(java.util.List<java.lang.String> db_ids, tigase.xmpp.XMPPResourceConnection session, boolean delete, tigase.server.amp.MsgRepository.OfflineMessagesProcessor proc)  
      java.util.Queue<tigase.xml.Element> loadMessagesToJID​(tigase.xmpp.XMPPResourceConnection session, boolean delete, tigase.server.amp.MsgRepository.OfflineMessagesProcessor proc)  
      boolean storeMessage​(tigase.xmpp.JID from, tigase.xmpp.JID to, java.util.Date expired, tigase.xml.Element msg, tigase.db.NonAuthUserRepository userRepo)  

      • Methods inherited from class tigase.server.amp.JDBCMsgRepository

        deleteMessage, ensureBroadcastMessageRecipient, insertBroadcastMessage, loadExpiredQueue, loadExpiredQueue, loadMessagesToBroadcast, loadMessagesToJID, parseLoadedMessages

      • Methods inherited from class tigase.server.amp.MsgRepository

        dumpBroadcastMessageKeys, getBroadcastMessages, getBroadcastMsg, getInstance, getMessageExpired, getMsgsStoreLimit, getStanzaTo, updateBroadcastMessage

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • JDBCFlexibleOfflineMessageRetrievalRepository

        public JDBCFlexibleOfflineMessageRetrievalRepository()

      • JDBCFlexibleOfflineMessageRetrievalRepository

        protected JDBCFlexibleOfflineMessageRetrievalRepository​(JDBCUnifiedArchiveRepository msg_repo)

    • Method Detail

      • initRepository

        public void initRepository​(java.lang.String conn_str,
                           java.util.Map<java.lang.String,​java.lang.String> map)
                    throws tigase.db.DBInitException
        Specified by:
        initRepository in interface tigase.db.Repository
        Overrides:
        initRepository in class tigase.server.amp.JDBCMsgRepository
        Throws:
        tigase.db.DBInitException

      • initRepository

        protected void initRepository​(tigase.db.DataRepository data_repo)
                       throws java.sql.SQLException
        Throws:
        java.sql.SQLException

      • getMessagesCount

        public java.util.Map<java.lang.Enum,​java.lang.Long> getMessagesCount​(tigase.xmpp.JID to)
        Overrides:
        getMessagesCount in class tigase.server.amp.JDBCMsgRepository

      • getMessagesList

        public java.util.List<tigase.xml.Element> getMessagesList​(tigase.xmpp.JID to)
        Overrides:
        getMessagesList in class tigase.server.amp.JDBCMsgRepository

      • loadMessagesToJID

        public java.util.Queue<tigase.xml.Element> loadMessagesToJID​(tigase.xmpp.XMPPResourceConnection session,
                                                             boolean delete,
                                                             tigase.server.amp.MsgRepository.OfflineMessagesProcessor proc)
                                                      throws tigase.db.UserNotFoundException
        Overrides:
        loadMessagesToJID in class tigase.server.amp.JDBCMsgRepository
        Throws:
        tigase.db.UserNotFoundException

      • loadMessagesToJID

        public java.util.Queue<tigase.xml.Element> loadMessagesToJID​(java.util.List<java.lang.String> db_ids,
                                                             tigase.xmpp.XMPPResourceConnection session,
                                                             boolean delete,
                                                             tigase.server.amp.MsgRepository.OfflineMessagesProcessor proc)
                                                      throws tigase.db.UserNotFoundException
        Overrides:
        loadMessagesToJID in class tigase.server.amp.JDBCMsgRepository
        Throws:
        tigase.db.UserNotFoundException

      • deleteMessagesToJID

        public int deleteMessagesToJID​(java.util.List<java.lang.String> db_ids,
                               tigase.xmpp.XMPPResourceConnection session)
                        throws tigase.db.UserNotFoundException
        Overrides:
        deleteMessagesToJID in class tigase.server.amp.JDBCMsgRepository
        Throws:
        tigase.db.UserNotFoundException

      • storeMessage

        public boolean storeMessage​(tigase.xmpp.JID from,
                            tigase.xmpp.JID to,
                            java.util.Date expired,
                            tigase.xml.Element msg,
                            tigase.db.NonAuthUserRepository userRepo)
                     throws tigase.db.UserNotFoundException
        Specified by:
        storeMessage in interface tigase.db.MsgRepositoryIfc
        Overrides:
        storeMessage in class tigase.server.amp.JDBCMsgRepository
        Throws:
        tigase.db.UserNotFoundException