Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Use multiprocessing for Pika event consumer #6760

Merged
merged 31 commits into from
Oct 14, 2020
Merged

Use multiprocessing for Pika event consumer #6760

Show file tree
Hide file tree
Changes from 8 commits
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
d6447dd
Pika event broker with multithreading
alwx Sep 23, 2020
78158ee
Fix to multithreading
alwx Sep 23, 2020
173bae9
PikaConnector
alwx Sep 23, 2020
22f7994
Code fixes
alwx Sep 23, 2020
b1b39c5
Updates for pika broker
alwx Sep 24, 2020
4090c27
Changelog entry
alwx Sep 24, 2020
f600187
Merge branch 'master' into pika-event-broker-connection
alwx Sep 24, 2020
aa1911b
Merge branch 'master' into pika-event-broker-connection
ricwo Sep 24, 2020
21c37b3
Merge branch 'master' into pika-event-broker-connection
alwx Sep 24, 2020
526c91b
Changelog entry update
alwx Sep 30, 2020
bed55f5
Pika import fixes
alwx Sep 30, 2020
1ab4126
Code style updates
alwx Sep 30, 2020
3a32684
Merge branch 'master' into pika-event-broker-connection
alwx Sep 30, 2020
e712927
Merge branch 'master' into pika-event-broker-connection
alwx Oct 1, 2020
6e0b86d
Merge branch 'master' into pika-event-broker-connection
alwx Oct 7, 2020
d15d733
Merge branch 'master' into pika-event-broker-connection
alwx Oct 8, 2020
21ee082
Black reformatting
alwx Oct 8, 2020
f8e6de8
Fix
alwx Oct 8, 2020
1e220c9
merge master
indam23 Oct 9, 2020
f2c3f62
monkeypatch pika test
indam23 Oct 9, 2020
50065c2
Merge branch 'master' into pika-event-broker-connection
alwx Oct 13, 2020
d3e6c13
Fix for running ioloop in a separate process
alwx Oct 13, 2020
25aa275
Update for `connect` function
alwx Oct 13, 2020
3efe6f9
Bugfix for .ready() function
alwx Oct 13, 2020
f92bf22
Removed unnecessary check
alwx Oct 13, 2020
f1beb7d
Better PikaMessageProcessor, with more callbacks and updated functions
alwx Oct 14, 2020
2e07743
Logger cleanup
alwx Oct 14, 2020
7d07c54
Code style updates
alwx Oct 14, 2020
ffb280d
Small bugfix
alwx Oct 14, 2020
d1e0e2b
Merge branch 'master' into pika-event-broker-connection
alwx Oct 14, 2020
b16375b
Test fix
alwx Oct 14, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions changelog/6760.bugfix.md
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
Update Pika event broker to be a separate process and make it use
alwx marked this conversation as resolved.
Show resolved Hide resolved
`multiprocessing.Queue` to send and process messages. This change should help
to avoid situations when events stop being send after a while.
alwx marked this conversation as resolved.
Show resolved Hide resolved
Loading