class
DdassDistriController extends Model
Instance Constructors
-
new
DdassDistriController()(implicit ws: WSClient, qualitometerDao: QualitometerDao, surfaceQualitometerController: SurfaceQualitometerController, stationDao: StationDao, contributorDao: ContributorsDao, operationDao: OperationDao, aqua6boSurfaceQualitometerDao: Aqua6boSurfaceQualitometerDao, qualitometerPointDao: QualitometerPointDao, sampleDao: SampleDao, analysisDao: AnalysisDao, qualitoPointOperationsEnvDao: QualitometerPointOperationsEnvDao, logUtil: LogUtil, installationDao: InstallationDao, sandreCodeDao: SandreCodeDao, distributionUnitDao: DistributionUnitDao, productionUnitDao: ProductionUnitDao, stationLinkDao: StationLinkDao, JobLogUtil: JobLogUtil)
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
execute(routingKey: String, message: JsValue): Unit
-
def
executeImportFichier(message: JsValue): String
-
def
executeJobImportFichier(message: JsValue): Unit
-
def
executeWrapper(routingKey: String, message: JsValue): Unit
-
def
finalize(): Unit
-
def
gestionStation(integration: Boolean = true, code: Option[String], code2: Option[String], jobExecutionId: Option[Long], name: Option[String], schemeAgencyID: Int, schemeAgencyID2: Int, dtePrel: DateTime, coordX: Option[Double], coordY: Option[Double], noCreateStation: Boolean, f: String, myStation: Seq[(String, Option[String], Option[String], String, NodeSeq, Option[Double], Option[Double], Option[Double])], support: Option[String]): Option[String]
-
def
gestionStationAqua6bo(code2: Option[String], code: Option[String], jobExecutionId: Option[Long], name: Option[String], dtePrel: DateTime, noCreateStation: Boolean, f: String, myStationNode: NodeSeq): Option[String]
-
final
def
getClass(): Class[_]
-
def
getRoutingKey(): String
-
def
handleError(e: Exception, jobExecutionId: Long): Unit
-
def
hashCode(): Int
-
def
initTopic(): (String, (String, JsValue) ⇒ Unit)
-
def
inserPoint(id: Double, jobExecutionId: Option[Long], code: Option[String], code2: Option[String], dtePrel: DateTime, f: String, myStation: Seq[(String, Option[String], Option[String], String, NodeSeq, Option[Double], Option[Double], Option[Double])]): Option[QualitometerPoint]
-
final
def
isInstanceOf[T0]: Boolean
-
var
listStationPurge: Seq[String]
-
lazy val
logUtil: LogUtil
-
lazy val
logsUtil: LogUtil
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
processFile(withPoint: Boolean, xmlResult: Elem, purge: Boolean, stationIntegrationValue: Boolean, dataIntegration: Boolean, dataFullIntegration: Boolean, jobExecutionId: Option[Long], campaignId: Option[Double], stations: Option[Seq[String]], defaultValueOption: Option[ImportQualityDefaultValue] = None, noCreateStation: Boolean, f: String): 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
updatePoint(id: Double, jobExecutionId: Option[Long], code: Option[String], code2: Option[String], dtePrel: DateTime, f: String, myStation: Seq[(String, Option[String], Option[String], String, NodeSeq, Option[Double], Option[Double], Option[Double])]): Double
-
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 Topic
Inherited from Producer
Inherited from AnyRef
Inherited from Any