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

    Close connection to broker.

    Close connection to broker. *

  14. def connect: Boolean

  15. var connection: Option[Connection]

  16. val datasetService: DatasetService

  17. lazy val enabled: Boolean

    Check if play plugin is enabled *

    Check if play plugin is enabled *

    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. var extractorsHeartbeats: Option[ActorRef]

  24. val extractorsService: ExtractorService

  25. var factory: Option[ConnectionFactory]

  26. 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

  27. 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

  28. 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

  29. 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

  30. 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

  31. val files: FileService

  32. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  33. 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

  34. def getBindings: Future[Response]

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

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

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

  36. def getChannelsList: Future[Response]

    Get Channel list from rabbitmq broker

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

    Definition Classes
    AnyRef → Any
  38. 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

  39. def getExchanges: Future[Response]

    Get the exchange list for a given host

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

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

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

    Get queue details for a given queue

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

    get list of queues attached to an exchange

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

  44. var globalAPIKey: String

  45. def hashCode(): Int

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

    Definition Classes
    Any
  47. 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

  48. 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

  49. var mgmtPort: String

  50. 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

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

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

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

    Definition Classes
    AnyRef
  54. def onStart(): Unit

    On start connect to broker.

    On start connect to broker.

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

    On stop clean up connection.

    On stop clean up connection.

    Definition Classes
    RabbitmqPlugin → Plugin
  56. var password: String

  57. 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

  58. var rabbitmquri: String

  59. var restURL: Option[String]

  60. 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

  61. val spacesService: SpaceService

  62. 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

  63. 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

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

    Preview creted for section.

    Preview creted for section.

    preview
    sectionId
    host

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

    Definition Classes
    AnyRef
  66. def toString(): String

    Definition Classes
    AnyRef → Any
  67. val userService: UserService

  68. var username: String

  69. var vhost: String

  70. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Plugin

Inherited from AnyRef

Inherited from Any

Ungrouped