benchmarks/basic_publish/with_1k_messages.rb | 100755 | 0 | 0 | | | 651 Bytes | 14b595c11749a6d9a9757492c554469d1be6652088dc6587413fa2ffc7ebb9a0 |
benchmarks/basic_publish/with_4K_messages.rb | 100755 | 0 | 0 | | | 651 Bytes | df62437a1c301bf162719a18c7616e4c340ec2e4c52e001253af8af4d2c70f2b |
benchmarks/queue_declare.rb | 100644 | 0 | 0 | | | 530 Bytes | a38a99cf72910e51dbe925205de892941de1a23a888b7276e211587e4176a3bd |
benchmarks/queue_declare_and_bind.rb | 100644 | 0 | 0 | | | 548 Bytes | a6d02fb93ed4db8ed0b9c3d399ffa8e49940f8e0766372ac68385a854b260ea1 |
benchmarks/queue_declare_bind_and_delete.rb | 100644 | 0 | 0 | | | 577 Bytes | 7d800b0b15d2adfc0cd4d7b5919958bc20644a75ecc9c0dbfa30ce3571945c17 |
benchmarks/synchronized_sorted_set.rb | 100644 | 0 | 0 | | | 848 Bytes | c9a53e5fbf76c14974909f3fc3b958fd9fcbf3ff93ad018e0a891c828f4062b4 |
benchmarks/write_vs_write_nonblock.rb | 100644 | 0 | 0 | | | 922 Bytes | 595b6940202220ba27cc6c37060d1126a0459eabeb93ed948b1908506fef38cd |
bin/ci/before_build.sh | 100755 | 0 | 0 | | | 915 Bytes | 193c025e1522392f926f0beebc70ccbfdfbf676b2e218c74fcb0d2376c6e6de0 |
bunny.gemspec | 100755 | 0 | 0 | | | 1.07 KB | 61e071b7056587357f8ae07771ec087cf5dac9c038362a2cedc7e1808e0ecd0b |
examples/connection/authentication_failure.rb | 100644 | 0 | 0 | | | 341 Bytes | d1442ccf60e31c8e749f4984818f8cba2f6ace2f1b56e914f7206f89fefb4fbf |
examples/connection/automatic_recovery_with_basic_get.rb | 100644 | 0 | 0 | | | 813 Bytes | 3687e999dc332c6c98106b8b5283e74cbb98ead6acd25f6ca16431f25e2f1b7a |
examples/connection/automatic_recovery_with_client_named_queues.rb | 100644 | 0 | 0 | | | 800 Bytes | 661969b292873d31e5c0f3f51034c5b4dce08de9a1d975529f9a1eece1bc2b80 |
examples/connection/channel_level_exception.rb | 100644 | 0 | 0 | | | 829 Bytes | 1f4434508af2467de11c45623e677a33242f2fcfdd0592137ceb02caea285119 |
examples/connection/disabled_automatic_recovery.rb | 100644 | 0 | 0 | | | 726 Bytes | 1a9e25a806fb36c3aa7ec2383ce8cb6aa7decb5928c8895f979a684dc3f985e7 |
examples/consumers/high_and_low_priority.rb | 100644 | 0 | 0 | | | 1.1 KB | ba2ad988e640c98fe96f64d15e8200fca7e6a5da46b4931bb0e8642bf437a5fb |
examples/guides/exchanges/headers_exchange_routing.rb | 100644 | 0 | 0 | | | 866 Bytes | 6852a7f6823d35465279185910e223a862ae8281a5aae2364ed64c1648158192 |
examples/guides/exchanges/mandatory_messages.rb | 100644 | 0 | 0 | | | 662 Bytes | 20a2ce08a229da6d5230afba760a7aec7c9bf8ee6505a3982b314f84153ea417 |
examples/guides/extensions/connection_blocked.rb | 100644 | 0 | 0 | | | 660 Bytes | 88f83f7a8a8eade0cd59d533cd5c5c939fb75b0bde0b6ae7ee04b3877562982e |
examples/guides/extensions/consumer_cancellation_notification.rb | 100644 | 0 | 0 | | | 645 Bytes | 79a8aa806453481c0a3a1ce2f5c9328680c3f4c2748714b34360166c5c29d383 |
examples/guides/extensions/dead_letter_exchange.rb | 100644 | 0 | 0 | | | 744 Bytes | 3129d42d1c690e47c34eef70a2be30096f23edc15fe849a9ef5ca9f14ca2d780 |
examples/guides/extensions/exchange_to_exchange_bindings.rb | 100644 | 0 | 0 | | | 596 Bytes | 7e86af94c527704220786f6128782a7aa5e1fe208f38cae4ec0fe4159ae7c0b0 |
examples/guides/extensions/per_message_ttl.rb | 100644 | 0 | 0 | | | 607 Bytes | 7b53ebedabbfcf937705657f3d47d345356b8de74d13d58417c28320ac6fef80 |
examples/guides/extensions/per_queue_message_ttl.rb | 100644 | 0 | 0 | | | 633 Bytes | 35f4bbdc78140e7377335a7ec2d96183abd6c6010beec6301b773206be44b121 |
examples/guides/extensions/sender_selected_distribution.rb | 100644 | 0 | 0 | | | 956 Bytes | 53aaae043d0607f1359dbf5910bd69e3ff5beb5b693f45e6371f415447b80c7d |
examples/guides/getting_started/blabbr.rb | 100644 | 0 | 0 | | | 620 Bytes | 51fb9e6743488646674ece8234b98da15545af6d335c1ae62bc70b9921913aca |
examples/guides/getting_started/hello_world.rb | 100644 | 0 | 0 | | | 348 Bytes | 6ddb8294659103dd8bb0302433a241e1f8e1bd199927a5d18ef871a21d9317e8 |
examples/guides/getting_started/weathr.rb | 100644 | 0 | 0 | | | 2.45 KB | 1d1ca86c46941ef29acd5d5e35df7037a9f8d5ecc1a230149e42d0ee5b60b59a |
examples/guides/queues/one_off_consumer.rb | 100644 | 0 | 0 | | | 496 Bytes | 0be421ca7158e27ae977d730a719ded246b7dfd7d3c2e077f20b38cc1bc2c69a |
examples/guides/queues/redeliveries.rb | 100644 | 0 | 0 | | | 1.95 KB | 465113cef14a2870ba0f82575140c0a3bf40977f3844f0e75d36655fa466b4f1 |
lib/amq/protocol/extensions.rb | 100644 | 0 | 0 | | | 267 Bytes | 48d54796662e32db2d63a5d935355d02fc4c069cfea373667f4de5b5d1bff54a |
lib/bunny.rb | 100644 | 0 | 0 | | | 1.85 KB | cf2d9a2c3a787e8fc6ee0027b4a88b5e182f6cc320adfc813c0948a4c645fd5c |
lib/bunny/authentication/credentials_encoder.rb | 100644 | 0 | 0 | | | 1.38 KB | cda009d12000dfa418af15395d1139f54b9ab110b59d38fe2856ca523dad8160 |
lib/bunny/authentication/external_mechanism_encoder.rb | 100644 | 0 | 0 | | | 976 Bytes | 46c9d4407ef14f3f1ef828c361b07774c91c9d48e84ebb40e8d3e048da991cb0 |
lib/bunny/authentication/plain_mechanism_encoder.rb | 100644 | 0 | 0 | | | 491 Bytes | 743cdc3c6dc88f4e04c11ed0e14ba74a9bf1c98736c641de94a44f7273273fec |
lib/bunny/channel.rb | 100644 | 0 | 0 | | | 68 KB | 131dd8328e119010dd8e7e3c511582543a6b33a6f3deb1104fb1baaf789f6019 |
lib/bunny/channel_id_allocator.rb | 100644 | 0 | 0 | | | 2.04 KB | 3b9c78b5d8e7e9b23f1287ff241f4e95842a5bccf31ef51d27b54e68a5ebaa4e |
lib/bunny/concurrent/atomic_fixnum.rb | 100644 | 0 | 0 | | | 1.33 KB | c0e41caf4a0cdb34305c64a609e54c700f3be27872f7cbc8e9d26c7522f6b688 |
lib/bunny/concurrent/condition.rb | 100644 | 0 | 0 | | | 1.53 KB | 6b1ba4d8c64d4f0a26d1b7e7351213e04960ceeafcabb58e75ec6d17378a7ca6 |
lib/bunny/concurrent/continuation_queue.rb | 100644 | 0 | 0 | | | 748 Bytes | 9f9a5a6160599c2cd5e1732c9940610c52bb177a53df335fbf1c68ed3f6403e9 |
lib/bunny/consumer.rb | 100644 | 0 | 0 | | | 4.25 KB | 42a5a54aa0b10010a14b89f34585e6148e0273036e9591688c55146ef6492346 |
lib/bunny/consumer_tag_generator.rb | 100644 | 0 | 0 | | | 532 Bytes | ee0bf320b8fb1479c96d4f9f5c9eeff2b6d1d40db1a2c5a59347506c8d3412ed |
lib/bunny/consumer_work_pool.rb | 100644 | 0 | 0 | | | 1.47 KB | 4b7cb7ba2003a3d9fea3f7671201695654ac99846b0b3fe70670d5a888b76675 |
lib/bunny/cruby/socket.rb | 100644 | 0 | 0 | | | 2.98 KB | 7d423f27ae74321f55e1ae75a4f5343b6467403b48dbb444cbd0755c6a026395 |
lib/bunny/cruby/ssl_socket.rb | 100644 | 0 | 0 | | | 3.17 KB | 03b98301b277872da88f1779e5ec82d3656422dcd00c7ab5d0c917f5d362c964 |
lib/bunny/delivery_info.rb | 100644 | 0 | 0 | | | 2.2 KB | 732cb137f7b82134a32c49fbe7ef1a014220b772e7e96b8db978509919d101e2 |
lib/bunny/exceptions.rb | 100644 | 0 | 0 | | | 7.46 KB | a351f1c7c7920066988f70b5c71dccfc15bb859110bbbd02448d4b95e6f54a44 |
lib/bunny/exchange.rb | 100644 | 0 | 0 | | | 9.88 KB | ab6c6e1fa6c7af2645a671824dd4e4017b3db76b960ea65926c4fb4bd49ceb4f |
lib/bunny/framing.rb | 100644 | 0 | 0 | | | 1.75 KB | 49ba1bbea12c9df3ccbb9a944ee617fb85df824753a5967fddf5a47eb5dbe73c |
lib/bunny/get_response.rb | 100644 | 0 | 0 | | | 1.77 KB | 59abbaca3562dee3e21e0b03176341f6fbdc33ca8f2894175c24f281bc186320 |
lib/bunny/heartbeat_sender.rb | 100644 | 0 | 0 | | | 1.57 KB | 4e118fb5de3d0c02f621485c52701fdf304156af11b47cbfea9547dc989ba81c |
lib/bunny/jruby/socket.rb | 100644 | 0 | 0 | | | 1.13 KB | 45734268f9b772de3a28632333f76befd6edffe64aca4f7d55abbcd7f317cf0e |
lib/bunny/jruby/ssl_socket.rb | 100644 | 0 | 0 | | | 1.52 KB | 9e7e24ff20b14792743fd55cb408252347be45059c2c76578ecab4edfdd3fa75 |
lib/bunny/message_properties.rb | 100644 | 0 | 0 | | | 2.58 KB | 15a8948cd6abfb5d13f63803d2c7ab608096a85363541b6b6daa850a94b9e1bb |
lib/bunny/queue.rb | 100644 | 0 | 0 | | | 13.1 KB | 665a699d43b074586db67b1cd9c3d76c69f3aa99c5e53563c59a91dd239e2061 |
lib/bunny/reader_loop.rb | 100644 | 0 | 0 | | | 3.69 KB | 68737cf07f177f0096f1eae47d35dc2cb7c49c03d9506b8936983be8548ed29f |
lib/bunny/return_info.rb | 100644 | 0 | 0 | | | 1.5 KB | 36c26d1f5c5b7918f4153aab8179241764cb2c91f70d3595f4f224fec4922121 |
lib/bunny/test_kit.rb | 100644 | 0 | 0 | | | 751 Bytes | 2d1712069761195ed9a7f740b00d3d2cccf37f4b71b96cc524a9d873259c1252 |
lib/bunny/timeout.rb | 100644 | 0 | 0 | | | 451 Bytes | 6fcfbcd1434b0da65527e134ecdb8b6c22e8b4195ba197b79498ebc481a4cf11 |
lib/bunny/transport.rb | 100644 | 0 | 0 | | | 12.8 KB | 8f47dbb9e8595b4c967a894fcf56eb2ff1e2a3dec6fdcd599ea53e4ef5e72e28 |
lib/bunny/version.rb | 100644 | 0 | 0 | | | 104 Bytes | 006764bf464cf5717d0e67f35a47a20371191dc8a2a6433ede1dc94da7e3dbe2 |
lib/bunny/versioned_delivery_tag.rb | 100644 | 0 | 0 | | | 640 Bytes | 994f1fa66ed5ae05d9f4eae64a64ccb52f19c510bcd7fc1c73ffd551e35f84f3 |
profiling/basic_publish/with_4K_messages.rb | 100644 | 0 | 0 | | | 602 Bytes | 2b79e00954642dac96dfa3d85fd606fd196ad1a734eb29fcf814796d51736e80 |
repl | 100755 | 0 | 0 | | | 43 Bytes | 1ea349a752f6bf0520e62e19d3cec47647afa6d18dd942e94c7993f21f20a613 |
spec/config/enabled_plugins | 100644 | 0 | 0 | | | 58 Bytes | b69f9321f8965b4d1d1f60f5d23e3c40633049a97e056955e477c61a169f4d4a |
spec/config/rabbitmq.config | 100644 | 0 | 0 | | | 390 Bytes | 7e3db70feb338a233acaf46e29123c3f6f2f604065abbdaae821195908e72a2e |
spec/higher_level_api/integration/basic_ack_spec.rb | 100644 | 0 | 0 | | | 2.75 KB | 886fd21e92aed9b4f2d17ea6df2bd55305c2c5e6bd938e64c20f68dc2284d9bd |
spec/higher_level_api/integration/basic_cancel_spec.rb | 100644 | 0 | 0 | | | 1.85 KB | 6b282d31ea98ecf58a93e0497aace09e0b6f806b88a88be761b4de5a4ff0b028 |
spec/higher_level_api/integration/basic_return_spec.rb | 100644 | 0 | 0 | | | 739 Bytes | 40558f6061523e2264053fe6aa46dbe5f4234b9277ae238d9a6e9d164dd16cea |
spec/higher_level_api/integration/channel_close_spec.rb | 100644 | 0 | 0 | | | 490 Bytes | 5a6dbea9cfffb284d4f90495394357dda57b122926d3b638193b458b2d84b4cd |
spec/higher_level_api/integration/channel_open_spec.rb | 100644 | 0 | 0 | | | 1.26 KB | 59d04c8dee3f18141ccb2435a6096ea7d862aa632e7bef4e05c34d982561af7b |
spec/higher_level_api/integration/confirm_select_spec.rb | 100644 | 0 | 0 | | | 380 Bytes | bdeeb93e28c58e8beb69bbbfdc4bf2d50f8aba07d5c5df5b1bf1a0b3c2d0bd1f |
spec/higher_level_api/integration/connection_recovery_spec.rb | 100644 | 0 | 0 | | | 8.38 KB | af9ffb666e12766bf23d85c87e3df450c83cea841541857d55b1b439cc74261c |
spec/higher_level_api/integration/connection_spec.rb | 100644 | 0 | 0 | | | 11 KB | f6cd2bf17b5719c5f9f2c4cbee8d67be4faf8aca0d8157deb6fcca7740f8f2a4 |
spec/higher_level_api/integration/connection_stop_spec.rb | 100644 | 0 | 0 | | | 1.5 KB | 2f451ae534dffacd9fcb591f4241bc1f563f125a7ac52306fec1562665572508 |
spec/higher_level_api/integration/consistent_hash_exchange_spec.rb | 100644 | 0 | 0 | | | 1.26 KB | b755c95e8966fc1fdeb2c26a2ee4292c5f00f5aaf7586f6a9aea6afd6fc3f47b |
spec/higher_level_api/integration/exclusive_queue_spec.rb | 100644 | 0 | 0 | | | 657 Bytes | 39aa6db0a49103a6ff913d96a046a5da491faaa91fb985062d586ffc71dac9a7 |
spec/higher_level_api/integration/heartbeat_spec.rb | 100644 | 0 | 0 | | | 696 Bytes | 5da46795c3b928a3f7504b684401ac8871dea48226f0ce0f29447636c86575d6 |
spec/higher_level_api/integration/queue_delete_spec.rb | 100644 | 0 | 0 | | | 914 Bytes | e121b9fb0a2404115db97fb78d3305f182b85c00368630111b03382935acdc6c |
spec/higher_level_api/integration/queue_purge_spec.rb | 100644 | 0 | 0 | | | 534 Bytes | 6f2ab0e74008032eaa17ff9b6abb0686047e84801643250d414d306581596a05 |
spec/higher_level_api/integration/tx_commit_spec.rb | 100644 | 0 | 0 | | | 390 Bytes | e77941aff3e62e220a59bede5b456e178c9fea751c8a6a4eab3a497ef141fe64 |
spec/issues/issue141_spec.rb | 100644 | 0 | 0 | | | 946 Bytes | 3b9570c453575933c3d5551567e0fa1a2cf25d3c8f52c532bba55985b8327b19 |
spec/issues/issue202_spec.rb | 100644 | 0 | 0 | | | 353 Bytes | a16e6bf86593c5ca6b12f717e2a72d413038889584c93b75413b741f66b808b5 |
spec/issues/issue224_spec.rb | 100644 | 0 | 0 | | | 911 Bytes | cb85b93df68324f737318604ec013e6313651d1288d82bc4b68ce230c4571b09 |
spec/issues/issue78_spec.rb | 100644 | 0 | 0 | | | 1.82 KB | a573f0db67a13a10ec6fdf80ff1c80f23bdd3afa16a1b4b560360d2cdd37d2f8 |
spec/issues/issue83_spec.rb | 100644 | 0 | 0 | | | 606 Bytes | f2dd5e471f22e866435c18a34ec85c4ea3d8dd5f991d6cb7089e9a3daaebaf1a |
spec/issues/issue97_attachment.json | 100644 | 0 | 0 | | | 242 KB | 26676106f0f219a4d49e7d86f2446852a3c7a30e34727cca64da56faf2b8939c |
spec/issues/issue97_spec.rb | 100644 | 0 | 0 | | | 3.95 KB | 2f9225ad669d8408de9f8ca3c0463c2074c3e59b1db06a172004c05119b2d6b3 |
spec/lower_level_api/integration/basic_cancel_spec.rb | 100644 | 0 | 0 | | | 2.22 KB | 8be8646ac3f9440ae206d361dd9f38dd853fd60f5238cd136edc2c3b99ba2f7d |
spec/lower_level_api/integration/basic_consume_spec.rb | 100644 | 0 | 0 | | | 2.75 KB | ce3e2870f4d3a9c79118ad8d1cac320fcbe5dbf87d57ada0f1b6a3bfc4642f8f |
spec/spec_helper.rb | 100644 | 0 | 0 | | | 1.4 KB | ac8eb366ca7353f0e7c5d7c92eb3251cdf31b4e55f20003413f09d7ed2817401 |
spec/stress/channel_open_stress_spec.rb | 100644 | 0 | 0 | | | 1.96 KB | 7e95461e34e7be688e685520a676bfd675cf5aef75e9ba1c71feb75a1c50b1c8 |
spec/stress/channel_open_stress_with_single_threaded_connection_spec.rb | 100644 | 0 | 0 | | | 653 Bytes | b1afa911381504f2768630986466d8c2be94665669da68a59afda2a85fd94410 |
spec/stress/concurrent_consumers_stress_spec.rb | 100644 | 0 | 0 | | | 1.64 KB | a5ab8e396311ebf7099f9e6167213227c64e8031c84029601e87b28d3ab22235 |
spec/stress/concurrent_publishers_stress_spec.rb | 100644 | 0 | 0 | | | 1.22 KB | e4839f8a61527963aaffb34bfdfcd3d46b1702d89c721f432cffdada8ce16cbd |
spec/stress/connection_open_close_spec.rb | 100644 | 0 | 0 | | | 1.25 KB | b60d9e5e17354f2a9f29372e2929a02f9b3dc8cb008e0bb45ea11ad189be849d |
spec/stress/long_running_consumer_spec.rb | 100644 | 0 | 0 | | | 1.94 KB | 7864401626fce297d501547c17c139c280715235b275062e0cff649a94ef3add |
spec/tls/ca_certificate.pem | 100644 | 0 | 0 | | | 1.05 KB | 1d83933578d2d37f524c01c844800c1c7abab560cbacef8381bb71ed352b28e7 |
spec/tls/ca_key.pem | 100644 | 0 | 0 | | | 1.64 KB | 0601b4270ad7d7e2cd312b4f80929db880e72127919c6784048edf1416b059bf |
spec/tls/cacert.pem | 100644 | 0 | 0 | | | 1.04 KB | c6f4d60d15bc0aba93a3863419785ade95d08f6a10aa80e82daaba635cfa5ff1 |
spec/tls/client_cert.pem | 100644 | 0 | 0 | | | 1.07 KB | bcee43f54d0250b90ce8405312cf28210e3daf52d7cffd3f0c040572f4bdf4f8 |
spec/tls/client_key.pem | 100644 | 0 | 0 | | | 1.64 KB | 231cd3ea668c0d388a2133e62234e2bd895be9a606ee8fd7e04de1933625cb61 |
spec/tls/server_cert.pem | 100644 | 0 | 0 | | | 1.07 KB | a33253ed0b1ffc51678bf3512b265ba712b7dbf019c74f9c58774a6773ec880b |
spec/tls/server_key.pem | 100644 | 0 | 0 | | | 1.64 KB | 0be95b5d3de5ca9cc085b0d888dcf080bffb5aa202275a4ccd060377ed2fd5c5 |
spec/unit/bunny_spec.rb | 100644 | 0 | 0 | | | 343 Bytes | 4f2f7373a42fae69967bc7470e848e9399b00af695965d61da620c8fc6cd83b0 |
spec/unit/system_timer_spec.rb | 100644 | 0 | 0 | | | 307 Bytes | 3aadb8fe0daf048bf031fedbb28333636a0348df54986efaa90fe4ab63929e8e |
spec/unit/version_delivery_tag_spec.rb | 100644 | 0 | 0 | | | 699 Bytes | 150231f2e4ad2d1f8a35c05951758aaaafa592a9627813de41427a569da0b6d1 |
.gitignore | 100644 | 0 | 0 | | | 208 Bytes | f8a2fabc8bf70c1beefa386e7e7d32a8089a04764b29322dd507a3c15f494a0a |
.rspec | 100644 | 0 | 0 | | | 26 Bytes | 99a55beef45ee2dc451beab669ae2b64623e37daff59051ddfd70215fb9d79c5 |
.travis.yml | 100644 | 0 | 0 | | | 430 Bytes | 1f41b6669e94acd26b46183d2efeecf6f9680c172a506cdc96bf52543c42c059 |
.yardopts | 100644 | 0 | 0 | | | 113 Bytes | b8fa93463f824e1309b4a583dbc48f890ea933dc39dce0e239dd2e783ef34539 |
ChangeLog.md | 100644 | 0 | 0 | | | 37.3 KB | 5c3d009af3efb2dd0ca4b4591d3e748234e455f63e8669ff563fdc60746ef3b1 |
Gemfile | 100644 | 0 | 0 | | | 1.42 KB | 4eb77062918cfd785074f9850d631bc1ea44a18355ffb5eeee3145ca94919345 |
LICENSE | 100644 | 0 | 0 | | | 1.13 KB | 73f911e96d04bd6aa3e79065f419e236a3d4ddc6908224984d17ec0205c3cf30 |
README.md | 100644 | 0 | 0 | | | 7.64 KB | ca3e24ea3c704da2398ea8a24b1bac2642b3b829ed9c433e300656f39f109a4b |
benchmarks/basic_publish/with_128K_messages.rb | 100755 | 0 | 0 | | | 659 Bytes | 2af1058d77a1a01de9116a9a35f8df5d2ffa5fef18efb3ff8b581d7cb67ae2f5 |
benchmarks/basic_publish/with_64K_messages.rb | 100755 | 0 | 0 | | | 658 Bytes | d0f1deee5fec75dace39299c5b6b7c882306a17ef62fc9ed69d17a74d9f777b9 |
benchmarks/channel_open.rb | 100644 | 0 | 0 | | | 445 Bytes | 0160d78cf9a8645ea0cec6102972e86656db27e48c79465a9144ed0760a070ce |
benchmarks/mutex_and_monitor.rb | 100644 | 0 | 0 | | | 708 Bytes | 778b4c4def7651db183f69ffc2e2e716dc658cc7139d4f8352bafe897a5fbfdb |
examples/connection/automatic_recovery_with_multiple_consumers.rb | 100644 | 0 | 0 | | | 1.18 KB | 92626802b344a4f92dfd2fb03a56fe7bf91f8f69c64938a5b099cc1f010d9807 |
examples/connection/automatic_recovery_with_republishing.rb | 100644 | 0 | 0 | | | 2.82 KB | f251b87dbc57d3baaa8a65f041caff356b2f303a0d9b708c135143fcf12e6cea |
examples/connection/automatic_recovery_with_server_named_queues.rb | 100644 | 0 | 0 | | | 732 Bytes | fa121c3bba0b1530a63e3ec52fb1f2e8af2ac026b11cd118a4e4d5a4caabbec6 |
examples/connection/heartbeat.rb | 100644 | 0 | 0 | | | 235 Bytes | 7e8d7ed1b2ec40c77bf5972b1a60bd9aa5d3027aee9ca5867d777ab0931b394f |
examples/connection/manually_reconnecting_consumer.rb | 100644 | 0 | 0 | | | 446 Bytes | dcb459385960085a19b076b3aab210064cd780fdcbb9e4b2423d1a53053d7f10 |
examples/connection/manually_reconnecting_publisher.rb | 100644 | 0 | 0 | | | 412 Bytes | f92e8ed20f9b7bbe2a50c111f1937c90cf98b9530206d0017bb26770ee8b0c50 |
examples/connection/unknown_host.rb | 100644 | 0 | 0 | | | 327 Bytes | 7df0c8383f637c596a8e0c41796bddab3679a1d22d1077ea1fb838dce954c39b |
examples/guides/exchanges/direct_exchange_routing.rb | 100644 | 0 | 0 | | | 794 Bytes | 6d1f6ce27cf98ba6f6dccddfc5f5460331612181eb81016473cae872519cdfa8 |
examples/guides/exchanges/fanout_exchange_routing.rb | 100644 | 0 | 0 | | | 473 Bytes | 734f14d89687402ca88e80c69e34c4fbfbd6044120b3bdfa990764796c34a5b3 |
examples/guides/extensions/alternate_exchange.rb | 100644 | 0 | 0 | | | 634 Bytes | 866264b6c3404a7962523c6c04d1e49152ff9a9ff8df673005bd28a3d4f7936c |
examples/guides/extensions/basic_nack.rb | 100644 | 0 | 0 | | | 571 Bytes | 22e3d2b74bfd9b7d16526b73bc75d1de43709397068c94391d4d057dea82c508 |
examples/guides/extensions/publisher_confirms.rb | 100644 | 0 | 0 | | | 538 Bytes | 50fb5618de80cf6c00262f37c79fecf1396185e1912212c5debd72ffc4b8226f |
examples/guides/extensions/queue_lease.rb | 100644 | 0 | 0 | | | 492 Bytes | f6e895f3bff05dad93302670998935dec4bf7ec2e5d9fb4a42ced886fd4d6ed6 |
lib/bunny/concurrent/linked_continuation_queue.rb | 100644 | 0 | 0 | | | 1.6 KB | 718d9cbe76e7f8068d887522c7487b86a8981c29c8c01b191ab3746f82301a8d |
lib/bunny/concurrent/synchronized_sorted_set.rb | 100644 | 0 | 0 | | | 1.07 KB | da1ac3c54d31089265d9b6b0ba738163bf948082ae6379fca34e521e548b6b03 |
lib/bunny/session.rb | 100644 | 0 | 0 | | | 38.5 KB | 983fa806a01248e32ee92fc4139d6e83f0208fe33199358ec3baa78edc274f4d |
lib/bunny/socket.rb | 100644 | 0 | 0 | | | 213 Bytes | 73243ad02add8a2d0a21b6a68c9725ef7ab4a69cb84fcb73ba6b3a2b7a62c53f |
lib/bunny/ssl_socket.rb | 100644 | 0 | 0 | | | 233 Bytes | 903ea72a761701b9402b4a15cae795c3683649e0d18dfcfa4d24b6a032117cdb |
lib/bunny/system_timer.rb | 100644 | 0 | 0 | | | 473 Bytes | 773cbf99f6ce6b74c464b70bd834067e22e53d2a28007220d24862f3252ea886 |
spec/higher_level_api/integration/basic_consume_spec.rb | 100644 | 0 | 0 | | | 9.85 KB | ce8592f410d578cedfd12986de2ad83c1d108a5597fd71594357c81677a744d7 |
spec/higher_level_api/integration/basic_consume_with_objects_spec.rb | 100644 | 0 | 0 | | | 1.29 KB | 0131bcbc30261d229e46c7a768a0120892a686012f3c53fe4dbc890ceeb26490 |
spec/higher_level_api/integration/basic_get_spec.rb | 100644 | 0 | 0 | | | 1.42 KB | 450b2d5371c877413ec07d92a95b1523c37ee4de1875f8d63cada9cf4c63c69b |
spec/higher_level_api/integration/basic_nack_spec.rb | 100644 | 0 | 0 | | | 2.02 KB | 567bbb0995cc4711b4314c200a92b30f57b7f705de844ae9c91d26944e59eeed |
spec/higher_level_api/integration/basic_publish_spec.rb | 100644 | 0 | 0 | | | 3.99 KB | 0572d9ae769bf879a4d8e2d0fe69aa667aa9ac211f900a0855069524b7395500 |
spec/higher_level_api/integration/basic_qos_spec.rb | 100644 | 0 | 0 | | | 675 Bytes | e68ddacd006f5c8d9124721472b782a327d15a1a842209d9ffd1533682035687 |
spec/higher_level_api/integration/basic_recover_spec.rb | 100644 | 0 | 0 | | | 452 Bytes | 38471f9c0a10581fab7b24766f79a93575c1519e4a46306ffec305248d95ffaf |
spec/higher_level_api/integration/basic_reject_spec.rb | 100644 | 0 | 0 | | | 1.87 KB | 321e3b1c25a6ab31aeea11095522723aa9751f8409990cebfb3f173c414f631a |
spec/higher_level_api/integration/consumer_cancellation_notification_spec.rb | 100644 | 0 | 0 | | | 2.97 KB | 4566881da4313492c170ad4030efe692e7486b25db4c0bfd4ccd650e7411e78e |
spec/higher_level_api/integration/dead_lettering_spec.rb | 100644 | 0 | 0 | | | 1.4 KB | de4c5aa9b202429007dc045435a85f23d7084419c2b5ab2c153638cc9f3c3469 |
spec/higher_level_api/integration/exchange_bind_spec.rb | 100644 | 0 | 0 | | | 712 Bytes | 9ca2e83ad8f1147c4262749620cfe2a791a8ba99efd22e90e93ab5b98c898f62 |
spec/higher_level_api/integration/exchange_declare_spec.rb | 100644 | 0 | 0 | | | 5.18 KB | 01e742e9520ee8a55fb3dbcde08b713172d4f854c8193ed55537c0d3d830d1c4 |
spec/higher_level_api/integration/exchange_delete_spec.rb | 100644 | 0 | 0 | | | 2.55 KB | a171968d8daf53ef85faffe172cd541d5e7077934f73492bcbbcba4a6aa9fa91 |
spec/higher_level_api/integration/exchange_unbind_spec.rb | 100644 | 0 | 0 | | | 870 Bytes | 1347f94ed2bb3f5817a51a7ad66c1a5a416475ad716c96629ff23d93eb65cc44 |
spec/higher_level_api/integration/merry_go_round_spec.rb | 100644 | 0 | 0 | | | 1.85 KB | c8ad84a0692bba89d0d01b913b12177ae3152573da8a0351ad8f13fb7cdb331b |
spec/higher_level_api/integration/message_properties_access_spec.rb | 100644 | 0 | 0 | | | 3 KB | b66b5eaaee079fd68e2abee4f8a34ddde03a2aa8b50a1bc37b27b0524c6d2a65 |
spec/higher_level_api/integration/predeclared_exchanges_spec.rb | 100644 | 0 | 0 | | | 498 Bytes | 28533b6dec336b9cb9ebbce447c81cabfc7555a19dbccec77609af39239f915f |
spec/higher_level_api/integration/publisher_confirms_spec.rb | 100644 | 0 | 0 | | | 3.34 KB | 4255cfc392dd7d3b5a5dca7d6636afa2dd69c36cbc7bf04d57ed7e649c0b9503 |
spec/higher_level_api/integration/publishing_edge_cases_spec.rb | 100644 | 0 | 0 | | | 2.05 KB | 9136f7beeab48ca9b54ecfbba8593053516e65c6f32c94ae0297ece101a65d0a |
spec/higher_level_api/integration/queue_bind_spec.rb | 100644 | 0 | 0 | | | 2.42 KB | 8f2ebf9f677192bfbce0520d4832b51c40eadc2e65c65bfae1e1ba041f50ab81 |
spec/higher_level_api/integration/queue_declare_spec.rb | 100644 | 0 | 0 | | | 4.18 KB | 4f38ff26d6a7f0602ccb55976bebb32fd4a5ede9853aa6ecdf350ce7b540d017 |
spec/higher_level_api/integration/queue_unbind_spec.rb | 100644 | 0 | 0 | | | 1.04 KB | 4d05ff9038e911a8f6aa05b674c8a2cbf7ee873ab1da580ba1729c7ff9ea3d9b |
spec/higher_level_api/integration/read_only_consumer_spec.rb | 100644 | 0 | 0 | | | 1.82 KB | 81bbf3bc45cbb8393a48c84faea9ad97811e5f27767ec6fcd9ae951ebdeafc79 |
spec/higher_level_api/integration/sender_selected_distribution_spec.rb | 100644 | 0 | 0 | | | 1.04 KB | 3f37bcd81db30b8cc2f6ad2f4078ed5705bf2e86c6db4aebea13d112ef17a2f8 |
spec/higher_level_api/integration/tls_connection_spec.rb | 100644 | 0 | 0 | | | 3.21 KB | 6e58a7ad5276d4951c1791539a75760baf770049bdcecd11633a4427e2667d5c |
spec/higher_level_api/integration/tx_rollback_spec.rb | 100644 | 0 | 0 | | | 394 Bytes | 84e7192a223201b745cfebb88941c3a36fc609f148e16a58bdd1691d60f71c6a |
spec/higher_level_api/integration/with_channel_spec.rb | 100644 | 0 | 0 | | | 507 Bytes | 9a5f2b1c5e0a5adfea28ab14bca52fe0df0ad88c161d6e3ecbf722577369e0f6 |
spec/issues/issue100_spec.rb | 100644 | 0 | 0 | | | 970 Bytes | 511078b876a62ac1cc1955a76a507c789a3ed7622f1bb27e0cbd02781c835ca8 |
spec/unit/concurrent/atomic_fixnum_spec.rb | 100644 | 0 | 0 | | | 613 Bytes | 8c2f21818dee8aefa0d0bc7d20d0be0fcd7632d5f7ff0f54c378c9cf68f9c748 |
spec/unit/concurrent/condition_spec.rb | 100644 | 0 | 0 | | | 1.82 KB | 0b8d0669f49e45274bcffa02aa0270f01429003d14df93f07968777a8863ca4c |
spec/unit/concurrent/linked_continuation_queue_spec.rb | 100644 | 0 | 0 | | | 880 Bytes | 7474c088a832219ba01b6373cf8fe1e5444a30caf4602a0615080167f0a2b13e |
spec/unit/concurrent/synchronized_sorted_set_spec.rb | 100644 | 0 | 0 | | | 1.56 KB | a5e39a1ed65c71d24ab13c8f8d6f32ebb40caaf0cad1f17ce3410d74479fbd57 |