Publisher

Simple example for publishing one message with some string:

import com.anymindgroup.pubsub.*, http.*
import zio.*, zio.ZIO.*

object BasicPublisher extends ZIOAppDefault:
  def run =
    for
      publisher <- makeTopicPublisher(
                     topicName = TopicName("gcp_project", "topic"),
                     serializer = Serde.utf8String,
                     // set by default to "PubsubConnectionConfig.Cloud" when not running against an emulator
                     connection = PubsubConnectionConfig.Emulator("localhost", 8085),
                   )
      data <- Random.nextInt.map(i => s"some data $i")
      mId <- publisher.publish(
               PublishMessage(
                 data = data,
                 attributes = Map.empty,
                 orderingKey = None,
               )
             )
      _ <- logInfo(s"Published message with id ${mId.value} and data '$data'")
    yield ()