README.md | 100644 | 0 | 0 | | | 6.01 KB | 707f5b20ff9a191e2bcf2984c204760c0443bd34f21ed2f44fb4664897ae1899 |
Rakefile | 100644 | 0 | 0 | | | 1.74 KB | 996b7f9b5193294e26466441e0aea5dfaf877551c3599ddf5e49edb92fa2bfcf |
benchmarks/basic_publish/with_128K_messages.rb | 100755 | 0 | 0 | | | 659 Bytes | 2af1058d77a1a01de9116a9a35f8df5d2ffa5fef18efb3ff8b581d7cb67ae2f5 |
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/basic_publish/with_64K_messages.rb | 100755 | 0 | 0 | | | 658 Bytes | d0f1deee5fec75dace39299c5b6b7c882306a17ef62fc9ed69d17a74d9f777b9 |
benchmarks/queue_declare_bind_and_delete.rb | 100644 | 0 | 0 | | | 577 Bytes | 7d800b0b15d2adfc0cd4d7b5919958bc20644a75ecc9c0dbfa30ce3571945c17 |
docker-compose.yml | 100644 | 0 | 0 | | | 476 Bytes | e2d9bb93fad0e619fdb469988415b6c9653bcb52a2aa7a65392a9a1f6dc18e08 |
docker/Dockerfile | 100644 | 0 | 0 | | | 487 Bytes | 2ecb209c7ab4e35f97da72ca9e16ff3951500d1f435128d1efd8f5573ea090c6 |
docker/docker-entrypoint.sh | 100755 | 0 | 0 | | | 921 Bytes | 25c6bae5ee11f41ed2386a5b7204680471771844e2ae0d41925ef2a6771eb9ea |
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/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/consumers/high_and_low_priority.rb | 100644 | 0 | 0 | | | 1.1 KB | ba2ad988e640c98fe96f64d15e8200fca7e6a5da46b4931bb0e8642bf437a5fb |
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/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/alternate_exchange.rb | 100644 | 0 | 0 | | | 654 Bytes | c073d043b885aa2c69712c22b379cc0e4c40e60c888d00262e55b4e5707f8014 |
examples/guides/extensions/basic_nack.rb | 100644 | 0 | 0 | | | 571 Bytes | 22e3d2b74bfd9b7d16526b73bc75d1de43709397068c94391d4d057dea82c508 |
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/publisher_confirms.rb | 100644 | 0 | 0 | | | 538 Bytes | 50fb5618de80cf6c00262f37c79fecf1396185e1912212c5debd72ffc4b8226f |
examples/guides/getting_started/hello_world.rb | 100644 | 0 | 0 | | | 368 Bytes | 9f92bc366d5ab79b1de914ad55a00f321e3a6107a5a1ff806f46b2e4e7203520 |
lib/bunny/authentication/credentials_encoder.rb | 100644 | 0 | 0 | | | 1.38 KB | cda009d12000dfa418af15395d1139f54b9ab110b59d38fe2856ca523dad8160 |
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 | | | 1.21 KB | f02514b9119cc5a34c28cc74a28ea051091dca3b1594760aecb1ac2cc44cf6ba |
lib/bunny/cruby/socket.rb | 100644 | 0 | 0 | | | 3.64 KB | 0a1c3e88bacabe1d83a43c569dd9a51695686a06328e132106539c6d158e86bc |
lib/bunny/cruby/ssl_socket.rb | 100644 | 0 | 0 | | | 3.74 KB | 7a186afb57749794f85c9d6e0829c8780145f7dd9f0dca15109ad2089f8ca725 |
lib/bunny/delivery_info.rb | 100644 | 0 | 0 | | | 2.2 KB | 732cb137f7b82134a32c49fbe7ef1a014220b772e7e96b8db978509919d101e2 |
lib/bunny/exceptions.rb | 100644 | 0 | 0 | | | 7.58 KB | 541f4928702a0859a060550705f1b3353da8e5e0c86cef82ddd6ed0fedc58974 |
lib/bunny/exchange.rb | 100644 | 0 | 0 | | | 9.91 KB | 3613137b30fca2da371a36c91fc5dd34adee32369734a3cd3a567b06c7ad3ef3 |
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.3 KB | 5b79b8069c7b56ba824194239a1862918ed06f2d1d88cf256bbff816dd8b8bcd |
lib/bunny/reader_loop.rb | 100644 | 0 | 0 | | | 3.69 KB | 712030c904e39ab96431e33765ee703d2f69b19b6cea203a162bc4d3758f2bce |
lib/bunny/ssl_socket.rb | 100644 | 0 | 0 | | | 233 Bytes | 903ea72a761701b9402b4a15cae795c3683649e0d18dfcfa4d24b6a032117cdb |
lib/bunny/test_kit.rb | 100644 | 0 | 0 | | | 751 Bytes | 2d1712069761195ed9a7f740b00d3d2cccf37f4b71b96cc524a9d873259c1252 |
lib/bunny/timeout.rb | 100644 | 0 | 0 | | | 99 Bytes | 2a0948227595d7bc49c754617c89c5a6e3710bc5f05bcde4cf9050e99cd26f58 |
lib/bunny/transport.rb | 100644 | 0 | 0 | | | 14 KB | 5907e8c6711cdaefcaadb5bd3df3dd3fe879104a6b28d0603b82509f64c23907 |
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 | | | 434 Bytes | 6aeb0a7e82686693d8b7703b32b0b08648d49a3bd0760cc1812cdb59656ea975 |
spec/higher_level_api/integration/basic_ack_spec.rb | 100644 | 0 | 0 | | | 7.04 KB | e74a98f4ee9c054f34b87f864908f8ad2a4baffa0b06b8fbce70563006d53f56 |
spec/higher_level_api/integration/basic_cancel_spec.rb | 100644 | 0 | 0 | | | 3.57 KB | 6ec95722ba1702316b064862fd3c89205774e4cbb6d503ff7f3912b1b209879b |
spec/higher_level_api/integration/basic_consume_spec.rb | 100644 | 0 | 0 | | | 9.86 KB | 6b9d8f0cd13c11b4e66f1ff8c113f06dee54d1ca6b990b02fe7457c6c1e87044 |
spec/higher_level_api/integration/basic_consume_with_objects_spec.rb | 100644 | 0 | 0 | | | 1.28 KB | cac309c388bc13fa80a42c73f008e0f39fea759b857e740d316c70cef3d2156a |
spec/higher_level_api/integration/basic_get_spec.rb | 100644 | 0 | 0 | | | 1.42 KB | 888ee623d21f379e8cbbcbf03a0d5dff2fa166d015e7809b7e92b38a0e635e29 |
spec/higher_level_api/integration/basic_nack_spec.rb | 100644 | 0 | 0 | | | 2.13 KB | 6a3a986c9b2604357f4bc1abd774b06dbdbdf750441b7418980a2a7419ab7064 |
spec/higher_level_api/integration/basic_publish_spec.rb | 100644 | 0 | 0 | | | 1.6 KB | e929ea0cdc1160f35ac315dd1b22fa14c4f1cc6ff7b30c32b6a2c2d35c55b521 |
spec/higher_level_api/integration/basic_qos_spec.rb | 100644 | 0 | 0 | | | 1.59 KB | 920c832793575fd6e77271a2f3e2669f228edc6f24c59e330ccbb9d8706bdb74 |
spec/higher_level_api/integration/basic_reject_spec.rb | 100644 | 0 | 0 | | | 4 KB | f9416fcb60ce4b60e04974a161ab0c8cd2207d536268429d06e9c6af85ee5abe |
spec/higher_level_api/integration/basic_return_spec.rb | 100644 | 0 | 0 | | | 729 Bytes | 4bbd6b1ba96b80c433f5a9a5db8808f620bdd696dbc6422a268cf50941598c79 |
spec/higher_level_api/integration/channel_close_spec.rb | 100644 | 0 | 0 | | | 493 Bytes | 6f7fe318deaf6ca90f15da571f85127d721604cecf8342ae560dc1438d6711dc |
spec/higher_level_api/integration/channel_open_spec.rb | 100644 | 0 | 0 | | | 1.29 KB | 264048fbd09ae19cb1fbbe729456c16100c696e276abc4eb9f41efc7f10f9b13 |
spec/higher_level_api/integration/connection_recovery_spec.rb | 100644 | 0 | 0 | | | 12.4 KB | ef7aa830b6391b8ed36416d8469ee731381dbdd4280692f15985bada672d743e |
spec/higher_level_api/integration/exchange_bind_spec.rb | 100644 | 0 | 0 | | | 702 Bytes | f810bcfe74f603fd58d648a339af8edcc38a499a3389f2491bf7ae03d2c318b6 |
spec/higher_level_api/integration/exchange_declare_spec.rb | 100644 | 0 | 0 | | | 5.26 KB | 5f715d28e517c633a878e5e51317cf8dc78be751b0c842efa5f360566a3723a2 |
spec/higher_level_api/integration/exchange_delete_spec.rb | 100644 | 0 | 0 | | | 2.59 KB | 51ee96c1d40a6f2864af9ad10cc641405388d140b021a3be7685c6f393bfa1cc |
spec/higher_level_api/integration/exchange_unbind_spec.rb | 100644 | 0 | 0 | | | 861 Bytes | 51fb86330aee2b3fba1887f8394907522ff7461cca0a99c628b040c693cd20b2 |
spec/higher_level_api/integration/exclusive_queue_spec.rb | 100644 | 0 | 0 | | | 640 Bytes | 3e88771cb191f09a01af6897cfa38a0319cfcd289e390c797bfe6b1d4463eb3d |
spec/higher_level_api/integration/heartbeat_spec.rb | 100644 | 0 | 0 | | | 1.05 KB | 7e294061cca985790826138ee0c4bdda7027ed786d392ac5e210faecc4c2d77a |
spec/higher_level_api/integration/merry_go_round_spec.rb | 100644 | 0 | 0 | | | 1.81 KB | 5ae02288784a030b4e78f446a7209d5f2afadf2c904430d0393feec81693ba51 |
spec/higher_level_api/integration/message_properties_access_spec.rb | 100644 | 0 | 0 | | | 2.97 KB | d43764d072d0e386dcadc63823e36271870fa335c491c4e5fafed8c6c8fdee76 |
spec/higher_level_api/integration/predeclared_exchanges_spec.rb | 100644 | 0 | 0 | | | 497 Bytes | 7d1779f9d4fe648eb5bd5c83d94ac2ca237864c9c4f7b907a4ac60738587a6e8 |
spec/higher_level_api/integration/publisher_confirms_spec.rb | 100644 | 0 | 0 | | | 5.05 KB | 910f807e7f11a285aa3fb20439b61cc2bad62178c2b324654541b56d14e33485 |
spec/higher_level_api/integration/publishing_edge_cases_spec.rb | 100644 | 0 | 0 | | | 2.03 KB | 03e29b4c32173ba3c461121a0a9d1200e0f5ef114575d07c85449bf3661123ca |
spec/higher_level_api/integration/queue_bind_spec.rb | 100644 | 0 | 0 | | | 2.44 KB | ac644225abc34e8782c1cfeafbc7571ccd49cc1814cd40beaf1466dc88cef433 |
spec/higher_level_api/integration/queue_declare_spec.rb | 100644 | 0 | 0 | | | 5.03 KB | a00688f23800adbeb5b9830730878ae341be59969ba1eb3c347fde3c987fe1fd |
spec/higher_level_api/integration/queue_delete_spec.rb | 100644 | 0 | 0 | | | 913 Bytes | 50ee0953ebc48a0cf2161bd47388d981e874608b6b8634d2f3e2122f676f3858 |
spec/higher_level_api/integration/queue_purge_spec.rb | 100644 | 0 | 0 | | | 531 Bytes | 939e06f3bfc288642288c43ef3ba99a7c78e7f0a1c0e40695931b263bcc26ebc |
spec/higher_level_api/integration/queue_unbind_spec.rb | 100644 | 0 | 0 | | | 1.03 KB | 25ffdba3d4bfeb4c18abc6fc10d3b0745980f305d99f94a0b447810c0a7f496e |
spec/higher_level_api/integration/sender_selected_distribution_spec.rb | 100644 | 0 | 0 | | | 1.02 KB | 4e19638b00470de3edcf1780faa998f7d57d7f512778eca7205c3a2cf6b408cc |
spec/higher_level_api/integration/tls_connection_spec.rb | 100644 | 0 | 0 | | | 5.44 KB | 67d83ff09630e2ae9318e79aa0c536e64ab968ff99e1f8831e24b145e1e12ea9 |
spec/higher_level_api/integration/tx_commit_spec.rb | 100644 | 0 | 0 | | | 385 Bytes | ae1b8c686481b37175b4ba4a9110f807c0cd271cda7c2b4c2b17a3846523723a |
spec/higher_level_api/integration/tx_rollback_spec.rb | 100644 | 0 | 0 | | | 389 Bytes | 2ffa38ac36bfc5df401586fc42fd28ed458ada2a073f3fb2f25e616aa19f55b1 |
spec/higher_level_api/integration/with_channel_spec.rb | 100644 | 0 | 0 | | | 506 Bytes | 77516b19927477c0da15ed7ad39b2abdebd6c2f7b82975521368817b6a1b1bdb |
spec/issues/issue100_spec.rb | 100644 | 0 | 0 | | | 998 Bytes | baf7e72b4dc4260b64fd20f3bc4684b2e7b53803e487907a312b44140480a8dd |
spec/issues/issue141_spec.rb | 100644 | 0 | 0 | | | 961 Bytes | 62bd3305293e44e08af3045533d3a19d964d19e22f86556bbb01289a75acf69b |
spec/issues/issue202_spec.rb | 100644 | 0 | 0 | | | 353 Bytes | a16e6bf86593c5ca6b12f717e2a72d413038889584c93b75413b741f66b808b5 |
spec/issues/issue224_spec.rb | 100644 | 0 | 0 | | | 909 Bytes | 43ee24e5235880b8e0e52db9925a75f2cc44318f6a6f39da606d43cabc45b331 |
spec/issues/issue465_spec.rb | 100644 | 0 | 0 | | | 676 Bytes | 60a0103b99c54cb8adde19353f427a5e39d112a00380208ca60c79a2483366be |
spec/issues/issue78_spec.rb | 100644 | 0 | 0 | | | 1.81 KB | 67e77492a58d542dfb5e37e5554b93a2942a4b19e3c9eabc578ab2a95b1d288c |
spec/issues/issue83_spec.rb | 100644 | 0 | 0 | | | 616 Bytes | 13eedb1c0eed5d9a8471190ab5dff2c0c503fb79c02ee8b7fbd7d007b3d49a88 |
spec/issues/issue97_attachment.json | 100644 | 0 | 0 | | | 242 KB | 26676106f0f219a4d49e7d86f2446852a3c7a30e34727cca64da56faf2b8939c |
spec/issues/issue97_spec.rb | 100644 | 0 | 0 | | | 3.91 KB | a726ee3ee2de8d91caef3ba93e8552773130ccbbe46f7aa518322a51f91660e5 |
spec/lower_level_api/integration/basic_cancel_spec.rb | 100644 | 0 | 0 | | | 2.26 KB | cba033f9bf73cd078e7bd2f2cd1c791e57b4a5617e4173b0b1e299b1a7dd5d18 |
spec/lower_level_api/integration/basic_consume_spec.rb | 100644 | 0 | 0 | | | 2.79 KB | 070be01ad30526be6dd1aeb7d81a6ce9e6a7b790a61070a9e5f1232dc0c6fedb |
spec/spec_helper.rb | 100644 | 0 | 0 | | | 1.17 KB | fa7d4737d6e06fd55997e943e14fa6da82ff990324455935da41bb83c1ed1050 |
spec/stress/channel_close_stress_spec.rb | 100644 | 0 | 0 | | | 1.28 KB | a850dc083124f778a3a2618ea1174d930fbb837cda777030fb27044f04dea18b |
spec/stress/channel_open_stress_spec.rb | 100644 | 0 | 0 | | | 1.96 KB | 19a0ebd2e1735e691d778d2d22429eecc1fc8178321e8fc3e60412e5c3182af8 |
spec/stress/channel_open_stress_with_single_threaded_connection_spec.rb | 100644 | 0 | 0 | | | 663 Bytes | 2578fa0f578514cf81f45e4ed942ed5f19519e194f4bf41dd114fb2ab6292533 |
spec/stress/concurrent_consumers_stress_spec.rb | 100644 | 0 | 0 | | | 1.74 KB | 8c473922152a4da77031d21349ba93b203f288d34297426bf59ca15d9e6b412c |
spec/stress/concurrent_publishers_stress_spec.rb | 100644 | 0 | 0 | | | 1.09 KB | 9c74e0ece8a5110d809d6a7b24765f425150f2fd8c6a23ec01b22f72c8a08873 |
spec/stress/connection_open_close_spec.rb | 100644 | 0 | 0 | | | 1.26 KB | b8739644af498cc4f4d6198bd431e5b1c43f65df149a1953f0c7d26218570ede |
spec/stress/long_running_consumer_spec.rb | 100644 | 0 | 0 | | | 1.97 KB | 87739dd50129787ecc5f7f0ed91dfd62e966ed17288b1912d9b365b31de65828 |
spec/tls/ca_certificate.pem | 100644 | 0 | 0 | | | 1.75 KB | 24ea235a6b21d563076268469eac0846d8a7bdbb77f317a314e7572287a65333 |
spec/tls/client_certificate.pem | 100644 | 0 | 0 | | | 1.75 KB | 235b43b69ce04a4da66432846c0a01fdba1e50b194cd576a4533da37d10675ff |
spec/tls/client_key.pem | 100644 | 0 | 0 | | | 3.17 KB | 3f431ee642f5e955acc6ab46ab4bd643de4a60555d6ae2947fe6d97c10690d52 |
spec/tls/generate-server-cert.sh | 100755 | 0 | 0 | | | 473 Bytes | 69ecd6ac6945f36b96eaf68742f8dc2c01391323afa2e86532ca90e87d032f45 |
spec/tls/server-openssl.cnf | 100644 | 0 | 0 | | | 256 Bytes | 7f8cfbcfaa9aa1d3192c8f34c8632b7fb44c31be41e5afd821fdbffd2951aaf1 |
spec/tls/server.csr | 100644 | 0 | 0 | | | 968 Bytes | 21665d85a5f133df71614502c05f3eb43f745ad808c70a310744b613d97c7456 |
spec/tls/server_certificate.pem | 100644 | 0 | 0 | | | 1.75 KB | f32ae633eccbaa7fe005ba3409338b28534f3655e02726b67151772193bf3636 |
spec/tls/server_key.pem | 100644 | 0 | 0 | | | 3.17 KB | 7a7c96becf04db7432fd82cd78961e1d22d660b6baec5d0a1184750c3083daaf |
spec/unit/bunny_spec.rb | 100644 | 0 | 0 | | | 363 Bytes | 3fb542a56d71548bbd7fa0e4f1d9a776290eb1969bbc86d3bbff1aedd5721865 |
spec/unit/concurrent/atomic_fixnum_spec.rb | 100644 | 0 | 0 | | | 637 Bytes | 76b00ccaa75c704aa51a005d52641c7216eec5094972341b442f05ff3b626974 |
spec/unit/concurrent/condition_spec.rb | 100644 | 0 | 0 | | | 1.82 KB | 54d57ffae58e7a2d567026856d515986f782e18f6f720a5ca3d602bc6d755a01 |
spec/unit/concurrent/linked_continuation_queue_spec.rb | 100644 | 0 | 0 | | | 880 Bytes | 2e0b88c66d7bfd96bcc68815c0f8ec09b7a1d4083fca40a0796c7268f0faa6bd |
spec/unit/concurrent/synchronized_sorted_set_spec.rb | 100644 | 0 | 0 | | | 1.63 KB | 124ab061aaa6c5a6edf77e9ff313c316e16d95ff76f0905c4dd3032765f783b7 |
spec/unit/exchange_recovery_spec.rb | 100644 | 0 | 0 | | | 1.49 KB | e6cab6e17b9982133d7bca8de411e7e17f0f0107f7e2c6461fede0710b36ffcd |
spec/unit/version_delivery_tag_spec.rb | 100644 | 0 | 0 | | | 711 Bytes | 216fbab37fc9e45c67253fd3f4bf8b20390e975895d16edc4ad2ce72b1f22bcc |
.gitignore | 100644 | 0 | 0 | | | 266 Bytes | acaae79365efeb436efcd6845ac1bb2250cb434710d4bf013e4aab6e2ba7bd83 |
.rspec | 100644 | 0 | 0 | | | 7 Bytes | cf19dc54ecf1395360aff287041dd3d75bc41ef74c227604d6bc0db64c92719a |
.travis.yml | 100644 | 0 | 0 | | | 351 Bytes | 82821f09597024bd85cebfd17445134290bceb5778d56e1d801726d8b75d7e26 |
.yardopts | 100644 | 0 | 0 | | | 113 Bytes | b8fa93463f824e1309b4a583dbc48f890ea933dc39dce0e239dd2e783ef34539 |
CONTRIBUTING.md | 100644 | 0 | 0 | | | 3.69 KB | d5f3e3b1abd44265739832820d150b00bf8c925df41f4218c23ae21d21805547 |
ChangeLog.md | 100644 | 0 | 0 | | | 49.3 KB | 8ebc80fb30c93741bbdc0d97c23417311f9ca4e4627f558cb9b0fb353d82ca2c |
Gemfile | 100644 | 0 | 0 | | | 1.36 KB | cd977a2da65757fe58b9fee76474c4798707a59cea5d2ae492a8ee6189360ccd |
LICENSE | 100644 | 0 | 0 | | | 1.13 KB | 8f3f1bda505d59b54bf34a56b0ba8a7aef581667191255b1fbad8ad388d36873 |
benchmarks/channel_open.rb | 100644 | 0 | 0 | | | 445 Bytes | 0160d78cf9a8645ea0cec6102972e86656db27e48c79465a9144ed0760a070ce |
benchmarks/mutex_and_monitor.rb | 100644 | 0 | 0 | | | 708 Bytes | 778b4c4def7651db183f69ffc2e2e716dc658cc7139d4f8352bafe897a5fbfdb |
benchmarks/queue_declare.rb | 100644 | 0 | 0 | | | 530 Bytes | a38a99cf72910e51dbe925205de892941de1a23a888b7276e211587e4176a3bd |
benchmarks/queue_declare_and_bind.rb | 100644 | 0 | 0 | | | 548 Bytes | a6d02fb93ed4db8ed0b9c3d399ffa8e49940f8e0766372ac68385a854b260ea1 |
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 | 100755 | 0 | 0 | | | 1.73 KB | 812217562e4db119e0dc277769039d5b2bb7d527567238b305e26d9834ea896c |
bunny.gemspec | 100755 | 0 | 0 | | | 960 Bytes | 433b8e57c9b1423fc53a97c54f71d0510a0883d08ba907b4d75de8f79f9d8be7 |
examples/connection/channel_level_exception.rb | 100644 | 0 | 0 | | | 594 Bytes | a317fb39a8b28ecc0db5921df6f58ac44c9c032e4d416111f49f4d00ad9870fe |
examples/connection/disabled_automatic_recovery.rb | 100644 | 0 | 0 | | | 726 Bytes | 1a9e25a806fb36c3aa7ec2383ce8cb6aa7decb5928c8895f979a684dc3f985e7 |
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/extensions/queue_lease.rb | 100644 | 0 | 0 | | | 492 Bytes | f6e895f3bff05dad93302670998935dec4bf7ec2e5d9fb4a42ced886fd4d6ed6 |
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/weathr.rb | 100644 | 0 | 0 | | | 2.47 KB | db8f9f46e200b5e43abb672bbeb80b763fb2d090086ac15b5489cad73b19b6fc |
examples/guides/queues/one_off_consumer.rb | 100644 | 0 | 0 | | | 516 Bytes | 997bb2008b7b5c0788c5930d05ea1ba7ded46f03a56f54f18c42ca5c43c4ac20 |
examples/guides/queues/redeliveries.rb | 100644 | 0 | 0 | | | 1.97 KB | 1279523bc47231f4e2859887d2d2aab8d4e872c1b7b9ac3f5f751eb3f8455fa4 |
lib/amq/protocol/extensions.rb | 100644 | 0 | 0 | | | 267 Bytes | 48d54796662e32db2d63a5d935355d02fc4c069cfea373667f4de5b5d1bff54a |
lib/bunny.rb | 100644 | 0 | 0 | | | 1.98 KB | f017c4ca08c57ce689bda74bf66d74830371060a2c333c50187f0a88ea8216ad |
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 | | | 69.2 KB | 04daee458a6effa2977328fd629706707cdad1dac878562a9b04089676491583 |
lib/bunny/channel_id_allocator.rb | 100644 | 0 | 0 | | | 2.05 KB | 8a01e3dfab959ed23e2bec0b341ed485e7993214d4b86020fe009f595a65e72e |
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/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 | | | 2.29 KB | 3510ee71a7286500a215ba91680b0b1d38e1f776ff0d93abe6e494cc538d987b |
lib/bunny/framing.rb | 100644 | 0 | 0 | | | 1.75 KB | 49ba1bbea12c9df3ccbb9a944ee617fb85df824753a5967fddf5a47eb5dbe73c |
lib/bunny/get_response.rb | 100644 | 0 | 0 | | | 1.76 KB | 69ddc59e74ce700d26f6805727a56b902e614d4fdcc84afe49f853125d2e7fed |
lib/bunny/heartbeat_sender.rb | 100644 | 0 | 0 | | | 1.58 KB | 9b4be9e2c91bee24efd07e214a0bb935cb5d64bd809195734fe19d7e89ee706c |
lib/bunny/jruby/socket.rb | 100644 | 0 | 0 | | | 1.14 KB | 7c4e8992dccbe973c72c89cfdf8c9183a0ac7e4ac53e8c54923d4241cf1ad771 |
lib/bunny/return_info.rb | 100644 | 0 | 0 | | | 1.5 KB | 36c26d1f5c5b7918f4153aab8179241764cb2c91f70d3595f4f224fec4922121 |
lib/bunny/session.rb | 100644 | 0 | 0 | | | 46.7 KB | 759732e1cb2cd6349ed8a14ddd02ab2b2ed919f6ba4135e6dc2456c5f34e11bd |
lib/bunny/socket.rb | 100644 | 0 | 0 | | | 213 Bytes | 73243ad02add8a2d0a21b6a68c9725ef7ab4a69cb84fcb73ba6b3a2b7a62c53f |
lib/bunny/version.rb | 100644 | 0 | 0 | | | 100 Bytes | c9420abfca1990f1d7319beefc41152e04dc2131b32ec7db5778de36f79de3c9 |
lib/bunny/versioned_delivery_tag.rb | 100644 | 0 | 0 | | | 640 Bytes | 994f1fa66ed5ae05d9f4eae64a64ccb52f19c510bcd7fc1c73ffd551e35f84f3 |
spec/higher_level_api/integration/connection_spec.rb | 100644 | 0 | 0 | | | 15.2 KB | d8d3e48e73a6cfdf3206a67534733a34884c2e438f968c9e902e1c8eb79f07a7 |
spec/higher_level_api/integration/connection_stop_spec.rb | 100644 | 0 | 0 | | | 1.81 KB | f41c25b2ee3f9c3945e1194614957ed9fddc8fa20da0585f32098d705efe921f |
spec/higher_level_api/integration/consumer_cancellation_notification_spec.rb | 100644 | 0 | 0 | | | 2.94 KB | 75bd5113fda176ae81c139844e83ddb6036525e829ae7f0c9728d31db506e900 |
spec/higher_level_api/integration/dead_lettering_spec.rb | 100644 | 0 | 0 | | | 2.07 KB | a640e08f8d1a6061c33fc8d74efa66112816ed3b4be7e6b00ac01bd3b9ed04de |
spec/higher_level_api/integration/read_only_consumer_spec.rb | 100644 | 0 | 0 | | | 1.8 KB | 0ffd4adb0c978b83e3a799e57e9117f3ece36ebcdb8411c4a386e410e96343fb |
spec/tls/ca_key.pem | 100644 | 0 | 0 | | | 3.17 KB | 71f375ad34575b7f5d04b690bd1171c8fe0c6a90383e070688ecd3313e49ae34 |