.gitignore | 100755 | 0 | 0 | | | 122 Bytes | c3690181317ad64ce1532cab8e1b1fa5cf5e0a0d4fc5144452faf128e1b69e3d |
.ruby-gemset | 100755 | 0 | 0 | | | 16 Bytes | 380bc0cfe1c67e745442535640943fffc3423535c5b4ff46fbe030bc75a2b0b5 |
.ruby-version | 100755 | 0 | 0 | | | 6 Bytes | 6d850e3ac42d0dd06bfdcce9151c1e6b40f4cf5272778f63eececea27c78f0b6 |
.travis.yml | 100644 | 0 | 0 | | | 144 Bytes | a51f162f59fec7bd4d31d25efec60430771be477b2d5cd412fcc56ae7aeef2ba |
CODE_OF_CONDUCT.md | 100644 | 0 | 0 | | | 178 Bytes | 638444a494d27d15818e54128b606af883b424f3ef8a540ccebaf955329d3ccb |
CONTRIBUTING.md | 100644 | 0 | 0 | | | 1.81 KB | 098e8053202530e98860d15868a2622d2609fc1c38066f78c6a1e6a9688beb04 |
Gemfile | 100755 | 0 | 0 | | | 43 Bytes | 1fefc0dbe3c9a02df8504532581ae18e38c9bd82195bcc44926b02161c5aa7fb |
Gemfile.lock | 100644 | 0 | 0 | | | 2.12 KB | da9d9a390c21f3208625fc96a40260187948dfbe01d5a05b6a2d93d2e2d76d1e |
LICENSE | 100644 | 0 | 0 | | | 1.05 KB | c8698f1d465a31c9bde8e3eaca98892b730e1d8406d6f9ddc975fdcbe9a28f87 |
README.md | 100755 | 0 | 0 | | | 21.2 KB | d3aeee63781dc386dc2ddfd1298023dfb66a81f4349a46f26c27667bd427d61a |
Rakefile | 100755 | 0 | 0 | | | 317 Bytes | 6e82623f5c19ebad32531c6c5701b268e3e039431a712d8adf14249d345ec998 |
docker-compose.yml | 100644 | 0 | 0 | | | 190 Bytes | df50960b8b85abd55455b37378fd5a034372f331e92853e1abbaa202bd905b16 |
docs/images/RabbitMQ_Management-2.png | 100755 | 0 | 0 | | | 65.4 KB | 4c63f21e73224c6a2885079e84c01dbc7d8f2b4068615e4a93261987fa5446ac |
docs/images/RabbitMQ_Management-3.png | 100755 | 0 | 0 | | | 58.9 KB | 3bbd0f5d15d358aeb1d6680424b8bd7154f69d79949b8089d965e0ac1af172a2 |
docs/images/RabbitMQ_Management.png | 100755 | 0 | 0 | | | 76.6 KB | 98b07a51932edb7240aefd7be33dc6891e2ba7dd97e20aca9dfb3df7d916873e |
lib/pwwka.rb | 100755 | 0 | 0 | | | 698 Bytes | b1eb4aeef0487b6c09b8a0518f3f6cec5a7e5793d34bad2f8be83a3249ced072 |
lib/pwwka/channel_connector.rb | 100755 | 0 | 0 | | | 2.61 KB | 5c7970a22f37703f4996e69ea1e03b6d3dd7b406c173d95d936b5718c11dfd25 |
lib/pwwka/configuration.rb | 100755 | 0 | 0 | | | 3.5 KB | c5d622bfaaa03644ea723144628b606326b4a76d6553deb2073196b7276865ba |
lib/pwwka/error_handlers.rb | 100644 | 0 | 0 | | | 286 Bytes | dd9910f68963cb2ad67fea89b4a8228724cfbc6305bd57f18235352ae774e1cb |
lib/pwwka/error_handlers/base_error_handler.rb | 100644 | 0 | 0 | | | 872 Bytes | ac80e52b4afcaf9b819babd1def111b4388312f19ab53de489f92375828a7911 |
lib/pwwka/error_handlers/chain.rb | 100644 | 0 | 0 | | | 1.54 KB | 98b14d44769c29e0ce987d42525791a15bbd79639835a3c41d8e6952f4c716b7 |
lib/pwwka/error_handlers/crash.rb | 100644 | 0 | 0 | | | 289 Bytes | 65e93d18fe83aa88586cd82821b6e7441f498eb2d7cc89d5440c1294a28e6804 |
lib/pwwka/error_handlers/nack_and_ignore.rb | 100644 | 0 | 0 | | | 374 Bytes | 00498a493924cf8df3aac150c235ec71212c0f70bc9537cd55fc003f0f2c0b8a |
lib/pwwka/error_handlers/nack_and_requeue_once.rb | 100644 | 0 | 0 | | | 601 Bytes | cb23f955e39bc5adca2462cb83e29bb40985503590a019084e63346e19219286 |
lib/pwwka/handling.rb | 100755 | 0 | 0 | | | 169 Bytes | d3e0f01d486726270888afc6215d3566a1f8d270b1dfc820a927955916c676d9 |
lib/pwwka/logging.rb | 100644 | 0 | 0 | | | 605 Bytes | 6748b5383df87afcb471aedba73d8c52967e9810b58a2682e28d05ef0caef8e5 |
lib/pwwka/message_queuer.rb | 100644 | 0 | 0 | | | 1.95 KB | ba3dfe2c9b551cbcdbd714b443381f3911ba9f7c7664f61033f6aa24f9ae345a |
lib/pwwka/publish_options.rb | 100644 | 0 | 0 | | | 979 Bytes | b2d4980ebef45179e139eaf81df34ea91925ac6c0b0c3e54e696910a72e34141 |
lib/pwwka/queue_resque_job_handler.rb | 100644 | 0 | 0 | | | 1.63 KB | daf00ba98fb1301e4b02fbeab226579ca57b9ff7a734366e2708cbfd5189d389 |
lib/pwwka/receiver.rb | 100755 | 0 | 0 | | | 2.49 KB | 2e7482133fb3504709ba8a783a59954daf7645d8f6219eb71e531fdc2e661b38 |
lib/pwwka/send_message_async_job.rb | 100644 | 0 | 0 | | | 786 Bytes | beeeec76477fdc882662c4e863eafc5025af41b36ab9398945699ba3f3f8c458 |
lib/pwwka/tasks.rb | 100755 | 0 | 0 | | | 481 Bytes | 6f051f2306a5b65662de225b50b61e62d1a9058e05ad190db30fa1ff461c9e33 |
lib/pwwka/test_handler.rb | 100755 | 0 | 0 | | | 3.13 KB | 1129115e4c8b420e24179d28178edf982e09910958fc25edbb0b7e53ef01a61d |
lib/pwwka/transmitter.rb | 100755 | 0 | 0 | | | 6.07 KB | d1079255fc6514758c5f35680eb07096c65b0da7f5d8236d8a59a25c5627e3c7 |
lib/pwwka/version.rb | 100755 | 0 | 0 | | | 38 Bytes | 11a8cbc74f1964f548e01c4d5db1749e4f68bfede29053709d022c6f44fe075e |
pwwka.gemspec | 100755 | 0 | 0 | | | 1.55 KB | 27d3a64b8d08ae0cc74759a5a751da87cd8d37c2024fd9311f3268e2bd864763 |
spec/integration/interrupted_receivers_spec.rb | 100644 | 0 | 0 | | | 1.44 KB | 1a96085e9319378f38c6abc9e238738726d3eea0b6826f540a634b54feed5279 |
spec/integration/send_and_receive_spec.rb | 100644 | 0 | 0 | | | 9.86 KB | 1282e5d44809e06f4d02bd119d451470726e8fb854fb2287e440593348a38dba |
spec/integration/support/integration_test_helpers.rb | 100644 | 0 | 0 | | | 140 Bytes | ead190d042638dfbd2be307ceb0a329ed6b9bd2ce754545aa7375f37407f604d |
spec/integration/support/integration_test_setup.rb | 100644 | 0 | 0 | | | 830 Bytes | 0bcbd567c282c339d2295d0a2478c7b30eb0bcfe7a85f957db6b22c6e136b082 |
spec/integration/support/logging_receiver.rb | 100644 | 0 | 0 | | | 362 Bytes | 6d6691c75ff22cd08a77656cf9dd33dca780315d1d78a8c28862a10c8ba7855c |
spec/integration/test_handler_spec.rb | 100644 | 0 | 0 | | | 2.8 KB | d80b545ac48623a3f95cc665bd68ba39fb011c1b652f5af4b4ed04d51551eaa1 |
spec/integration/unhandled_errors_in_receivers_spec.rb | 100644 | 0 | 0 | | | 6.28 KB | c7a5f5836f38b95272ed87c77ec169386003815c13d768394d5affaf883b59ad |
spec/legacy/handling_spec.rb | 100755 | 0 | 0 | | | 843 Bytes | 040cc9c4b0e85a7718b9bd0dfcaac3d8d9f98075bf3b9aabf4a9b743855c2e85 |
spec/legacy/receiver_spec.rb | 100755 | 0 | 0 | | | 6.14 KB | 144e17fdb1177fdc7760fc4958c47611854988840a092c35051d953771686a60 |
spec/legacy/send_message_async_job_spec.rb | 100644 | 0 | 0 | | | 425 Bytes | 79b560753ee7023a199d20e013d3a3a499287c0a73b00b9782c8a644da6098c7 |
spec/legacy/transmitter_spec.rb | 100755 | 0 | 0 | | | 11.7 KB | a14d289e976edff45fc021c0f604d95efa993e0bc864ad2b750df77062603c88 |
spec/spec_helper.rb | 100755 | 0 | 0 | | | 1.54 KB | 255ce6eb5b778c67ac3b43ad7bec272fdd5779dcf14f696595afd25927f88a5f |
spec/support/test_configuration.rb | 100644 | 0 | 0 | | | 1.18 KB | 17ba33d35e8a95597be42810a7b3fbc16e71731608c1174edf3be8b465fa186b |
spec/unit/channel_connector_spec.rb | 100644 | 0 | 0 | | | 1.16 KB | ace2030b2c9fce4954375a14fbf570f62d367e7161e0a4850c79f834bffd1fd7 |
spec/unit/configuration_spec.rb | 100644 | 0 | 0 | | | 3.85 KB | 55138f8613f5ea76e5e2ed57d435a16aa0277d86f6bd378c3f4ac11f1e5cd639 |
spec/unit/logging_spec.rb | 100644 | 0 | 0 | | | 2.47 KB | dc20c13d8a8ba9ee0e996768175c9af218915279cabfd3010c0d97f70a9e0883 |
spec/unit/message_queuer_spec.rb | 100644 | 0 | 0 | | | 2.3 KB | 8c587ff03eeedd0bec4a133324c3387c7300a08398657be428a23f0d914ad30f |
spec/unit/queue_resque_job_handler_spec.rb | 100644 | 0 | 0 | | | 2.71 KB | 223359141940096644b761e395b733661a91f06c8a32ddfbce2261c4d78e4247 |
spec/unit/send_message_async_job_spec.rb | 100644 | 0 | 0 | | | 1.21 KB | df983b06ef902dff2213aeb616e433df9855abccec714ebea3c0430688b418f1 |
spec/unit/test_handler_message_spec.rb | 100644 | 0 | 0 | | | 944 Bytes | 3189cdcb79479a46aa48ba2b1c2335e813e6e3dca0f61e3de02a0c489ef4e50e |
spec/unit/transmitter_spec.rb | 100644 | 0 | 0 | | | 13.7 KB | 1c120909e2f8aac6d17b3789603e4ac4724062c5e35fd3d9167923634bfb55fd |