class
HydrologicalStationController extends Producer
Instance Constructors
-
new
HydrologicalStationController()(implicit logUtil: LogUtil, hydrologicalStationDao: HydrologicalStationDao, hydrologicalMeasureDao: HydrologicalMeasureDao, watermassHydrologicalLinkDao: WatermassHydrologicalLinkDao, stationContributorDao: StationContributorDao, userDao: UserDao, statUtil: StatUtil)
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
val
codeWithPlateformRead: Reads[(Double, String, String)]
-
def
createHydrologicalStation(message: JsValue): String
-
def
createObservation(message: JsValue): String
-
def
deleteHydrologicalStation(message: JsValue): String
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
def
get(message: JsValue): String
-
def
getAll(message: JsValue): String
-
def
getAllContributorLinks(message: JsValue): String
-
def
getAllHydrologicalStationWithGeoOutput(message: JsValue): String
-
def
getAllLastObservations(message: JsValue): String
-
final
def
getClass(): Class[_]
-
def
getHydrologicalMeasures(message: JsValue): String
-
def
getHydrologicalSituation(message: JsValue): String
-
def
getHydrologicalStationByIds(message: JsValue): String
-
def
getHydrologicalStationDataTypes(message: JsValue): String
-
def
getHydrologicalStationsByWaterShed(message: JsValue): String
-
def
getHydrologicalStationsByWatermass(message: JsValue): String
-
def
getObservationsByStation(message: JsValue): String
-
def
hashCode(): Int
-
val
hydrologicalStationIdsReads: Reads[(String, Seq[Double], String)]
-
val
hydrologicalStationObservationReads: Reads[(String, HydrologicalObservationInput)]
-
val
hydrologicalStationParamsReads: Reads[Option[GetAllQueryParams]]
-
val
hydrometerIdUserReads: Reads[(String, Int)]
-
val
hydrometerParamsUserReads: Reads[(String, Option[GetAllQueryParams], String)]
-
final
def
isInstanceOf[T0]: Boolean
-
val
linksRead: Reads[(String, HydroStationLinks)]
-
lazy val
logsUtil: LogUtil
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
-
def
sendRPC[A](routingKey: String, message: String, connection: Connection, channel: Channel, replyQueueName: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
-
def
sendRPC[A](routingKey: String, message: String, timeout: Duration)(implicit rds: Reads[A], m: ClassTag[A]): A
-
def
sendTopic(routingKey: String, message: String): Unit
-
def
sendTopic(exchangeName: String, routingKey: String, queueName: String, message: String): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
updateContact(message: JsValue): String
-
def
updateHydroStationLinks(message: JsValue): String
-
def
updateHydrologicalStation(message: JsValue): String
-
def
updateLocalisation(message: JsValue): String
-
val
userReadsWithModule: Reads[(String, String)]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Deprecated Value Members
-
def
sendRPC(routingKey: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) ⇒ Unit): Unit
-
def
sendRPC(exchangeName: String, routingKey: String, queueName: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) ⇒ Unit): Unit
Inherited from Producer
Inherited from AnyRef
Inherited from Any