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