# Reliable Pub/Sub Service

## Functions

- **put()** Publish a message on a topic. If the topic doesn't exist, creates a new topic
- **get()** Consume a message from a topic
- **subcribe()** Subscribes a topic. If the topic doesn't exist, creates a new topic
- **unsubscribe()** Unsubscribe a topic

## Questions

- Blocking or non-blocking?

## Notes

- No messages to read with **get()** equivalent to having read all the messages on a topic.