openstack/deb-python-pyngus
Code Issues Proposed changes

fix proton rename of local endpoint events

Browse Source
This commit is contained in:
Kenneth Giusti 2014-10-14 10:13:46 -04:00
parent b96c91a7aa
commit 0352dc9137
2 changed files with 6 additions and 6 deletions

4
python/pyngus/connection.py

@ -641,8 +641,8 @@ class Connection(Endpoint):
_endpoint_event_map = {
proton.Event.CONNECTION_REMOTE_OPEN: Endpoint.REMOTE_OPENED,
proton.Event.CONNECTION_REMOTE_CLOSE: Endpoint.REMOTE_CLOSED,
proton.Event.CONNECTION_OPEN: Endpoint.LOCAL_OPENED,
proton.Event.CONNECTION_CLOSE: Endpoint.LOCAL_CLOSED}
proton.Event.CONNECTION_LOCAL_OPEN: Endpoint.LOCAL_OPENED,
proton.Event.CONNECTION_LOCAL_CLOSE: Endpoint.LOCAL_CLOSED}
def _handle_proton_event(self, pn_event):
ep_event = Connection._endpoint_event_map.get(pn_event.type)

8
python/pyngus/link.py

@ -204,8 +204,8 @@ class _Link(Endpoint):
_endpoint_event_map = {
proton.Event.LINK_REMOTE_OPEN: Endpoint.REMOTE_OPENED,
proton.Event.LINK_REMOTE_CLOSE: Endpoint.REMOTE_CLOSED,
proton.Event.LINK_OPEN: Endpoint.LOCAL_OPENED,
proton.Event.LINK_CLOSE: Endpoint.LOCAL_CLOSED}
proton.Event.LINK_LOCAL_OPEN: Endpoint.LOCAL_OPENED,
proton.Event.LINK_LOCAL_CLOSE: Endpoint.LOCAL_CLOSED}
@staticmethod
def _handle_proton_event(pn_event, connection):
@ -766,8 +766,8 @@ class _SessionProxy(Endpoint):
_endpoint_event_map = {
proton.Event.SESSION_REMOTE_OPEN: Endpoint.REMOTE_OPENED,
proton.Event.SESSION_REMOTE_CLOSE: Endpoint.REMOTE_CLOSED,
proton.Event.SESSION_OPEN: Endpoint.LOCAL_OPENED,
proton.Event.SESSION_CLOSE: Endpoint.LOCAL_CLOSED}
proton.Event.SESSION_LOCAL_OPEN: Endpoint.LOCAL_OPENED,
proton.Event.SESSION_LOCAL_CLOSE: Endpoint.LOCAL_CLOSED}
@staticmethod
def _handle_proton_event(pn_event, connection):