RabbitmqPlugin

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. var apiKey: String

7. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

8. var bindings: List[Binding]

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

10. val cancellationDownloadQueueName: String

11. var cancellationQueue: Option[ActorRef]

12. var channel: Option[Channel]

13. def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

14. def close(): Unit

15. def connect: Boolean

16. var connection: Option[Connection]

17. val datasetService: DatasetService

18. lazy val enabled: Boolean

    Definition Classes

    RabbitmqPlugin → Plugin

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

    Definition Classes

    AnyRef

20. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

21. var event_filter: Option[ActorRef]

22. var exchange: String

23. var extractQueue: Option[ActorRef]

24. val extractorsService: ExtractorService

25. var factory: Option[ConnectionFactory]

26. def fileAddedToDataset(file: File, dataset: Dataset, host: 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): 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): 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): 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. val files: FileService

31. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

32. def getBindings: Future[Response]

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

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

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

34. def getChannelsList: Future[Response]

    Get Channel list from rabbitmq broker

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

    Definition Classes

    AnyRef → Any

36. def getExchanges: Future[Response]

    Get the exchange list for a given host

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

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

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

    Get queue details for a given queue

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

    get list of queues attached to an exchange

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

41. def hashCode(): Int

    Definition Classes

    AnyRef → Any

42. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

43. def metadataAddedToResource(metadataId: UUID, resourceRef: ResourceRef, extraInfo: Map[String, Any], host: String): Unit

    Metadata added to a resource (file or dataset).

    Metadata added to a resource (file or dataset).

    resourceRef

    extraInfo

    host

44. def metadataRemovedFromResource(metadataId: UUID, resourceRef: ResourceRef, host: String): Unit

    Metadata removed from a resource (file or dataset).

    Metadata removed from a resource (file or dataset).

    resourceRef

    host

45. var mgmtPort: String

46. def multimediaQuery(tempFileId: UUID, contentType: String, length: String, host: String): Unit

    File upladed for multimedia query.

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

    tempFileId

    contentType

    length

    host

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

    Definition Classes

    AnyRef

48. final def notify(): Unit

    Definition Classes

    AnyRef

49. final def notifyAll(): Unit

    Definition Classes

    AnyRef

50. def onStart(): Unit

    Definition Classes

    RabbitmqPlugin → Plugin

51. def onStop(): Unit

    Definition Classes

    RabbitmqPlugin → Plugin

52. var password: String

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

54. var rabbitmquri: String

55. var restURL: Option[String]

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

57. val spacesService: SpaceService

58. def submitDatasetManually(host: String, queue: String, extraInfo: Map[String, Any], datasetId: UUID, newFlags: 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

59. def submitFileManually(originalId: UUID, file: File, host: String, queue: String, extraInfo: Map[String, Any], datasetId: UUID, newFlags: String): 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

60. def submitSectionPreviewManually(preview: Preview, sectionId: UUID, host: String): Unit

    Preview creted for section.

    Preview creted for section.

    preview

    sectionId

    host

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

    Definition Classes

    AnyRef

62. def toString(): String

    Definition Classes

    AnyRef → Any

63. var username: String

64. var vhost: String

65. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

66. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

67. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )