Skip to content

Instantly share code, notes, and snippets.

@deepanshu42
Created August 23, 2021 10:06
Show Gist options
  • Save deepanshu42/40d6837cfeae3029e0781ece8cb1906a to your computer and use it in GitHub Desktop.
Save deepanshu42/40d6837cfeae3029e0781ece8cb1906a to your computer and use it in GitHub Desktop.
interface MessageService {
@Send(topic = "messages/send", qos = QoS.TWO)
fun send(@Data message: Message)
@Receive(topic = "messages/receive")
fun receive(): Observable<Message>
@Subscribe(topic = "messages/receive", qos = QoS.ONE)
fun subscribe(): Observable<Message>
@Unsubscribe(topics = ["messages/receive"])
fun unsubscribe()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment