fs2-jms

fs2 Streaming utilities for JMS providers

Supported JMS Message Types

• TextMessage
• ByteMessage
• MapMessage
• ObjectMessage

Publisher

Example JMS publisher

val producerSettings = {
  JmsProducerSettings(
    connectionFactory,
    sessionCount = 1,
    queueName = "testQueue"
  )
}

fs2.Stream
  .range(1, 10)
  .map(_.toString)
  .through(textPipe[IO](producerSettings))