diff options
Diffstat (limited to 'python/qpid/session.py')
| -rw-r--r-- | python/qpid/session.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/qpid/session.py b/python/qpid/session.py index 2f70461ab6..f500ab112f 100644 --- a/python/qpid/session.py +++ b/python/qpid/session.py @@ -344,6 +344,7 @@ class Incoming(Queue): self.destination = destination 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) |