c

meteofrance

MF_RadarController

class MF_RadarController extends Model

Linear Supertypes
Model, Topic, Producer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MF_RadarController
  2. Model
  3. Topic
  4. Producer
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new MF_RadarController()(implicit LogUtil: LogUtil, JobLogUtil: JobLogUtil, pluviometerDao: PluviometerDao, GenericImportDao: GenericImportDao, PredImportDao: PredImportDao, database: Database, WSClient: WSClient)
    Annotations
    @Inject()

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def execute(routingKey: String, message: JsValue): Unit
    Definition Classes
    MF_RadarControllerModel
  9. def executeImport(message: JsValue): Seq[Int]
  10. def executeWrapper(routingKey: String, message: JsValue): Unit
    Definition Classes
    Model
  11. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def getRoutingKey(): String
    Definition Classes
    MF_RadarControllerModel
  13. def handleError(e: Exception, jobExecutionId: Long): Unit
    Definition Classes
    MF_RadarControllerModel
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  15. def initTopic(): (String, (String, JsValue) => Unit)
    Definition Classes
    Model → Topic
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. lazy val logUtil: LogUtil
    Definition Classes
    Topic
  18. lazy val logsUtil: LogUtil
    Definition Classes
    Producer
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  22. def sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
    Definition Classes
    Producer
  23. def sendRPC[A](routingKey: String, message: String, connection: Connection, channel: Channel, replyQueueName: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
    Definition Classes
    Producer
  24. def sendRPC[A](routingKey: String, message: String, timeout: Duration)(implicit rds: Reads[A], m: ClassTag[A]): A
    Definition Classes
    Producer
    Annotations
    @throws(classOf[java.util.concurrent.TimeoutException])
  25. def sendTopic(routingKey: String, message: String): Unit
    Definition Classes
    Producer
  26. def sendTopic(exchangeName: String, routingKey: String, queueName: String, message: String): Unit
    Definition Classes
    Producer
  27. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  28. def toString(): String
    Definition Classes
    AnyRef → Any
  29. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  30. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  31. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. def sendRPC(routingKey: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) => Unit): Unit
    Definition Classes
    Producer
    Annotations
    @deprecated @Deprecated
    Deprecated

    Use sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A]): Future[JsResult[A]]

  3. def sendRPC(exchangeName: String, routingKey: String, queueName: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) => Unit): Unit
    Definition Classes
    Producer
    Annotations
    @deprecated @Deprecated
    Deprecated

    Use sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A]): Future[JsResult[A]]

Inherited from Model

Inherited from Topic

Inherited from Producer

Inherited from AnyRef

Inherited from Any

Ungrouped