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. var channel: Option[Channel]

10. def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

11. def close(): Unit

12. def connect: Boolean

13. var connection: Option[Connection]

14. val datasetService: DatasetService

15. lazy val enabled: Boolean

    Definition Classes

    RabbitmqPlugin → Plugin

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

    Definition Classes

    AnyRef

17. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

18. var event_filter: Option[ActorRef]

19. var exchange: String

20. var extractQueue: Option[ActorRef]

21. val extractorsService: ExtractorService

22. var factory: Option[ConnectionFactory]

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

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

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

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

27. val files: FileService

28. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

29. def getBindings: Future[Response]

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

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

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

31. def getChannelsList: Future[Response]

    Get Channel list from rabbitmq broker

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

    Definition Classes

    AnyRef → Any

33. def getExchanges: Future[Response]

    Get the exchange list for a given host

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

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

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

    Get queue details for a given queue

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

    get list of queues attached to an exchange

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

38. def hashCode(): Int

    Definition Classes

    AnyRef → Any

39. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

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

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

42. var mgmtPort: String

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

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

    Definition Classes

    AnyRef

45. final def notify(): Unit

    Definition Classes

    AnyRef

46. final def notifyAll(): Unit

    Definition Classes

    AnyRef

47. def onStart(): Unit

    Definition Classes

    RabbitmqPlugin → Plugin

48. def onStop(): Unit

    Definition Classes

    RabbitmqPlugin → Plugin

49. var password: String

50. var rabbitmquri: String

51. var restURL: Option[String]

52. val spacesService: SpaceService

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

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

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

    Preview creted for section.

    Preview creted for section.

    preview

    sectionId

    host

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

    Definition Classes

    AnyRef

57. def toString(): String

    Definition Classes

    AnyRef → Any

58. var username: String

59. var vhost: String

60. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )