Fixes param issues with AMQP transport
@@ -23,6 +23,7 @@ class ExampleAmqpService(object):
@amqp('example.route1')
async def route1a(self, data: Any) -> None:
+ banana = True
self.logger.info('Received data (function: route1a) - "{}"'.format(data))
@amqp('example.route1')
