message-broker
An experimental pub/sub client and server project.
Star
Fork
Watch

Commits on main
reconnect clients (#16)
committed
publisher now attempts to reconnect if the server is down (#15)
committed
fix error wrap (#14)
committed
added mutex logic to the topic subscriptions (#13)
committed
update readme docs and also made example better (#11)
committed
Refactor app structure + test improvements (#10)
committed
Merge pull request #9 from willdot/persist
committed
hopefully fix flakey test
committed
some tweaks and typos
committed
Error handling
committed
Refactor the message types to just 1
committed
Tweaks
committed
give each topic its own store
committed
persist messages to memory store and allow subscribers to start from x when starting
committed
Merge pull request #8 from willdot/refactorConnWrite
committed
write to connection once
committed
update readme
committed
Create README.md
committed
Merge pull request #7 from willdot/ack
committed
Tidy up
committed
better handling when unsubscribing
committed
nack/ack
committed
Merge pull request #6 from willdot/bugs
committed
logging
committed
Merge pull request #5 from willdot/publish-messages-async
committed
makes the call to publish message async
committed
Merge pull request #4 from willdot/ci
committed
comment on the timeout check
committed
better error logging
committed
whole lota lint
committed
basic lint config
committed
add ci
committed
Merge pull request #3 from willdot/connLock
committed
comments
committed
tidy up and refactor
committed
fixed the peer read action pointer
committed
more tweaks
committed
small tweaks
committed
Refactor. Huge refactor to make conns synchronous
committed
Better error handling for closed listener
committed
removed all that commented out cod
committed
comment
committed
improve the consumer API for subscribing
committed
update unsubscribe test
committed
Unsubscribe
committed
Refactor so that resp status are sent back to connections
committed
Merge pull request #1 from willdot/subscriber
committed
Implement publisher code and refactor / comments
committed
Made a subscriber package....kinda words
committed
Some refactoring and publisher conn can now send multiple messages
committed
Change module name and exported messages
committed
initial commit with basic pub/sub
committed
Initial commit
committed