Linux iad1-shared-b7-18 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64
Apache
: 67.205.6.31 | : 216.73.216.13
Cant Read [ /etc/named.conf ]
8.2.29
fernandoquevedo
Terminal
AUTO ROOT
Adminer
Backdoor Destroyer
Linux Exploit
Lock Shell
Lock File
Create User
CREATE RDP
PHP Mailer
BACKCONNECT
UNLOCK SHELL
HASH IDENTIFIER
README
+ Create Folder
+ Create File
/
usr /
share /
doc /
ruby-bunny /
examples /
guides /
queues /
[ HOME SHELL ]
Name
Size
Permission
Action
one_off_consumer.rb
516
B
-rw-r--r--
redeliveries.rb
1.97
KB
-rw-r--r--
Delete
Unzip
Zip
${this.title}
Close
Code Editor : redeliveries.rb
#!/usr/bin/env ruby # encoding: utf-8 require "rubygems" require "bunny" STDOUT.sync = true puts "=> Subscribing for messages using explicit acknowledgements model" puts connection1 = Bunny.new connection1.start connection2 = Bunny.new connection2.start connection3 = Bunny.new connection3.start ch1 = connection1.create_channel ch1.prefetch(1) ch2 = connection2.create_channel ch2.prefetch(1) ch3 = connection3.create_channel ch3.prefetch(1) x = ch3.direct("amq.direct") q1 = ch1.queue("bunny.examples.acknowledgements.explicit", :auto_delete => false) q1.purge q1.bind(x).subscribe(:manual_ack => true, :block => false) do |delivery_info, properties, payload| # do some work sleep(0.2) # acknowledge some messages, they will be removed from the queue if rand > 0.5 # FYI: there is a shortcut, Bunny::Channel.ack ch1.acknowledge(delivery_info.delivery_tag, false) puts "[consumer1] Got message ##{properties.headers['i']}, redelivered?: #{delivery_info.redelivered?}, ack-ed" else # some messages are not ack-ed and will remain in the queue for redelivery # when app #1 connection is closed (either properly or due to a crash) puts "[consumer1] Got message ##{properties.headers['i']}, SKIPPED" end end q2 = ch2.queue("bunny.examples.acknowledgements.explicit", :auto_delete => false) q2.bind(x).subscribe(:manual_ack => true, :block => false) do |delivery_info, properties, payload| # do some work sleep(0.2) ch2.acknowledge(delivery_info.delivery_tag, false) puts "[consumer2] Got message ##{properties.headers['i']}, redelivered?: #{delivery_info.redelivered?}, ack-ed" end t1 = Thread.new do i = 0 loop do sleep 0.5 x.publish("Message ##{i}", :headers => { :i => i }) i += 1 end end t1.abort_on_exception = true t2 = Thread.new do sleep 4.0 connection1.close puts "----- Connection 1 is now closed (we pretend that it has crashed) -----" end t2.abort_on_exception = true sleep 7.0 connection2.close connection3.close
Close