def test_message(self, container_factory, rabbit_config):
from examples.retry import Service
container = container_factory(Service, rabbit_config)
container.start()
timestamp = arrow.utcnow().replace(seconds=+1)
publish = publisher(rabbit_config)
with entrypoint_waiter(
container, 'handle_message', callback=wait_for_result
) as result:
payload = {'timestamp': timestamp.isoformat()}
publish(payload, routing_key="messages")
res = result.get()
assert arrow.get(re.match("Time is (.+)", res).group(1)) >= timestamp
评论列表
文章目录