- JDK 1.8
- Maven
- createTopic(topicName) -> topicId
- subscribe(topicId, subscriber) -> boolean
- publish(topicId, message) -> boolean
- readOffset(topidId, subscriber, offset) -> boolean
We have to design a message queue supporting publisher-subscriber model.
Java