From 6fb82d6538fdfefbf68cf145094bb91957cd141a Mon Sep 17 00:00:00 2001 From: Peter Kotyczka Date: Fri, 9 Feb 2024 00:46:10 +0100 Subject: [PATCH] send.py and test.py work --- app/message_producer.py | 26 ------------------ .../bindings/activemq-bindings-1.bindings | Bin 1048576 -> 1048576 bytes .../bindings/activemq-bindings-2.bindings | Bin 1048576 -> 1048576 bytes .../artemis-data/journal/activemq-data-1.amq | Bin 10485760 -> 10485760 bytes .../artemis-data/journal/activemq-data-2.amq | Bin 10485760 -> 10485760 bytes artemis/docker-compose-amq.yml | 3 +- 6 files changed, 2 insertions(+), 27 deletions(-) delete mode 100644 app/message_producer.py diff --git a/app/message_producer.py b/app/message_producer.py deleted file mode 100644 index 0f53e54..0000000 --- a/app/message_producer.py +++ /dev/null @@ -1,26 +0,0 @@ -from proton import Message -from proton.handlers import MessagingHandler -from proton.reactor import Container - - -class HelloWorld(MessagingHandler): - def __init__(self, server, address): - super(HelloWorld, self).__init__() - self.server = server - self.address = address - - def on_start(self, event): - conn = event.container.connect(self.server) - event.container.create_receiver(conn, self.address) - event.container.create_sender(conn, self.address) - - def on_sendable(self, event): - event.sender.send(Message(body="Hello World!")) - event.sender.close() - - def on_message(self, event): - print(event.message.body) - event.connection.close() - - -Container(HelloWorld("localhost:5672", "examples")).run() \ No newline at end of file diff --git a/artemis/artemis-data/bindings/activemq-bindings-1.bindings b/artemis/artemis-data/bindings/activemq-bindings-1.bindings index 64a0b8b03e47ed793c7b63be60fe3c9d8db62bc1..cac52e3fdbb2629c63c63444729e32f62b1b72cd 100644 GIT binary patch delta 479 zcmaiuI|{-;5QZo570pWmi8i`+S_rv83@GSDJb>W~G3aLxLu70M-WU=CY$^#!#CpPb9_eQ^7z#2i z_`xNohw%+A2~ypxYxOELy)&7Ln?CgW!7>OTxNA zA<9&)RJk1+H`(QB#hYdQ%?kCe^RF?VE8|mXpG(^UTpOSXTA&R&zyV#*11|7@4}wQ& Hhu7B!d5SO) delta 79 zcmZo@aA;_7*sz7EIgzD3k%bY6nShuXh(UZ-AZ7z%b|B^eVoo6D0%C3;<^f_}Am-bi O$ihGW_vQkYwTu9nHx{}8 diff --git a/artemis/artemis-data/bindings/activemq-bindings-2.bindings b/artemis/artemis-data/bindings/activemq-bindings-2.bindings index f0365b32a140cf8f4aef59348a2c3d8b96c5e1e2..134df1337840a27898ab17a39d07f1b769e4bfee 100644 GIT binary patch delta 74 zcmXxT$q|4c001#S@xHbrO2fyNWL=h^e#}g2Ewz>-gpj_!d?HbjG}20zPI?(+lu2e; LWR>k=zn>Uh+-?qw delta 74 zcmXxTM-hN9006-hdOt^z79J-FT}S{v?9A3$YAr_yA$@=OM4}|g(nu?v^fJgOlgzTn KD%-_=KQX-A1`de; diff --git a/artemis/artemis-data/journal/activemq-data-1.amq b/artemis/artemis-data/journal/activemq-data-1.amq index 42a33824e74ab5d1e868e7856bd36f5a731e7254..5c552a8f3a8b1b4304dd38ddfa9a14babf8a1313 100644 GIT binary patch delta 508 zcmXxbXFJsa06_6eE+xvzXeos<(hzBwMM^4LgHoZC($FUTubfCrJ0(7a&(%lZzHy%C z_wocm5DubJLZMJ>)Jh2vBt~LomBdL{;w3>=%Nj|PwUQ*svQE}ZibR(Uk}7GEE*Y{> zHpyn$B3mU>w#jzMk{z;BvL#1yWtZ%hJjs^=DU>}@Bzt9_?3V*lEC;1TO68E0$zeGn zN9CB5ONCTQl~hZO9G4SPD|K>G>gAN2mIgT^jdE7b$$4p#W@(XDX_I#8kWRTE7v+*% zmM-a*D{@tO+?NOPP#(#!JeDW&RG!Imc_A-l zL`LP6jLB;WBqHPTMkYjgE0Z!M?_^ru%Ln-=pX9U5$QSu4-{iaeke~8Pe#@-<79mkOzrDyfzlIW8xpR_f%WoRZUWM(X9PG{`wQFBhaynxt7;q*dCaT{`5VT$0Oj zMLMNRuF5s(mg{muZc2~zN}t@4+tM$0GkGpAee3u{cQ+~;e{FXm5D}QB9 N=H=fa3;&m5Ld&q&l&b&$ diff --git a/artemis/artemis-data/journal/activemq-data-2.amq b/artemis/artemis-data/journal/activemq-data-2.amq index fb3f4368eb525c21c2b7d165e52859941facdee5..45144fa3d7e852a57d21a76536f6c57498238024 100644 GIT binary patch delta 508 zcmXxbXFJsa06_6eE)wNrv{NV}4UvXfG^DaMC>2U64NXb^D<{&_QX-$i=jtPH-#E|n zdwGH&2nSKAp-?C`YNf;o5+kv)O5!9e@sc2kvRaa4jU-Eotd(_=D$!-Vq)EDDNTzI% zjj~BL%NE%x+hn_B$qv~m*^(o`$Dl{z^or{uJpk$O2R4RTJ-%LQqaCTW%yX_YonnnClfL$?`29p$Vd4kpXG~um1+4V-{pt=lwUFlTe|OLZf7Ak}0zkqKG8Du?8-9Fa09 zmkK#5m2ym~q*{*42{|b>QY&>*FAdTtr=&?vOS7DjvvN+(%LQqXR%w%V>5z-kDVOB3 zT#>7CO}gZ|+>o1cOK!^@xhwaiTkcDb^vVNyD37F19?KKymjQVy&ty=Z%L^HjmohA` zWJF%esJxLt#^kNMllP*G%Ln-=6Y@zu%NLoHDVdh9@=a!BR=&%e%*zj1ke~8P7G+6( N%b&k2|62)%RspiSl&k;% diff --git a/artemis/docker-compose-amq.yml b/artemis/docker-compose-amq.yml index 2df2331..14de2f7 100644 --- a/artemis/docker-compose-amq.yml +++ b/artemis/docker-compose-amq.yml @@ -15,7 +15,8 @@ services: - "./artemis-data:/var/lib/artemis-instance/data:rw" ports: - 8161:8161 - - 61616:61616 + - 61613:61616 + - 5672:5672 mem_limit: 512m mem_reservation: 256m networks: