Scala Reactive Programming

WF Reactive System – Producer API

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

1. Develop our Producer API model, as shown here:

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

2. Define the Producer WFService, as follows:

      trait WFService extends Service{ 
 
        def wfTemperature(city: String, temperature:String): ServiceCall[WFMessage, Done] override final def descriptor: Descriptor = { import Service._ named("wfproducer").withCalls( pathCall("/wf/:city/:temperature", wfTemperature _) ).withTopics( topic(WFService.TOPIC_NAME, wfTopic) ).withAutoAcl(true) } def wfTopic(): ...