RabbitMQMessageService

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]

   Definition Classes

   MessageService

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

   Definition Classes

   RabbitMQMessageService → MessageService

9. val cancellationDownloadQueueName: String

10. var cancellationQueue: Option[ActorRef]

    Definition Classes

    MessageService

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

    Definition Classes

    RabbitMQMessageService → MessageService

14. def connect(): Boolean

    Open connection to broker.

    Open connection to broker. *

15. var connection: Option[Connection]

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]

    Definition Classes

    MessageService

21. var extractorsHeartbeats: Option[ActorRef]

22. var factory: Option[ConnectionFactory]

23. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

24. def getBindings: Future[Response]

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

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

    Definition Classes

    RabbitMQMessageService → MessageService

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

    Definition Classes

    AnyRef → Any

26. def getExchange: String

    Definition Classes

    MessageService

27. def getExchanges: Future[Response]

    Get the exchange list for a given host

    Get the exchange list for a given host

    Definition Classes

    RabbitMQMessageService → MessageService

28. def getGlobalKey: String

    Definition Classes

    MessageService

29. def getInfo(isServerAdmin: Boolean): JsObject

    Get information about the service such as if it is connected and connection parameters.

    Get information about the service such as if it is connected and connection parameters.

    isServerAdmin

    if the current user is a server admin (show more info)

    returns

    JSONObject

    Definition Classes

    RabbitMQMessageService → MessageService

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

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

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

    Definition Classes

    RabbitMQMessageService → MessageService

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

    Get queue details for a given queue

    Get queue details for a given queue

    Definition Classes

    RabbitMQMessageService → MessageService

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

    get list of queues attached to an exchange

    get list of queues attached to an exchange

    Definition Classes

    RabbitMQMessageService → MessageService

33. def hashCode(): Int

    Definition Classes

    AnyRef → Any

34. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

35. var mgmtPort: String

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

    Definition Classes

    AnyRef

37. final def notify(): Unit

    Definition Classes

    AnyRef

38. final def notifyAll(): Unit

    Definition Classes

    AnyRef

39. var password: String

40. var rabbitmquri: String

41. var restURL: Option[String]

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

    Definition Classes

    RabbitMQMessageService → MessageService

43. def submit(exchange: String, routing_key: String, message: JsValue, exchange_type: String = "topic"): Unit

    Submit a message to broker.

    Submit a message to broker.

    Definition Classes

    RabbitMQMessageService → MessageService

44. def submit(message: ExtractorMessage): Unit

    Submit a message to default broker.

    Submit a message to default broker.

    Definition Classes

    RabbitMQMessageService → MessageService

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

    Definition Classes

    AnyRef

46. def toString(): String

    Definition Classes

    AnyRef → Any

47. var username: String

48. var vhost: String

49. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )