changed naming of messaging methods

fixed_reply.py

@@ -44,9 +44,9 @@ class FixedReplyFlow(AtomicFlow):
         :param input_message: The input message
         :type input_message: FlowMessage
         """
-        reply = self._package_output_message(
+        reply = self.package_output_message(
             input_message=input_message,
             response={"fixed_reply": self.flow_config["fixed_reply"]}
         )
-        self.reply_to_message(reply=reply, to=input_message)
+        self.send_message(reply, is_reply = True)
 

run.py

@@ -77,10 +77,10 @@ if __name__ == "__main__":
     )
 
     #option2: use the proxy_flow
-    #input_message = proxy_flow._package_input_message(data = data)
+    #input_message = proxy_flow.package_input_message(data = data)
     
     #7. ~~~ Run inference ~~~
-    future = proxy_flow.send_message_blocking(input_message)
+    future = proxy_flow.get_reply_future(input_message)
     
     #uncomment this line if you would like to get the full message back
     #reply_message = future.get_message()