services

RabbitmqPlugin

class RabbitmqPlugin extends Plugin

Rabbitmq service.

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

Instance Constructors

  1. new RabbitmqPlugin(application: Application)

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. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. var bindings: List[Binding]

  8. def cancelPendingSubmission(id: UUID, queueName: String, msg_id: UUID): Unit

  9. val cancellationDownloadQueueName: String

  10. var cancellationQueue: Option[ActorRef]

  11. var channel: Option[Channel]

  12. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. def close(): Unit

  14. def connect: Boolean

  15. var connection: Option[Connection]

  16. val datasetService: DatasetService

  17. lazy val enabled: Boolean

    Definition Classes
    RabbitmqPlugin → Plugin
  18. final def eq(arg0: AnyRef): Boolean

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

    Definition Classes
    AnyRef → Any
  20. var event_filter: Option[ActorRef]

  21. var exchange: String

  22. var extractQueue: Option[ActorRef]

  23. val extractorsService: ExtractorService

  24. var factory: Option[ConnectionFactory]

  25. def fileAddedToDataset(file: File, dataset: Dataset, host: String, requestAPIKey: Option[String]): Unit

    Send message when a file is added to a dataset.

    Send message when a file is added to a dataset. Use both old method using topic queues and new method using work queues and extractors registration in Clowder.

    file

    the file that was added to the dataset

    dataset

    the dataset it was added to

    host

    the Clowder host URL for sharing extractors across instances

  26. def fileCreated(file: TempFile, host: String, requestAPIKey: Option[String]): Unit

    Send message when a new file is uploaded to the system.

    Send message when a new file is uploaded to the system. This is the same as the method above but it supports TempFile instead of File. This is currently only used for multimedia queries.

    file

    the file that was just uploaded

    host

    the Clowder host URL for sharing extractors across instances

  27. def fileCreated(file: File, dataset: Option[Dataset], host: String, requestAPIKey: Option[String]): Unit

    Publish to the proper queues when a new file is uploaded to the system.

    Publish to the proper queues when a new file is uploaded to the system.

    file

    the file that was just uploaded

    dataset

    the dataset the file belongs to

    host

    the Clowder host URL for sharing extractors across instances

  28. def fileRemovedFromDataset(file: File, dataset: Dataset, host: String, requestAPIKey: Option[String]): Unit

    Send message when file is removed from a dataset and deleted.

    Send message when file is removed from a dataset and deleted.

    file
    dataset
    host

  29. def fileSetAddedToDataset(dataset: Dataset, filelist: List[File], host: String, requestAPIKey: Option[String]): Unit

    Send message when a group of files is added to a dataset via UI.

    Send message when a group of files is added to a dataset via UI. Use both old method using topic queues and new method using work queues and extractors registration in Clowder.

    dataset

    the dataset it was added to

    filelist

    the list of files that were added to the dataset

    host

    the Clowder host URL for sharing extractors across instances

  30. val files: FileService

  31. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  32. def getApiKey(requestAPIKey: Option[String], user: Option[User]): String

    Return the API key to use in the submission.

    Return the API key to use in the submission. If the one in the key is not set in the request then get the default extraction key for the user. If the user is not defined default to the global key. for the user

    requestAPIKey

    the API key from the request

    user

    the user from the request

    returns

    the API key to use

  33. def getBindings: Future[Response]

    Get the binding lists (lists of routing keys) from the rabbitmq broker

  34. def getChannelInfo(cid: String): Future[Response]

    Get Channel information from rabbitmq broker for given channel id 'cid'

  35. def getChannelsList: Future[Response]

    Get Channel list from rabbitmq broker

  36. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  37. def getEmailNotificationEmailList(requestAPIKey: Option[String]): List[String]

    a helper function to get user email address from user's request api key.

    a helper function to get user email address from user's request api key.

    requestAPIKey

    user request apikey

    returns

    a list of email address

  38. def getExchanges: Future[Response]

    Get the exchange list for a given host

  39. def getQueueBindings(qname: String): Future[Response]

    Get queue bindings for a given host and queue from rabbitmq broker

  40. def getQueueDetails(qname: String): Future[Response]

    Get queue details for a given queue

  41. def getQueuesNamesForAnExchange(exchange: String): Future[Response]

    get list of queues attached to an exchange

  42. def getRestEndPoint(path: String): Future[Response]

  43. var globalAPIKey: String

  44. def hashCode(): Int

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

    Definition Classes
    Any
  46. def metadataAddedToResource(metadataId: UUID, resourceRef: ResourceRef, extraInfo: Map[String, Any], host: String, requestAPIKey: Option[String], user: Option[User]): Unit

    Metadata added to a resource (file or dataset).

    Metadata added to a resource (file or dataset).

    resourceRef
    extraInfo
    host

  47. def metadataRemovedFromResource(metadataId: UUID, resourceRef: ResourceRef, host: String, requestAPIKey: Option[String], user: Option[User]): Unit

    Metadata removed from a resource (file or dataset).

    Metadata removed from a resource (file or dataset).

    resourceRef
    host

  48. var mgmtPort: String

  49. def multimediaQuery(tempFileId: UUID, contentType: String, length: String, host: String, requestAPIKey: Option[String]): Unit

    File upladed for multimedia query.

    File upladed for multimedia query. Not a common used feature.

    tempFileId
    contentType
    length
    host

  50. final def ne(arg0: AnyRef): Boolean

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

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

    Definition Classes
    AnyRef
  53. def onStart(): Unit

    Definition Classes
    RabbitmqPlugin → Plugin
  54. def onStop(): Unit

    Definition Classes
    RabbitmqPlugin → Plugin
  55. var password: String

  56. def postSubmissionEven(file_id: UUID, extractor_id: String): UUID

    Post the event of SUBMITTED

    Post the event of SUBMITTED

    file_id

    the UUID of file

    extractor_id

    the extractor queue name to be submitted

  57. var rabbitmquri: String

  58. var restURL: Option[String]

  59. def resubmitPendingRequests(cancellationQueueConsumer: QueueingConsumer, channel: Channel, cancellationSearchTimeout: Long): Unit

    loop through the queue and dispatch the message via the routing key.

    loop through the queue and dispatch the message via the routing key.

    cancellationQueueConsumer

    the queue consumer to download the requests from the cancellation downloaded queue

    channel

    the channel connecting to the rabbitmq

    cancellationSearchTimeout

    the timeout of downloading the requests from the rabbitmq

  60. val spacesService: SpaceService

  61. def submitDatasetManually(host: String, queue: String, extraInfo: Map[String, Any], datasetId: UUID, newFlags: String, requestAPIKey: Option[String], user: Option[User]): Unit

    An existing dataset was manually submitted to the extraction bus by a user.

    An existing dataset was manually submitted to the extraction bus by a user.

    host
    queue
    extraInfo
    datasetId
    newFlags

  62. def submitFileManually(originalId: UUID, file: File, host: String, queue: String, extraInfo: Map[String, Any], datasetId: UUID, newFlags: String, requestAPIKey: Option[String], user: Option[User]): Unit

    An existing file was manually submitted to the extraction bus by a user.

    An existing file was manually submitted to the extraction bus by a user.

    originalId
    file
    host
    queue
    extraInfo
    datasetId
    newFlags

  63. def submitSectionPreviewManually(preview: Preview, sectionId: UUID, host: String, requestAPIKey: Option[String]): Unit

    Preview creted for section.

    Preview creted for section.

    preview
    sectionId
    host

  64. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  65. def toString(): String

    Definition Classes
    AnyRef → Any
  66. val userService: UserService

  67. var username: String

  68. var vhost: String

  69. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Plugin

Inherited from AnyRef

Inherited from Any

Ungrouped