28
28
plugin.persist_name = "wubble"
29
29
plugin.register(self.monitor)
30
30
plugin.persist.set("hi", "there")
31
self.assertEquals(self.monitor.persist.get("wubble"), {"hi": "there"})
31
self.assertEqual(self.monitor.persist.get("wubble"), {"hi": "there"})
33
33
def test_with_no_run_interval(self):
90
90
self.mstore.add_schema(Message("wubble", {"wubblestuff": Int()}))
92
92
def test_get_message(self):
93
self.assertEquals(self.plugin.get_message(),
94
{"type": "wubble", "wubblestuff": 1})
93
self.assertEqual(self.plugin.get_message(),
94
{"type": "wubble", "wubblestuff": 1})
96
96
def test_get_message_unchanging(self):
97
self.assertEquals(self.plugin.get_message(),
98
{"type": "wubble", "wubblestuff": 1})
99
self.assertEquals(self.plugin.get_message(), None)
97
self.assertEqual(self.plugin.get_message(),
98
{"type": "wubble", "wubblestuff": 1})
99
self.assertEqual(self.plugin.get_message(), None)
101
101
def test_basic_exchange(self):
102
102
# Is this really want we want to do?
103
103
self.mstore.set_accepted_types(["wubble"])
104
104
self.plugin.exchange()
105
105
messages = self.mstore.get_pending_messages()
106
self.assertEquals(messages[0]["type"], "wubble")
107
self.assertEquals(messages[0]["wubblestuff"], 1)
106
self.assertEqual(messages[0]["type"], "wubble")
107
self.assertEqual(messages[0]["wubblestuff"], 1)
108
108
self.assertIn("Queueing a message with updated data watcher info for "
109
109
"landscape.monitor.tests.test_plugin.StubDataWatching"
110
110
"Plugin.", self.logfile.getvalue())
115
115
self.plugin.exchange()
116
116
self.plugin.exchange()
117
117
messages = self.mstore.get_pending_messages()
118
self.assertEquals(len(messages), 1)
118
self.assertEqual(len(messages), 1)
120
120
def test_urgent_exchange(self):