tpeetz/kontor
1
0
Fork 0
Code Issues 6 Pull Requests 2 Actions Packages Projects Releases 2 Wiki Activity

set messages durable

Browse Source
This commit is contained in:
Thomas Peetz
2025-07-10 15:58:11 +02:00
parent ee280e0b8e
commit d2d4deb350
1 changed files with 18 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kontor-scripts/read_list.py
+18 -7
View File
@@ -35,24 +35,32 @@ class AddLinkMessage(MessagingHandler):
conn = event.container.connect(self.server, user="artemis", password="artemis") conn = event.container.connect(self.server, user="artemis", password="artemis")
event.container.create_sender(conn, self.address) event.container.create_sender(conn, self.address)
def on_connection_opened(self, event: Event) -> None:
self.log.debug("connection open")
def on_connection_error(self, event: Event) -> None: def on_connection_error(self, event: Event) -> None:
self.log.info(f"error: {event}") self.log.info(f"error: {event}")
def on_sendable(self, event: Event): def on_sendable(self, event: Event):
self.log.info("send message") self.log.info("send message")
event.sender.send(Message(body=self.url, address=self.address, content_type="application/json")) message = Message(body=self.url, address=self.address, content_type="application/json", durable=True)
event.connection.close() delivery = event.sender.send(message)
self.log.info(f"Delivery {delivery} sent")
event.sender.close() event.sender.close()
event.connection.close()
def on_accepted(self, event: Event) -> None: def on_accepted(self, event: Event) -> None:
self.log.info(f"accepted: {event}") self.log.info(f"accepted Delivery: {event.delivery}")
def on_rejected(self, event: Event) -> None:
self.log.info(f"rejected Delivery: {event.delivery}")
if __name__ == '__main__': if __name__ == '__main__':
logging.basicConfig(level=logging.INFO, format='[%(asctime)s] {%(filename)s:%(lineno)d} %(levelname)s - %(message)s') logging.basicConfig(level=logging.INFO, format='[%(asctime)s] {%(filename)s:%(lineno)d} %(levelname)s - %(message)s')
logging.info('kontor.read_list started') logging.info('kontor.read_list started')
conn = stomp.Connection([('127.0.0.1', '61616')]) #conn = stomp.Connection([('127.0.0.1', '61616')])
conn.connect('artemis', 'artemis', wait=True) #conn.connect('artemis', 'artemis', wait=True)
if args.links: if args.links:
logging.info("read links from file") logging.info("read links from file")
links = read_links_file(args.links) links = read_links_file(args.links)
@@ -60,8 +68,11 @@ if __name__ == '__main__':
data_dict = {'url': link.strip()} data_dict = {'url': link.strip()}
data = json.dumps(data_dict) data = json.dumps(data_dict)
logging.info("send link message") logging.info("send link message")
Container(AddLinkMessage("amqp://127.0.0.1:5672", data, logging)).run() handler = AddLinkMessage("amqp://127.0.0.1:5672", data, logging)
container = Container(handler)
container.container_id = "process_add_links"
container.run()
# conn.send(body=data, destination='KontorMediaFile::add_link_file', headers={'content-type': 'application/json'}) # conn.send(body=data, destination='KontorMediaFile::add_link_file', headers={'content-type': 'application/json'})
conn.disconnect() #conn.disconnect()
logging.info('kontor.read_list finished') logging.info('kontor.read_list finished')