We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
val lolExchange = Exchange("book.lol.lol", Direct, durable = true) val lolSubscriber: Subscriber[Message] = connection.publish(lolExchange.name, "") class MessageBroadcasterActor(sub : Subscriber[Message]) extends Actor { import com.google.common.net.MediaType implicit def toMsg(rl : RelatedProduct) : Message = { new Message( body = rl.productId.toString.getBytes(StandardCharsets.UTF_8), contentType = Some(MediaType.PLAIN_TEXT_UTF_8), mode = Persistent ) } override def receive: Receive = { case x : RelatedProduct => { sub.onNext(toMsg(x)) } } }
I'm using the code above but I can only see the first message on rabbit. Am I doing something wrong or is it a bug?
The text was updated successfully, but these errors were encountered:
What is sub?
sub
Sorry, something went wrong.
It's a message exchange val lolSubscriber: Subscriber[Message] = connection.publish(lolExchange.name, "")
val lolSubscriber: Subscriber[Message] = connection.publish(lolExchange.name, "")
No branches or pull requests
I'm using the code above but I can only see the first message on rabbit. Am I doing something wrong or is it a bug?
The text was updated successfully, but these errors were encountered: