Skip to content
This repository has been archived by the owner on Jun 25, 2019. It is now read-only.

Synchronize application shutdown closing Run methods when broadcast channels are closed #103

Merged
merged 2 commits into from
Jan 1, 2019

Conversation

andig
Copy link
Collaborator

@andig andig commented Jan 1, 2019

This PR addresses the following points:

  • make rate limiting reusable by moving from MQTT output to scheduler
  • synchronize application shutdown by making tee wait for attached consumers to shutdown
  • have all tee consumers valididate input channel still open or close if not
  • finally use these to allow homie to unpublish retained messages when sdm is shutdown

Clean version of #102, replaces #89

@andig andig changed the title Unpublish2 Synchronize application shutdown closing Run methods when broadcast channels are closed Jan 1, 2019
@andig andig merged commit b5b812d into gonium:master Jan 1, 2019
@andig andig deleted the unpublish2 branch January 1, 2019 18:00
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

1 participant