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.
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
624 convert qpid to amqp 1.0 #810
Conversation
|
nice work, looking forward for final review |
df7a08d
to
9f2fd40
Compare
6035c32
to
ac43cc6
Compare
kombu/transport/qpid.py
Outdated
|
|
||
| PY3 = sys.version_info[0] == 3 | ||
|
|
||
| StartConsumer = namedtuple('StartConsumer', ['queue']) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think a comment here would help to describe what these named tuples are for.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Great idea. I just pushed a change with docstrings for each object type.
8eb8303
to
0038711
Compare
Still working on basic_consume(), but everything else should work.
* Adds error raising in MainThread. * Removes several Channel methods so there is less to maintain * Pass in connection options and store them for the async connect * Many docstring improvements
It works with Pulp.
The workaround is already built in all the places this dependency will provided so this is safe to remove.
Also adds reconnect support for the QMF BrokerAgent Connection.
The objects used to pass "commands" between MainThread and ProtonThread had no documentation. This fixes that, and also renames one of them for clarity. Also added an else: clause where I saw it made sense to do that.
0038711
to
ebfc436
Compare
Since Pulp still won't run with vanilla qpid broker[1] it seems reasonable to refer to the RabbitMQ as the default broker instead. Fixes pulp#3366 https://pulp.plan.io/issues/3366 [1] celery/kombu#810
Since Pulp still won't run with vanilla qpid broker[1] it seems reasonable to refer to the RabbitMQ as the default broker instead. Fixes pulp#3366 https://pulp.plan.io/issues/3366 [1] celery/kombu#810
|
/rebase |
|
The rebase failed: To rebase manually, run these commands in your terminal: # Fetch latest updates from GitHub.
git fetch
# Create new working tree.
git worktree add .worktrees/rebase 624-convert-qpid-to-amqp-1.0
# Navigate to the new directory.
cd .worktrees/rebase
# Rebase and resolve the likely conflicts.
git rebase --interactive --autosquash master
# Push the new branch state to GitHub.
git push --force
# Go back to the original working tree.
cd ../..
# Delete the working tree.
git worktree remove .worktrees/rebase |
| qpid-python>=0.26 | ||
| qpid-tools>=0.26 | ||
| python-qpid-proton | ||
| qpid-tools |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i get this error while trying to install qpid-tools File "/tmp/pip-install-9104bo_x/qpid-python_a14df52a368846c0b0474e8c8647e96c/setup.py", line 42
raise DistutilsFileError,
^
SyntaxError: invalid syntax
----------------------------------------
ERROR: Command errored out with exit status 1: python setup.py egg_info Check the logs for full command output.
I wanted to see what the test runners said about the code I have. I had developed it against 3.0. All of the unit tests pass locally, but sometimes the PR test runners point out other issues.
I will rebase onto 4.0 soon and switch the target branch to 4.0 later. I don't plan to merge this to the 3.0 branch.