Source code for pyicat_plus.tests.test_icat_mockup
[docs]
def test_stomp(icat_publisher, icat_subscriber):
icat_publisher.sendall(b"MYMESSAGE1\nMYMESSAGE2\n")
assert icat_subscriber.get(timeout=5) == "MYMESSAGE1"
assert icat_subscriber.get(timeout=5) == "MYMESSAGE2"