We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d9740e5 commit d2f0373Copy full SHA for d2f0373
plugins/sqs.py
@@ -68,8 +68,7 @@ async def get_payloads(server, config):
68
path = js.get('pubsub_path', '/') # Default to catch-all pubsub topic
69
payload = pypubsub.Payload(path, js)
70
server.pending_events.append(payload)
71
- backlog_size = server.config['clients'].get('payload_backlog_size',
72
- pypubsub.PUBSUB_DEFAULT_BACKLOG_SIZE)
+ backlog_size = server.config.backlog.queue_size
73
if backlog_size > 0:
74
server.backlog.append(payload)
75
except ValueError as e:
0 commit comments