CHANGELOG.md | 100644 | 0 | 0 | | | 3.12 KB | 8dde0e9010504618d16251f0a0b15b8b32465b74d6db917000b89432f5aa9f6c |
Gemfile | 100644 | 0 | 0 | | | 1.48 KB | e8d64cf62b82142dc57a6ad34a9013f4ac3567639d5e3d7026462bed6318ca0f |
Guardfile | 100644 | 0 | 0 | | | 2.38 KB | cfdb58d002d9b22a11e869ee5ced898ab0ad56bdf857257a9897333392637f58 |
LICENSE | 100644 | 0 | 0 | | | 1.06 KB | 26b96ec7a63901757dd1b4dd446524702ba794f6efaef0aabef11075c3b7aa73 |
README.md | 100644 | 0 | 0 | | | 1.38 KB | 5b6aa4ce63233699277eff6be1b8927f3de569e03324744ce7fbbaa3dca408d2 |
Rakefile | 100644 | 0 | 0 | | | 2.46 KB | 13a345f4c5bcc933bd7985f160cd05a0ff3807aa36d846ef4cf7bfe3608400d4 |
ci/reset_vhost | 100755 | 0 | 0 | | | 235 Bytes | 9893c130e6f09a633c22ef829888722dbeef1d35bf6bebad087229d15c619770 |
.coveralls.yml | 100644 | 0 | 0 | | | 25 Bytes | e5653a55637d6f5b58170e013404033194bf0039cb14b6a02b138986df046449 |
.gitignore | 100644 | 0 | 0 | | | 222 Bytes | 200cd3f42a532afcc868c33c9b1ed802f8b63a988527dc73041ed02edefb2c7a |
.relish | 100644 | 0 | 0 | | | 43 Bytes | a7fa1c610c72f6e7c7323ca529bb3eb13039c3b2732b1d153447b00d9c64ad3e |
.rspec | 100644 | 0 | 0 | | | 26 Bytes | 6f8fcfc5bfd33096b5db508443f3d8bcd0a1561afceedec438b31bac3edc8571 |
.rubocop.yml | 100644 | 0 | 0 | | | 958 Bytes | 6d49a79efeb83d6dbcdb8c2120c30da51acbf3a97a58ca2fde9e25ae3f839905 |
.rubocop_todo.yml | 100644 | 0 | 0 | | | 1.06 KB | 4084f84215305451e907d074fdf89caca89755ccd06e3013a36dfc687bda9e2d |
.travis.yml | 100644 | 0 | 0 | | | 712 Bytes | 921967c6f0a6fe644e48031a2736e3157b6162f00ce96d76cffccd841d0934b7 |
.yardopts | 100644 | 0 | 0 | | | 37 Bytes | 863d406bb435910b6c38b05a67cd27a366065cd7c9aab99d53cf8bc2682b7b1d |
examples/basic_producer_and_consumer/Gemfile | 100644 | 0 | 0 | | | 80 Bytes | 5966341c22e3c5f589635a05fc39f574d21f40dc9139eb6e9583506ccdb6025c |
examples/basic_producer_and_consumer/common.rb | 100644 | 0 | 0 | | | 360 Bytes | 6cb9799d746d66d02b921bc954e926a7a30fa62e66098ebfe6d0bcc74baf0bf1 |
examples/basic_producer_and_consumer/consumer.rb | 100644 | 0 | 0 | | | 471 Bytes | 4b73a21a8ea57951734f9f0805c47191dd26e44d62474a58b7ff6dd318ab4de8 |
examples/basic_producer_and_consumer/producer.rb | 100644 | 0 | 0 | | | 628 Bytes | 2c9bf51d4b214a160e411ccf80ee043d94849a3aa9a78ff3939d26cdb483ea53 |
features/.nav | 100644 | 0 | 0 | | | 883 Bytes | cb2b12536e7dc45910b17573aee9b4e9d2a423b0ba118c386cf2715c0823d87d |
features/CHANGELOG.md | 120755 | 0 | 0 | | ../CHANGELOG.md | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
features/README.md | 100644 | 0 | 0 | | | 56 Bytes | 28d40df1a62f0a3e36b7c8d05023269fc37968397931ffca56b43888ad432e7d |
features/Rails.md | 100644 | 0 | 0 | | | 37 Bytes | e99361dc07ae1ccd420ea3c90c73b7964733348a076e060dfcf9443cf2148648 |
features/amqp_specific_features/README.md | 100644 | 0 | 0 | | | 157 Bytes | 22e93610fb41af1987fb533ac029420d585b38b5881758931554ad33de53b106 |
features/amqp_specific_features/binding_amqp_destinations.feature | 100644 | 0 | 0 | | | 1.75 KB | df97049eb5f69731281ff32f7aa70e6f8dafa76a341dcb9fa9303260add575e7 |
features/amqp_specific_features/declaring_amqp_exchanges.feature | 100644 | 0 | 0 | | | 873 Bytes | 4ab533ac0360f355901e4749a60787e41d94028f38fd9e54a87c7bd3676eda12 |
features/amqp_specific_features/nack_redelivered_messages.feature | 100644 | 0 | 0 | | | 3.25 KB | 4bd0c48b8fd4ada6fe6b64376e4573c691daa27a77f00eadddc88234c79a20e4 |
features/amqp_specific_features/requeueing_on_nack.feature | 100644 | 0 | 0 | | | 1.25 KB | 3fe580e82c669d9b7a6b25cc112fbe910e8e88640409eb339757f26443fd7305 |
features/amqp_specific_features/server_named_destinations.feature | 100644 | 0 | 0 | | | 1.02 KB | 2c19e12a1a39fb694e8ed2471d63d2f9f53739e7b7cb207e63338bde2225d9bb |
features/client_acks.feature | 100644 | 0 | 0 | | | 2.55 KB | 85cfb9ee3e1adc8288695ec72227d37427e3fd219ad4c8f915ff512e6eb4a212 |
features/connecting_to_multiple_brokers.feature | 100644 | 0 | 0 | | | 1.61 KB | 8c4efee4325926a4fa1275d708a01819f45b8d62447e1522df2d5b0cc947d459 |
features/destination_metadata.feature | 100644 | 0 | 0 | | | 1.68 KB | f53825e82a4eb0f22985ef314795963f7ba4a952cb2154717f6f9a642e3753ad |
features/dynamic_destinations.feature | 100644 | 0 | 0 | | | 1.27 KB | 4066dda2c3c0a9061fccfac6387be3b35a531ae58d799af44ab6c9ae28340689 |
features/error_handling.feature | 100644 | 0 | 0 | | | 1.24 KB | 19b573a074f66290e0dfb5fe35d6a1b026a6fff09b728e4b86974637726b355f |
features/getting_started.md | 100644 | 0 | 0 | | | 27 Bytes | 2a6f2755548e00482444e9b6582bd498862217c6f006c8577e90d40cbd7d69e6 |
features/logging.feature | 100644 | 0 | 0 | | | 427 Bytes | d5b1fb5dd02c1ec06f7bb909f1f4407c5d426619da866d213bf8e49510d9d9c4 |
features/message_consumers/auto_ack_consumers.feature | 100644 | 0 | 0 | | | 2.37 KB | 3dabb827e5a7f17fcd6040ce55ed02e5c4ffc325c8fc7265c278238072a62fc4 |
features/message_consumers/basics.feature | 100644 | 0 | 0 | | | 1.55 KB | 2a11f5cc9a21c8af062fedb03d1075755ecea8296f79e66390cd4f0af7c3a019 |
features/message_consumers/manual_ack_consumers.feature | 100644 | 0 | 0 | | | 2.63 KB | 3cdf9f213d622552c7d151c3eae63d3bb5dc2eee87661b12fcf40e26fe52bba3 |
features/message_consumers/prefetch_size.feature | 100644 | 0 | 0 | | | 1.72 KB | f221e02f849b509cc8a821b6e17ef341fca473a07030fb52578ca4c2f13c3821 |
features/message_consumers/subscribe_with_a_block.feature | 100644 | 0 | 0 | | | 1.45 KB | fdf81b7c0ce5509dc7de9803b890e498f1663a952e58654ffbd240c1bc38499d |
features/message_consumers/transactional_ack_consumers.feature | 100644 | 0 | 0 | | | 2.52 KB | 1f4a66e2babcfe3d034775ea98e45c8d9e4e7374819fbe9207d6c814bb5436ae |
features/middleware/middleware_basics.feature | 100644 | 0 | 0 | | | 3.25 KB | 9675ec524c3d2d057fba0ffaaa8e86d696d12c49895a88b6231e8280eb043e39 |
features/middleware/middleware_error_handling.feature | 100644 | 0 | 0 | | | 3.6 KB | f803dba2bec224860e291beadee4a8506bdddba2fc914189a48e6c826dc5267f |
features/middleware/middleware_ordering.feature | 100644 | 0 | 0 | | | 2.03 KB | 17ead6980837ccd49cdd71c43fb280e7d4bcae578d50cfc742564a85f344cf2c |
features/middleware/middleware_parameters.feature | 100644 | 0 | 0 | | | 1.28 KB | ec1f4a7668eadfb005a5240d81738d33e51822119d0e302484b4f1349dc94f9c |
features/middleware/middleware_with_blocks.feature | 100644 | 0 | 0 | | | 3.03 KB | d229fb25a9b5c9e8c271debfa0febb811004897f8ef1998524fc39bc18986657 |
features/publishing_a_message.feature | 100644 | 0 | 0 | | | 410 Bytes | a8011d2a4cb5edb5c81936d9340e70abfb564810d50bb1765cef788a2af5ed23 |
features/publishing_with_transactions.feature | 100644 | 0 | 0 | | | 1.03 KB | e11f8379943a7301eee82c830c2b3f1cf362f3c3be1cf84d049c1a51502d7863 |
features/rabbitmq_specific_features/dead_letter_queueing.feature | 100644 | 0 | 0 | | | 3.59 KB | 87b1f9c91a49b1fe2fba757da7d4547b5f0f054a6fabfe123c4e246b03e9ab03 |
features/rabbitmq_specific_features/publisher_acknowledgements.feature | 100644 | 0 | 0 | | | 1.63 KB | 3e8248880bd50724061af333ff24f3c921efa58298a0f106a62fd5cbb213533a |
features/step_definitions/dynamic_destinations_steps.rb | 100644 | 0 | 0 | | | 682 Bytes | d482ac485b1b5ce1772f1865e88caa3334993193a08a0c9289ec922e68540d35 |
features/step_definitions/error_handling_steps.rb | 100644 | 0 | 0 | | | 169 Bytes | 1d00d46bdec9243ae13210c988055a9aeaa9dbdddfeb7423cc551f1eab5169c0 |
features/step_definitions/logging_steps.rb | 100644 | 0 | 0 | | | 827 Bytes | 4dfb602ce4e1f3380138341cdf3741248ea45074e5bd4ecde073d8c13615df72 |
features/step_definitions/message_consumers_steps.rb | 100644 | 0 | 0 | | | 851 Bytes | d76cbeb7803f4ed6369c4aafef0883a19357b9150405a3295f15a0650a50f9d1 |
features/step_definitions/middleware_steps.rb | 100644 | 0 | 0 | | | 362 Bytes | 8ce68ee423d1138d185f14bc17984c74e0bbfd644d874192468154ea6e5edd11 |
features/step_definitions/rabbitmq_specific_steps.rb | 100644 | 0 | 0 | | | 368 Bytes | 8a0f9b4136cbf9d94576763c7ec4d76955d9f82aab30cd76a2b127cbf5d2a17f |
features/step_definitions/steps.rb | 100644 | 0 | 0 | | | 3.49 KB | 4ee63d6cabb5ba4d393c28e05e1b2d5d42953f97598b9fafd9b76205e6c11f34 |
features/support/broker_config_helper.rb | 100644 | 0 | 0 | | | 250 Bytes | 1549264eb47c823664889e97621df3dba6438a01c9fcf56081116ea3f79027d0 |
features/support/env.rb | 100644 | 0 | 0 | | | 318 Bytes | bbcf8d70acc95ced3e74ad42434ba25e3ec61b31b653c90b017706ad8070f81f |
features/support/firewall_helper.rb | 100644 | 0 | 0 | | | 911 Bytes | c79096d1f8b1876d814c9aaf6456c7bed3a5f96b2897140befe6dfdbaa97ffd5 |
features/support/message_table_matcher.rb | 100644 | 0 | 0 | | | 630 Bytes | 33eb63e81f34e914b3c4be5eb831f18d5d57a7febd36e4eb012cd08bb9ddaa7d |
features/support/no_error_matcher.rb | 100644 | 0 | 0 | | | 381 Bytes | d2591f19e2813af3dd698eff9b6533dd80ad2df9391e531c62f06641057e99f7 |
features/support/test_runner.rb | 100644 | 0 | 0 | | | 901 Bytes | 6539b802a706a4757378440082c8998fc22e6b3deb859f613eff5367a673fa66 |
features/support/transforms.rb | 100644 | 0 | 0 | | | 278 Bytes | b069bc9c9db4759c79d391e69e4290bab304d67140c2ebbc20c6887356396428 |
lib/message-driver.rb | 100644 | 0 | 0 | | | 25 Bytes | 7e6e275c8b82ee80d56f9a642f29f609490fabdd362e8e5487dc47847cbd76b0 |
lib/message_driver.rb | 100644 | 0 | 0 | | | 887 Bytes | b284e4699ba80561db8cfb40aca15c90e8b65126a7f4c5688aac7e7a0991d191 |
lib/message_driver/adapters/base.rb | 100644 | 0 | 0 | | | 4.64 KB | 1e6f51a8a171f5eb8f52eba9df9f6657028399c9dd911f505a5732ee6a64f2d5 |
lib/message_driver/adapters/bunny_adapter.rb | 100644 | 0 | 0 | | | 17.3 KB | 858336f3d07c4e544b1832f61146edee0acdb285fd677c694b4ada42ba1913be |
lib/message_driver/adapters/in_memory_adapter.rb | 100644 | 0 | 0 | | | 4.74 KB | 6a5d170144b16bf243729f79637df1b9c75e28840ef1373db2fba0706db51877 |
lib/message_driver/adapters/stomp_adapter.rb | 100644 | 0 | 0 | | | 3.35 KB | 6e05639c3ad2074e19d2ae3a6717c34388c125fe9dd17442d5bd4d8322eeead4 |
lib/message_driver/broker.rb | 100644 | 0 | 0 | | | 5.97 KB | 71cbd45de4b673293e66501bc35a2d460d382b98bb7bfd88a88b3fe68972699c |
lib/message_driver/client.rb | 100644 | 0 | 0 | | | 5.53 KB | d449f6b313f8cb8d5efed15aacddfd09a1b7e62f0ecd902e8ccd3025da3f933e |
lib/message_driver/destination.rb | 100644 | 0 | 0 | | | 1.25 KB | a9e6327664d8c3d5078cc8652337eaf9d3f1af5372cc05bd60f8a84c6de18ff5 |
lib/message_driver/errors.rb | 100644 | 0 | 0 | | | 670 Bytes | 997f2b83e7f65524143c69d7d194bef65e0a31e7db9f3a9c0d860bb88857f7ac |
lib/message_driver/logging.rb | 100644 | 0 | 0 | | | 325 Bytes | 39ccff8d64b843eeb93a4e6514ac05222c68fa98a66072d4259d38a8820d7459 |
lib/message_driver/message.rb | 100644 | 0 | 0 | | | 874 Bytes | b21b172abee276da110ce1fc52643cada44b9445acce0692bbbda1e19f700301 |
lib/message_driver/middleware.rb | 100644 | 0 | 0 | | | 199 Bytes | 3c63ce7debac87855fb6b421c7d9df7f9eec75e404d68706542cf4714a3a28cc |
lib/message_driver/middleware/base.rb | 100644 | 0 | 0 | | | 368 Bytes | f76db73208a7623c2d32abb65d791145c7221971061dcb5af7815973ccb2defd |
lib/message_driver/middleware/block_middleware.rb | 100644 | 0 | 0 | | | 970 Bytes | b7ec02bc2aa66592c1035b677dd74030f6e29e7ea9096eeaba971592ceb7b2ed |
lib/message_driver/middleware/middleware_stack.rb | 100644 | 0 | 0 | | | 1.4 KB | 84e38e2f0bec5b9a9301ef71a8dae11f2bcd7f5365797fc29df549ebe04a9c62 |
lib/message_driver/subscription.rb | 100644 | 0 | 0 | | | 437 Bytes | c2493566320ee007b3ea391e2c002b0eac9fa858d21fa12b4e8b900af351d6bc |
lib/message_driver/version.rb | 100644 | 0 | 0 | | | 96 Bytes | 05ecb7d6559e6c8e0a281b50df6ea9c1ca92f6a36e57354ac5676c967b5b52e9 |
lib/vendor/.document | 100644 | 0 | 0 | | | 0 Bytes | e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855 |
lib/vendor/nesty.rb | 100644 | 0 | 0 | | | 36 Bytes | 3fdd2a95373c2a69e416739152d634a5d82a7c2be7e32b319f0e6b7518ea3b86 |
lib/vendor/nesty/nested_error.rb | 100644 | 0 | 0 | | | 695 Bytes | 625b4713e5c3613aaf7eb0f80e005a811f2e4aa4ce31310d41ab2ebaf3d2cfa5 |
message-driver.gemspec | 100644 | 0 | 0 | | | 1.05 KB | 5e47c29499ef498a35a7d7db01dfb2b143b7dd8a9175743244f2f66a9fc06206 |
spec/integration/bunny/amqp_integration_spec.rb | 100644 | 0 | 0 | | | 3.29 KB | 8faf22efd7de83991872b5183a729106eeb2dcaf63c9e5a97b5cf8c94b1dd7f7 |
spec/integration/bunny/bunny_adapter_spec.rb | 100644 | 0 | 0 | | | 19 KB | 1d9e012b245389ebd0694f6bb69ab63fc8d0420333be847196c9414b15bb7d27 |
spec/integration/in_memory/in_memory_adapter_spec.rb | 100644 | 0 | 0 | | | 5.21 KB | f82594748370dbb3ee9be77f86074889ad53cb182e8c62b0940e9fdef31eec3c |
spec/integration/stomp/stomp_adapter_spec.rb | 100644 | 0 | 0 | | | 5.97 KB | 6d590a5b763693b7182f97ea36bdf12aa68d1b7109a02b71209a89a71438994e |
spec/spec_helper.rb | 100644 | 0 | 0 | | | 1.1 KB | 39e044d4e1a15825e0c76b746b5311d52f7b33fead605b16e0a3d9d4f04cca7f |
spec/support/matchers/override_method_matcher.rb | 100644 | 0 | 0 | | | 211 Bytes | f027cc9b16986667763572dbd8cbeb7dd8864ce2e71513b3291c2012806bb37b |
spec/support/shared/adapter_examples.rb | 100644 | 0 | 0 | | | 747 Bytes | 6dd97d95bfffb780ee74032bd36cc9b90c164175c356cef3fb562bf8f23697d0 |
spec/support/shared/client_ack_examples.rb | 100644 | 0 | 0 | | | 1.22 KB | c904f06ed413b024b7582194d13fb6f4acf49f3cd90a98824d264c72eabed2a1 |
spec/support/shared/context_examples.rb | 100644 | 0 | 0 | | | 2.8 KB | a14a015b5ac1874c3304f87741c839e2b2bdae4b4a6cecbf3bffd4342bfc7e50 |
spec/support/shared/destination_examples.rb | 100644 | 0 | 0 | | | 3.24 KB | ab57f2339a4fa8776de4d91d67fdc4063d0d492a0d84d7438cf1872e1d29b06e |
spec/support/shared/subscription_examples.rb | 100644 | 0 | 0 | | | 4.44 KB | 429acddc398f88a26f2541b46ff4f184418084d0c8c876e8b51581c3528654d0 |
spec/support/shared/transaction_examples.rb | 100644 | 0 | 0 | | | 2.45 KB | d0c95767be2e75a927aa2c8a89d6aaa6f53d41163f624368fb577d31db3a4ac9 |
spec/support/test_adapter.rb | 100644 | 0 | 0 | | | 490 Bytes | c708fd7da24b6e4ecd56307650ce967fa284bbf23739b6431efab8a8cd385c6b |
spec/support/utils.rb | 100644 | 0 | 0 | | | 225 Bytes | cb3772a3fb89ffd9253eba34b88dacada8657b79d39cbfa086beeff36c8c8542 |
spec/units/message_driver/adapters/base_spec.rb | 100644 | 0 | 0 | | | 1.77 KB | 82a7944b041168916df4ba1237ab35f62d7a06e6e95f502918aa5baa2077ff7a |
spec/units/message_driver/broker_spec.rb | 100644 | 0 | 0 | | | 11.5 KB | 8790f0273a6f1010acf62abd97d65ece868b10f68f26dcd9e3d3abafe8f99fdf |
spec/units/message_driver/client_spec.rb | 100644 | 0 | 0 | | | 15.9 KB | c61b0676cf716d0325041e05f8738760ce65cecf6195b6f3e056d25302be62fc |
spec/units/message_driver/destination_spec.rb | 100644 | 0 | 0 | | | 777 Bytes | b4bd3f5d3df7cf0daaa0bafff3820f32d06c808de5fdfc45b100c84bde7b50b0 |
spec/units/message_driver/message_spec.rb | 100644 | 0 | 0 | | | 4.08 KB | 4bda6f6348e0c1e1c735093082dd093763f08c364442e827ca0aa3512b8e28ca |
spec/units/message_driver/middleware/base_spec.rb | 100644 | 0 | 0 | | | 856 Bytes | 89e6768708fee9f9c0a8949ab492ead1e957d567af189b7fcd3953611037a2e2 |
spec/units/message_driver/middleware/block_middleware_spec.rb | 100644 | 0 | 0 | | | 3.02 KB | d50c2ff416edbf60499397736325d31c5b87d52ffd761275f9d3fa37f087099a |
spec/units/message_driver/middleware/middleware_stack_spec.rb | 100644 | 0 | 0 | | | 5.68 KB | 51a52fd8454cbfe7a9f9d70b382547e0eff33a68a0dc787f4fe4e37fd16b4791 |
spec/units/message_driver/subscription_spec.rb | 100644 | 0 | 0 | | | 823 Bytes | db984ca478ebf62d40b15f2c945a7660d3f62afcfbf3ccc49659b4424f843cf4 |
test_lib/broker_config.rb | 100644 | 0 | 0 | | | 1.47 KB | a811dac48e46229dfb5802f5e9ef95763b290ee8f50b3a2d3358c0160967fc1a |
test_lib/coverage.rb | 100644 | 0 | 0 | | | 254 Bytes | 526c08863d07f222b99fb000ae6d91602769e09d83dfec01ed319a4776cbe37a |
test_lib/provider/base.rb | 100644 | 0 | 0 | | | 1.27 KB | e184baa1dd2e2407d5d610f608b331c5375d0c2cfbeb0a2d437cabac697d2312 |
test_lib/provider/in_memory.rb | 100644 | 0 | 0 | | | 96 Bytes | b165b08bb9894e795b47189ee8f2755b2ac0bf86c97a6ff0910ff81364863151 |
test_lib/provider/rabbitmq.rb | 100644 | 0 | 0 | | | 1.57 KB | 0d7de5a64f56fcac68abe1b696be86587b75625166c251b92fec0e5fa4c684d6 |