services

ElasticsearchQueue

class ElasticsearchQueue extends MongoDBQueueService

Elasticsearch queue service to allow code that updates ES indexes to proceed asynchronously.

Linear Supertypes
MongoDBQueueService, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ElasticsearchQueue
  2. MongoDBQueueService
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ElasticsearchQueue(files: FileService, datasets: DatasetService, collections: CollectionService, sections: SectionService)

    Annotations
    @Inject()

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. object Queue extends ModelCompanion[QueuedAction, ObjectId]

    Definition Classes
    MongoDBQueueService
  7. def _indexAll(): Unit

  8. def _swapIndex(): Unit

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. val consumer: String

  12. var disabledNotified: Boolean

    Definition Classes
    MongoDBQueueService
  13. def enabled(): Boolean

  14. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  16. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  18. def getNextQueuedAction(): Option[QueuedAction]

    Definition Classes
    MongoDBQueueService
  19. def handleQueuedAction(action: QueuedAction): com.mongodb.casbah.Imports.WriteResult

    Definition Classes
    MongoDBQueueService
  20. def handler(action: QueuedAction): Unit

  21. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  22. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  23. def listen(): Unit

    Definition Classes
    MongoDBQueueService
  24. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  25. final def notify(): Unit

    Definition Classes
    AnyRef
  26. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  27. def queue(action: String, target: ResourceRef, parameters: ElasticsearchParameters): Boolean

    Definition Classes
    MongoDBQueueService
  28. def queue(action: String, target: ResourceRef): Boolean

    Definition Classes
    MongoDBQueueService
  29. def queue(action: String, parameters: ElasticsearchParameters): Boolean

    Definition Classes
    MongoDBQueueService
  30. def queue(action: String): Boolean

    Definition Classes
    MongoDBQueueService
  31. var queueFetchError: Boolean

    Definition Classes
    MongoDBQueueService
  32. var queueTimer: Cancellable

    Definition Classes
    MongoDBQueueService
  33. def status(): JsObject

    Definition Classes
    MongoDBQueueService
  34. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  35. def toString(): String

    Definition Classes
    AnyRef → Any
  36. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  38. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from MongoDBQueueService

Inherited from AnyRef

Inherited from Any

Ungrouped