1import unittest 2 3import stomp 4from stomp.listener import TestListener 5from stomp.test.testutils import * 6 7 8class TestStompServerSend(unittest.TestCase): 9 10 def setUp(self): 11 pass 12 13 def testbasic(self): 14 conn = stomp.Connection10(get_stompserver_host()) 15 listener = TestListener('123') 16 conn.set_listener('', listener) 17 conn.start() 18 conn.connect(wait=True) 19 conn.subscribe(destination='/queue/test', ack='auto') 20 21 conn.send(body='this is a test', destination='/queue/test', receipt='123') 22 23 listener.wait_on_receipt() 24 25 conn.unsubscribe('/queue/test') 26 27 conn.disconnect(receipt=None) 28 29 self.assertTrue(listener.connections == 1, 'should have received 1 connection acknowledgement') 30 self.assertTrue(listener.messages == 1, 'should have received 1 message') 31 self.assertTrue(listener.errors == 0, 'should not have received any errors') 32