|
|
@ -341,8 +341,8 @@ class Connection(NetworkBase): |
|
|
|
result.extend(response_data) |
|
|
|
result.extend(response_data) |
|
|
|
page += 1 # Request the next page |
|
|
|
page += 1 # Request the next page |
|
|
|
|
|
|
|
|
|
|
|
_log.debug('%d messages, %d threshold' % (len(response_data, |
|
|
|
_log.debug('%d messages, %d threshold' % (len(response_data), |
|
|
|
self._options[self.NAMESPACE]['message_threshold']))) |
|
|
|
self._options[self.NAMESPACE]['message_threshold'])) |
|
|
|
|
|
|
|
|
|
|
|
if (len(response_data) <= |
|
|
|
if (len(response_data) <= |
|
|
|
self._options[self.NAMESPACE]['message_threshold']): |
|
|
|
self._options[self.NAMESPACE]['message_threshold']): |
|
|
|