MessageService

abstract def getInfo(isServerAdmin: Boolean): JsObject

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

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

var bindings: List[Binding]

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

var cancellationQueue: Option[ActorRef]

def clone(): AnyRef

def close(): Unit

Close connection to broker.

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

var extractQueue: Option[ActorRef]

def finalize(): Unit

def getBindings: Future[Response]

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

final def getClass(): Class[_]

def getExchange: String

def getExchanges: Future[Response]

Get the exchange list for a given host

def getGlobalKey: String

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

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

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

Get queue details for a given queue

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

get list of queues attached to an exchange

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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

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

def submit(exchange: String, routing_key: String, message: JsValue, exchange_type: String): Unit

Submit a message to broker of a specific type.

def submit(message: ExtractorMessage): Unit

Submit a message to default broker.

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

def toString(): String

final def wait(): Unit

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

final def wait(arg0: Long): Unit