Scala Reactive Programming

WF Reactive System – Consumer API

In this section, we will perform the following steps to develop our Reactive System's Consumer API (wf-consumer-api) microservice:

1. Define the Consumer model, as shown here:

      case class WeatherForcasting(city:String, temperature:String) 
 
      object WeatherForcasting { 
        implicit val format: Format[WeatherForcasting] =         Json.format[WeatherForcasting] 
      }  

2. Define the Consumer Service (we will provide the implementation for this Service in the Consumer Implementation section):

 trait WFConsumerService extends Service { override def descriptor: Descriptor = { import Service._ named("wfconsumer").withCalls( restCall(Method.GET, "/api/wf", findTopTenWFData _), restCall(Method.GET, "/api/wf/one", findOneWFData _), restCall(Method.GET, ...