Package org.alfresco.repo.events

Class AbstractEventsService

    • Field Detail

      • TRANSACTION_HAS_EVENTS

        protected static final java.lang.String TRANSACTION_HAS_EVENTS
        See Also:
        Constant Field Values

      • nodeService

        protected org.alfresco.service.cmr.repository.NodeService nodeService

      • dictionaryService

        protected org.alfresco.service.cmr.dictionary.DictionaryService dictionaryService

      • namespaceService

        protected org.alfresco.service.namespace.NamespaceService namespaceService

      • permissionService

        protected org.alfresco.service.cmr.security.PermissionService permissionService

      • eventRegistry

        protected org.alfresco.sync.events.EventRegistry eventRegistry

      • includeEventTypes

        protected java.util.Set<java.lang.String> includeEventTypes

      • matchingTypes

        protected java.util.Set<org.alfresco.service.namespace.QName> matchingTypes

      • sendEventsBeforeCommit

        protected boolean sendEventsBeforeCommit

    • Constructor Detail

      • AbstractEventsService

        public AbstractEventsService()

    • Method Detail

      • setHiddenAspect

        public void setHiddenAspect​(HiddenAspect hiddenAspect)

      • setSendEventsBeforeCommit

        public void setSendEventsBeforeCommit​(boolean sendEventsBeforeCommit)

      • setTransactionService

        public void setTransactionService​(TransactionService transactionService)

      • setIncludeEventTypes

        public void setIncludeEventTypes​(java.lang.String includeEventTypesStr)

      • setFileFolderService

        public void setFileFolderService​(FileFolderService fileFolderService)

      • setEventRegistry

        public void setEventRegistry​(org.alfresco.sync.events.EventRegistry eventRegistry)

      • setNamespaceService

        public void setNamespaceService​(org.alfresco.service.namespace.NamespaceService namespaceService)

      • setPermissionService

        public void setPermissionService​(org.alfresco.service.cmr.security.PermissionService permissionService)

      • setMessageProducer

        public void setMessageProducer​(org.gytheio.messaging.MessageProducer messageProducer)

      • setDictionaryService

        public void setDictionaryService​(org.alfresco.service.cmr.dictionary.DictionaryService dictionaryService)

      • setNodeService

        public void setNodeService​(org.alfresco.service.cmr.repository.NodeService nodeService)

      • setSiteService

        public void setSiteService​(SiteService siteService)

      • init

        public void init()

      • nextSequenceNumber

        protected long nextSequenceNumber()

      • beforeCommit

        public void beforeCommit​(boolean readOnly)
        Description copied from class: TransactionListenerAdapter
        Called before a transaction is committed.

        All transaction resources are still available.

        Specified by:
        beforeCommit in interface TransactionListener
        Specified by:
        beforeCommit in interface org.alfresco.util.transaction.TransactionListener
        Overrides:
        beforeCommit in class TransactionListenerAdapter
        Parameters:
        readOnly - true if the transaction is read-only

      • getAlfrescoClient

        protected org.alfresco.sync.repo.Client getAlfrescoClient​(org.alfresco.sync.repo.Client knownClientType)

      • afterCommit

        public void afterCommit()
        Description copied from class: TransactionListenerAdapter
        Invoked after transaction commit.

        Any exceptions generated here will only be logged and will have no effect on the state of the transaction.

        Although all transaction resources are still available, this method should be used only for cleaning up resources after a commit has occured.

        Specified by:
        afterCommit in interface TransactionListener
        Specified by:
        afterCommit in interface org.alfresco.util.transaction.TransactionListener
        Overrides:
        afterCommit in class TransactionListenerAdapter

      • shouldSendCommitEvent

        protected boolean shouldSendCommitEvent()
        Determines whether it still makes sense to create and send a TransactionCommittedEvent after the transaction is committed. (e.g. if there are no events for the specific transaction makes no sense to signal the end of transaction with TransactionCommittedEvent)
        Returns:
        whether the TransactionCommitted event should be sent

      • filterEventsBeforeSend

        protected java.util.List<org.alfresco.sync.events.types.Event> filterEventsBeforeSend​(java.util.List<org.alfresco.sync.events.types.Event> events)
        Filter out event before sending them to MessageProducer
        Parameters:
        events - the events to be filtered
        Returns:
        a filtered list of events

      • afterRollback

        public void afterRollback()
        Description copied from class: TransactionListenerAdapter
        Invoked after transaction rollback.

        Any exceptions generated here will only be logged and will have no effect on the state of the transaction.

        Although all transaction resources are still available, this method should be used only for cleaning up resources after a rollback has occured.

        Specified by:
        afterRollback in interface TransactionListener
        Specified by:
        afterRollback in interface org.alfresco.util.transaction.TransactionListener
        Overrides:
        afterRollback in class TransactionListenerAdapter

      • includeEventType

        protected boolean includeEventType​(java.lang.String eventType)

      • retrieveAdditionalProps

        protected void retrieveAdditionalProps​(java.util.Map<java.lang.String,​java.io.Serializable> properties,
                                       org.alfresco.service.cmr.repository.NodeRef nodeRef)
        Extract additional information for the provided node
        Parameters:
        properties - the properties map to add the new info to
        nodeRef - the node to extract the property from

      • getPaths

        protected java.util.List<java.lang.String> getPaths​(java.util.List<org.alfresco.service.cmr.repository.Path> nodePaths,
                                                    java.util.List<java.lang.String> toAppend)

      • getNodeIdsFromParent

        protected java.util.List<java.util.List<java.lang.String>> getNodeIdsFromParent​(java.util.List<org.alfresco.service.cmr.repository.Path> nodePaths)
        For each path, construct a list of ancestor node ids starting with the parent node id first.
        Parameters:
        nodePaths -
        Returns:

      • getNodeIds

        protected java.util.List<java.util.List<java.lang.String>> getNodeIds​(java.util.List<org.alfresco.service.cmr.repository.Path> nodePaths)
        For each path, construct a list of ancestor node ids starting with the leaf path element node id first.
        Parameters:
        nodePaths -
        Returns:

      • getTxnEvents

        protected org.alfresco.repo.events.AbstractEventsService.TxnEvents getTxnEvents()

      • sendEvent

        public void sendEvent​(org.alfresco.sync.events.types.Event event)
        Register the event to be sent to a message producer once the transaction is over
        Parameters:
        event - event to be sent

      • getNodeInfo

        protected AbstractEventsService.NodeInfo getNodeInfo​(org.alfresco.service.cmr.repository.NodeRef nodeRef,
                                                     java.lang.String eventType)