changed naming of messaging methods

ChromaDBFlow.py

@@ -143,8 +143,8 @@ class ChromaDBFlow(AtomicFlow):
                 )
             response["retrieved"] = ""
 
-        reply = self._package_output_message(
+        reply = self.package_output_message(
             input_message = input_message,
             response = response
         )
-        self.reply_to_message(reply = reply, to = input_message)
+        self.send_message(reply, is_reply = True)

VectorStoreFlow.py

@@ -167,8 +167,8 @@ class VectorStoreFlow(AtomicFlow):
             self.vector_db.add_documents(documents)
             response["retrieved"] = ""
 
-        reply = self._package_output_message(
+        reply = self.package_output_message(
             input_message = input_message,
             response = response
         )
-        self.reply_to_message(reply = reply, to = input_message)
+        self.send_message(reply, is_reply = True)

run.py

@@ -115,14 +115,14 @@ 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 ~~~
     print("##########CHROMA DB DEMO###############")
     #write to DB
-    proxy_flow_cdb.send_message_async(input_message_write)
+    proxy_flow_cdb.send_message(input_message_write)
     #read from DB
-    future = proxy_flow_cdb.send_message_blocking(input_message_read)
+    future = proxy_flow_cdb.get_reply_future(input_message_read)
     
     #uncomment this line if you would like to get the full message back
     #reply_message = future.get_message()
@@ -135,9 +135,9 @@ if __name__ == "__main__":
     
     print("##########VECTOR STORE DEMO###############")
     #write to DB
-    proxy_flow_vs.send_message_async(input_message_write)
+    proxy_flow_vs.send_message(input_message_write)
     #read from DB
-    future = proxy_flow_vs.send_message_blocking(input_message_read)
+    future = proxy_flow_vs.get_reply_future(input_message_read)
 
     #uncomment this line if you would like to get the full message back
     #reply_message = future.get_message()