import time
from crawler.message_bus import MessageBus


def test_receive_message():
    message_bus = MessageBus('queue-kafka-bootstrap:9092', 'tweet-created')
    message_bus.send(b'test_message')
    time.sleep(5)
    response = message_bus.consume_one()
    assert response.value == b'test_message'

051109e642c21e999075cb5bdefe2b5d2938f943
<mask token>

<mask token>


def test_receive_message():
    message_bus = MessageBus('queue-kafka-bootstrap:9092', 'tweet-created')
    message_bus.send(b'test_message')
    time.sleep(5)
    response = message_bus.consume_one()
    assert response.value == b'test_message'

import time
from crawler.message_bus import MessageBus


def test_receive_message():
    message_bus = MessageBus('queue-kafka-bootstrap:9092', 'tweet-created')
    message_bus.send(b'test_message')
    time.sleep(5)
    response = message_bus.consume_one()
    assert response.value == b'test_message'
