AmqChangeIndexer(com.atlassian.messagequeue.MessageRunnerService messageRunnerService,
PayloadSerializer<IndexPayload> indexPayloadSerializer,
com.atlassian.util.concurrent.Supplier<ContentEntityObjectDao> contentEntityObjectDao) |
IndexChangeRunner(com.atlassian.messagequeue.registry.MessageRunnerRegistryService messageRunnerRegistryService,
PayloadSerializer<IndexPayload> indexPayloadSerializer,
HibernateObjectLoader<com.atlassian.bonnie.Searchable> searchableLoader,
DocumentVersionService documentVersionService,
BiConsumer<com.atlassian.bonnie.Searchable,Long> indexChangeAction) |
IndexContentRunner(com.atlassian.messagequeue.registry.MessageRunnerRegistryService messageRunnerRegistryService,
PayloadSerializer<IndexPayload> indexPayloadSerializer,
DocumentVersionService documentVersionService,
HibernateObjectLoader<com.atlassian.bonnie.Searchable> searchableLoader,
BiConsumer<com.atlassian.bonnie.Searchable,Long> indexContentAction) |
UnindexChangesRunner(com.atlassian.messagequeue.registry.MessageRunnerRegistryService messageRunnerRegistryService,
PayloadSerializer<IndexPayload> indexPayloadSerializer,
DocumentVersionService documentVersionService,
ESDeleteByQueryAction deleteByQueryAction) |
UnindexContentRunner(com.atlassian.messagequeue.registry.MessageRunnerRegistryService messageRunnerRegistryService,
PayloadSerializer<IndexPayload> indexPayloadSerializer,
DocumentVersionService documentVersionService,
ESIndexRequestProcessor indexRequestProcessor) |