Mercurial > libervia-pubsub
changeset 203:2c46e6664680
Match wokkel API change for PubSubClient.
author | Ralph Meijer <ralphm@ik.nu> |
---|---|
date | Mon, 14 Jul 2008 09:16:16 +0000 |
parents | 77c61e2b8c75 |
children | b4bf0a5ce50d |
files | idavoll/gateway.py |
diffstat | 1 files changed, 9 insertions(+), 6 deletions(-) [+] |
line wrap: on
line diff
--- a/idavoll/gateway.py Wed Jun 25 12:27:55 2008 +0000 +++ b/idavoll/gateway.py Mon Jul 14 09:16:16 2008 +0000 @@ -411,12 +411,12 @@ return defer.succeed(None) - def itemsReceived(self, recipient, service, nodeIdentifier, items): + def itemsReceived(self, event): """ Fire up HTTP client to do callback """ - atomEntries = extractAtomEntries(items) + atomEntries = extractAtomEntries(event.items) # Don't notify if there are no atom entries if not atomEntries: @@ -427,18 +427,21 @@ payload = atomEntries[0] else: contentType = 'application/atom+xml;type=feed' - payload = constructFeed(service, nodeIdentifier, atomEntries, + payload = constructFeed(event.sender, event.nodeIdentifier, + atomEntries, title='Received item collection') - self.callCallbacks(service, nodeIdentifier, payload, contentType) + self.callCallbacks(event.sender, event.nodeIdentifier, payload, + contentType) - def deleteReceived(self, recipient, service, nodeIdentifier): + def deleteReceived(self, event): """ Fire up HTTP client to do callback """ - self.callCallbacks(service, nodeIdentifier, eventType='DELETED') + self.callCallbacks(event.sender, event.nodeIdentifier, + eventType='DELETED') def _postTo(self, callbacks, service, nodeIdentifier,