Class MsgRepository.MsgRepositoryMDBean

    • Constructor Detail

      • MsgRepositoryMDBean

        public MsgRepositoryMDBean()
    • Method Detail

      • getMessageExpired

        public Element getMessageExpired​(long time,
                                         boolean delete)
        Description copied from interface: OfflineMsgRepositoryIfc
        Loads head of the payloads queue which holds items that would be expired after stated time with an option to delete them from repository after being retrieved. This is blocking method, which means if there is not data to return, implementation should block the call until data is available.
        Specified by:
        getMessageExpired in interface OfflineMsgRepositoryIfc
        time - time in milliseconds representing time after which given message would be considered as expired
        delete - boolean parameter controlling whether messages should be removed from repository after they retrieved.
        head of the payloads queue which holds items that would be expired after stated time with an option to delete them from repository after being retrieved.
      • loadExpiredQueue

        protected void loadExpiredQueue​(int min_elements)
      • loadExpiredQueue

        protected void loadExpiredQueue​(java.util.Date expired)
      • initRepository

        public void initRepository​(java.lang.String resource_uri,
                                   java.util.Map<java.lang.String,​java.lang.String> params)
                            throws DBInitException
        Description copied from interface: Repository
        Method is deprecated and should not be user any more.
        The method is called to initialize the data repository. Depending on the implementation all the initialization parameters can be passed either via resource_uri parameter as the database connection string or via params map if the required repository parameters are more complex or both.
        Specified by:
        initRepository in interface Repository
        resource_uri - value in most cases representing the database connection string.
        params - is a Map with repository properties necessary to initialize and perform all the functions. The initialization parameters are implementation dependent.
        DBInitException - if there was an error during repository initialization. Some implementations, though, perform so called lazy initialization so even though there is a problem with the underlying repository it may not be signaled through this method call.
      • setCondition

        public void setCondition​(java.util.concurrent.locks.ReentrantLock lock,
                                 java.util.concurrent.locks.Condition condition)
        Specified by:
        setCondition in interface MsgRepositoryIfc
      • getDefaultBeanClass

        public java.lang.Class<?> getDefaultBeanClass()
        Description copied from interface: RegistrarBeanWithDefaultBeanClass
        Returns default class for all bean which are defined using configuration as subbeans of bean implementing this interface. This allows users to have more convenient configuration file without the need to specify class for each of subbbeans if most of them will have the same class.
        Specified by:
        getDefaultBeanClass in interface RegistrarBeanWithDefaultBeanClass
      • getValueForDomain

        protected <T> T getValueForDomain​(java.util.Map<java.lang.String,​T> map,
                                          java.lang.String domain)