yankee/yankee-gnome-fire-consumer
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

automated terminal push

Browse Source
This commit is contained in:
Your Name
2025-02-06 23:51:17 -05:00
parent c36503e6ef
commit 0d6d2ff76e
3 changed files with 85 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files

85
consumer.py
View File

@@ -1 +1,84 @@
print("hello") import stomp
import time
import SullyGnomeRobot
import RestAPIClient
print("## ")
print("## starting > JMS consumer (yankee-sully-channels-monthly)")
print("## ")
class MyListener(stomp.ConnectionListener):
def on_message(headers, message):
print("** new message! **")
print("message / ", message)
print("messagebody / ", message.body)
print("checking the value does or doesnt exist in db")
alreadyExistsSuccess = RestAPIClient.searchURLSuccesses(message.body)
print("alreadyExistsSuccess / ", alreadyExistsSuccess)
if alreadyExistsSuccess.lower().strip() == "true":
print("this record exists (successes). returning. doing nothing")
return
print("didn't exist in success. check in errors now.")
alreadyExistsFailure = RestAPIClient.searchURLFailures(message.body)
print("alreadyExistsFailure / ", alreadyExistsFailure)
if alreadyExistsFailure.lower().strip() == "true":
print("this record exists (failures). returning. doing nothing")
return
print("didn't exist in success or errors. will process now")
try:
SullyGnomeRobot.download(message.body)
except Exception as e:
print(f"exception / something went wrong when the sully gnome robot was downloading: {e}")
RestAPIClient.addDownloadFailure(message.body)
def on_error(headers, message):
print('received an error "%s"' % message)
RestAPIClient.addDownloadFailure(message.body)
print("## ")
print("## starting > JMS consumer (yankee-sully-channels-monthly)")
print("## ")
conn = stomp.Connection([('osiris.yankee.embanet.online', 61613)])
conn.set_listener('', MyListener())
conn.connect('admin', 'password', wait=True)
conn.subscribe('/queue/yankee-sully-channels-monthly', id=1, ack='auto', headers={'activemq.prefetchSize': 10})
print("## ")
print("## notification > connected to JMS server (yankee-sully-channels-monthly)")
print("## ")
while True:
pass
time.sleep(1)
conn.disconnect()

1
hello.py Normal file
View File

@@ -0,0 +1 @@
print("hello")

84
test.py
View File

@@ -1,84 +0,0 @@
import stomp
import time
import SullyGnomeRobot
import RestAPIClient
print("## ")
print("## starting > JMS consumer (yankee-sully-channels-monthly)")
print("## ")
class MyListener(stomp.ConnectionListener):
def on_message(headers, message):
print("** new message! **")
print("message / ", message)
print("messagebody / ", message.body)
print("checking the value does or doesnt exist in db")
alreadyExistsSuccess = RestAPIClient.searchURLSuccesses(message.body)
print("alreadyExistsSuccess / ", alreadyExistsSuccess)
if alreadyExistsSuccess.lower().strip() == "true":
print("this record exists (successes). returning. doing nothing")
return
print("didn't exist in success. check in errors now.")
alreadyExistsFailure = RestAPIClient.searchURLFailures(message.body)
print("alreadyExistsFailure / ", alreadyExistsFailure)
if alreadyExistsFailure.lower().strip() == "true":
print("this record exists (failures). returning. doing nothing")
return
print("didn't exist in success or errors. will process now")
try:
SullyGnomeRobot.download(message.body)
except Exception as e:
print(f"exception / something went wrong when the sully gnome robot was downloading: {e}")
RestAPIClient.addDownloadFailure(message.body)
def on_error(headers, message):
print('received an error "%s"' % message)
RestAPIClient.addDownloadFailure(message.body)
print("## ")
print("## starting > JMS consumer (yankee-sully-channels-monthly)")
print("## ")
conn = stomp.Connection([('osiris.yankee.embanet.online', 61613)])
conn.set_listener('', MyListener())
conn.connect('admin', 'password', wait=True)
conn.subscribe('/queue/yankee-sully-channels-monthly', id=1, ack='auto', headers={'activemq.prefetchSize': 10})
print("## ")
print("## notification > connected to JMS server (yankee-sully-channels-monthly)")
print("## ")
while True:
pass
time.sleep(1)
conn.disconnect()