diff options
| -rw-r--r-- | python/qpid/session.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/qpid/session.py b/python/qpid/session.py index f500ab112f..4a7ecbc28a 100644 --- a/python/qpid/session.py +++ b/python/qpid/session.py @@ -346,7 +346,7 @@ class Incoming(Queue): def start(self): self.session.message_set_flow_mode(self.destination, self.session.flow_mode.credit) for unit in self.session.credit_unit.values(): - self.session.message_flow(self.destination, unit, 0xFFFFFFFF) + self.session.message_flow(self.destination, unit, 0xFFFFFFFFL) def stop(self): self.session.message_cancel(self.destination) |