Skip to content

simple web socket service built with the akka-stream and http API

Notifications You must be signed in to change notification settings

leetoo/akka-stream-http-sample

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Simple WebSocket Service with Akka Streams / HTTP

  1. a scheduled Actor checks an external webservice every 5 seconds for a conversion rate
  2. stores the rate in a database only if it has changed since the last time
  3. the WebSocket streams all stored values. Once all available stored data is transmitted it continues streaming real-time updates.

Run "sbt run" from the project directory. To connect to the WS endpoint you can use the Chrome extension simple-websocket-client. The endpoint is ws://127.0.0.1:8080/ws-rates

Uses the following technologies:

  • Akka Http: Websockets and HttpClient
  • Akka Streams: concatenate a persistent DB content stream and a stream of real time events
  • Slick 3: simple DAO based on Slick 3
  • Spray Json: parse and query Json

About

simple web socket service built with the akka-stream and http API

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Scala 100.0%