We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ff6ba2c commit 921215eCopy full SHA for 921215e
1 file changed
src/python_ms_core/core/queue/queue.py
@@ -22,19 +22,6 @@ def send(self, data=None):
22
sender.send_messages(self.provider.sender(json.dumps(message)))
23
self.queue = list()
24
25
- def send_local(self, data=None):
26
- if data:
27
- message = QueueMessage.to_dict(data)
28
- url = f'{self.provider.queue_name}/log'
29
- try:
30
- resp = requests.post(url, json=message)
31
- print(resp.status_code)
32
- except Exception as e:
33
- print(e)
34
- print(message)
35
-
36
- self.queue = list()
37
38
def add(self, data):
39
if data is not None:
40
self.queue.insert(0, json.dumps(data))
0 commit comments