65
66
class TestCassandra(fixtures.TestWithFixtures):
67
68
def test_add_message(self):
71
74
# Write the message out to Cassandra, and read it back in.
73
76
cmsg = c.messages.get(key)
75
78
# The archive should contain a single message, a reference to
78
81
self.assertEqual(1, len(archive_messages))
79
82
self.assertEqual(key, archive_messages[0][1])