Merge lp://staging/~free.ekanayaka/txamqp/amq-endpoint into lp://staging/txamqp
Status: | Merged | ||||
---|---|---|---|---|---|
Merged at revision: | 73 | ||||
Proposed branch: | lp://staging/~free.ekanayaka/txamqp/amq-endpoint | ||||
Merge into: | lp://staging/txamqp | ||||
Diff against target: |
364 lines (+345/-0) 4 files modified
src/txamqp/endpoint.py (+130/-0) src/txamqp/factory.py (+61/-0) src/txamqp/test/test_endpoint.py (+103/-0) src/txamqp/test/test_factory.py (+51/-0) |
||||
To merge this branch: | bzr merge lp://staging/~free.ekanayaka/txamqp/amq-endpoint | ||||
Related bugs: |
|
Reviewer | Review Type | Date Requested | Status |
---|---|---|---|
Esteve Fernandez | Approve | ||
Review via email:
|
Description of the change
This branch adds an AMQEndpoint class which has the same interface as a regular IStreamClientEn
Example code:
from twisted.internet import reactor
from twisted.
from txamqp.factory import AMQFactory
from txamqp.endpoint import AMQEndpoint
@inlineCallbacks
def connect():
endpoint = AMQEndpoint.
client = yield endpoint.
# ... "client" is a connected and authenticated AMQClient
For now no support for TLS connections is in place, but it'd be easy
to add as follow-up branch, if there's desire for it.
Thanks, changes look great!