kulikov / sbus

Service Bus for java/scala services with RabbitMQ transport

GitHub

sbus

Travis CI

Service Bus for java/scala services with RabbitMQ transport

sbus.on[GetOrders, List[Order]]("get-orders") { (req, context)  
  Future.successful(List(Order(), Order()))
}

sbus.request[List[Order]]("get-orders", GetOrders(id = 123)) map { orders  
  println(orders)
}