From 97fd356038b8881e02f899b51356abf981bd0c9e Mon Sep 17 00:00:00 2001 From: "DSTO\\pivatom" Date: Fri, 11 Jan 2019 11:40:27 +1030 Subject: [PATCH] Add mqtt messenger file for implementation of paxos messenger --- DecisionSystem/PaxosDecision/mqttmessenger.py | 42 +++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 DecisionSystem/PaxosDecision/mqttmessenger.py diff --git a/DecisionSystem/PaxosDecision/mqttmessenger.py b/DecisionSystem/PaxosDecision/mqttmessenger.py new file mode 100644 index 0000000..fc47ba2 --- /dev/null +++ b/DecisionSystem/PaxosDecision/mqttmessenger.py @@ -0,0 +1,42 @@ +from DecisionSystem.PaxosDecision.paxosmessenger import Messenger +from + +class MqttMessenger(Messenger): + + def __init__(self): + + + def send_prepare(self, proposal_id): + ''' + Broadcasts a Prepare message to all Acceptors + ''' + + + + def send_promise(self, proposer_id, proposal_id, previous_proposal): + ''' + Sends a Promise message to the specified Proposer + ''' + + NotImplementedError + + def send_accept(self, proposal): + ''' + Broadcasts an Accept message to all Acceptors + ''' + + NotImplementedError + + def send_accepted(self, proposal): + ''' + Broadcasts an Accepted message to all Learners + ''' + + NotImplementedError + + def on_resolution(self, proposal_id, value): + ''' + Called when a resolution is reached + ''' + + NotImplementedError \ No newline at end of file