Fredrik Skogberg freskog
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.util.concurrent.TimeUnit | |
| import scalaz.zio._ | |
| import scalaz.zio.clock.Clock | |
| import scalaz.zio.duration.Duration | |
| import scala.concurrent.duration._ | |
| object DynamicSharding extends App { |
freskog
/ Runner.scala
Created
May 14, 2019 21:34
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import com.rabbitmq.client.{AMQP, Channel, ConnectionFactory, DefaultConsumer, Envelope} | |
| import scalaz.zio._ | |
| import scalaz.zio.console.Console | |
| object Runner extends App with DefaultRuntime { | |
| case class AmqpMessage(consumerTag: String, | |
| envelope: Envelope, | |
| properties: AMQP.BasicProperties, | |
| body: Array[Byte], |