Skip to main content

Sending Data

To send data we can use the low level method to just send a string:

queue.sendMessage("hello world")
// res0: IO[SendMessageResponse] = IO$685538097

We can also send some headers:

queue.sendMessage("a message", Map("client" -> "fawn"))
// res1: IO[SendMessageResponse] = IO$1074923160

To make things a bit easier we could use the method which understands encoding:

import com.meltwater.fawn.codec.circe.CirceCodec._
import io.circe.literal._

queue.sendAs(json"""{"some": "circe json"}""")
// res2: IO[SendMessageResponse] = IO$1182510333
queue.sendAs(json"""123""", Map("a header" -> "a header value"))
// res3: IO[SendMessageResponse] = IO$954567900