.circleci/config.yml | 100644 | 0 | 0 | | | 8.52 KB | d6e52125b164753c4c61ddb1628ffd1ed86d0c6d7d091422ef35191b88027af9 |
.gitignore | 100755 | 0 | 0 | | | 146 Bytes | 9c4cb79875f2d3e5b39fbe8f3e95f884396364ea954e148e2268c900ffcd1c94 |
.ruby-gemset | 100755 | 0 | 0 | | | 16 Bytes | 380bc0cfe1c67e745442535640943fffc3423535c5b4ff46fbe030bc75a2b0b5 |
.ruby-version | 100755 | 0 | 0 | | | 11 Bytes | 1999a4a1248a9f9a12cb00c43a84daaf5d3f4c2ec531fa4a64c8ce0273824dda |
.travis.yml | 100644 | 0 | 0 | | | 144 Bytes | 125c58bb1416e932a58311483572d786697dbb4824aae0ce21c7a8034774ed25 |
CODEOWNERS | 100644 | 0 | 0 | | | 27 Bytes | 2d5f7e2e2b53c719df2bbb533a8814eb120861355f7cdc88fb55329b5d91bbc2 |
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.rails-6.1 | 100644 | 0 | 0 | | | 169 Bytes | 07cdbb78db9bfe5e73d2898a1298c14524a0b8d8fd94ef234f4c04135715269e |
Gemfile.rails-7.0 | 100644 | 0 | 0 | | | 169 Bytes | 906926118c8c48faa3556ff375e0a1394eae03356dfb1030563593e3960b3e51 |
LICENSE | 100644 | 0 | 0 | | | 1.05 KB | c8698f1d465a31c9bde8e3eaca98892b730e1d8406d6f9ddc975fdcbe9a28f87 |
README.md | 100755 | 0 | 0 | | | 23.5 KB | 474a04ebdfde104ec3247877b2bc27936b34fdefa6aa0408053fda06de48adbf |
Rakefile | 100755 | 0 | 0 | | | 313 Bytes | ca276268ae64670e1542318e929e786eb4c2ad6c6c64fed8358b1224a8887a3c |
build-matrix.json | 100644 | 0 | 0 | | | 113 Bytes | 9bea3ed238f7f730c15a0c5291371f7b56584e813cce0becec5f2bb7488af009 |
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 | | | 741 Bytes | 68d06bb66cc235d8a2a32cbc4e0c94ec9ccc6069fe0f75d1ded4e85005de50a5 |
lib/pwwka/channel_connector.rb | 100755 | 0 | 0 | | | 3.52 KB | cadc2c372eb3f3d7ece706fbe17059347e7744b250bba561e1329def0e867978 |
lib/pwwka/configuration.rb | 100755 | 0 | 0 | | | 5.61 KB | f14e95991487c7d8034afcc8cc83a609fd5d10b881472c401b33a1c09d94fe0f |
lib/pwwka/error_handlers.rb | 100644 | 0 | 0 | | | 349 Bytes | e9def089f682c657aa98962a54859b4827ce366efa5c28b742afc29c4d88225a |
lib/pwwka/error_handlers/base_error_handler.rb | 100644 | 0 | 0 | | | 872 Bytes | ac80e52b4afcaf9b819babd1def111b4388312f19ab53de489f92375828a7911 |
lib/pwwka/error_handlers/chain.rb | 100644 | 0 | 0 | | | 1.89 KB | 14de58a91e1e3e92e707f2c5a6688865956b51f5ccee6a0bd6f70cbff6d73310 |
lib/pwwka/error_handlers/crash.rb | 100644 | 0 | 0 | | | 289 Bytes | 65e93d18fe83aa88586cd82821b6e7441f498eb2d7cc89d5440c1294a28e6804 |
lib/pwwka/error_handlers/ignore_payload_format_errors.rb | 100644 | 0 | 0 | | | 481 Bytes | d8a99b293a2711183c8921662b99f5e85674a1ed9c431df627b313f665e0afed |
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 | | | 774 Bytes | 1cca047fc3a0ea38f99d06ad56ba1334639ae595379a1a2e802eafaae92c2025 |
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.85 KB | 40c494f072efe631caf7f9b74eced3990b3d11e91b8160504131d20306a5b0f6 |
lib/pwwka/send_message_async_job.rb | 100644 | 0 | 0 | | | 786 Bytes | beeeec76477fdc882662c4e863eafc5025af41b36ab9398945699ba3f3f8c458 |
lib/pwwka/send_message_async_sidekiq_job.rb | 100644 | 0 | 0 | | | 818 Bytes | 7cf3f658e42ab0f2a2199e0faa7dd4ce77675a8ceb11eec185cda815b84133cb |
lib/pwwka/tasks.rb | 100755 | 0 | 0 | | | 573 Bytes | ceb0c0cd66589150271123296d8dac24f3494a5b2f74257184f24358e254ebb5 |
lib/pwwka/test_handler.rb | 100755 | 0 | 0 | | | 3.13 KB | 1129115e4c8b420e24179d28178edf982e09910958fc25edbb0b7e53ef01a61d |
lib/pwwka/transmitter.rb | 100755 | 0 | 0 | | | 7.72 KB | 15bd64c7694163da0ece135c3220ffeb78aacb96d8af13b2339ccd9b41ba57a8 |
lib/pwwka/version.rb | 100755 | 0 | 0 | | | 38 Bytes | d21338fcfbf174411ddcfc62697104e3746bbf5990a6e295a849af6e939d0cd4 |
owners.json | 100644 | 0 | 0 | | | 60 Bytes | a80e58d99569bca31ee3f23ff9b3c8c6fa72445cf12b0059b2e9e1428bdee88f |
pwwka.gemspec | 100755 | 0 | 0 | | | 1.72 KB | 18f6cddb286b65553b448a9903048ed20a30794716fb3bc205d57e1845eb761f |
spec/integration/interrupted_receivers_spec.rb | 100644 | 0 | 0 | | | 1.44 KB | 1a96085e9319378f38c6abc9e238738726d3eea0b6826f540a634b54feed5279 |
spec/integration/send_and_receive_spec.rb | 100644 | 0 | 0 | | | 11.1 KB | 24c22851d20193adbcfa6b2b545bafb4a01263af41fb8f729c3e0e484fd44d22 |
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 | | | 9 KB | 897e3abb53f7f5e19dd204575c06c90de31cf3d018c8ba2a0b2fafd30b925efd |
spec/legacy/handling_spec.rb | 100755 | 0 | 0 | | | 843 Bytes | 040cc9c4b0e85a7718b9bd0dfcaac3d8d9f98075bf3b9aabf4a9b743855c2e85 |
spec/legacy/receiver_spec.rb | 100755 | 0 | 0 | | | 6.8 KB | e00f17236062e9c7679394265d2797558161ab47fbc917dd24da94be422ae996 |
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/lib/pwwka/error_handlers/chain_spec.rb | 100644 | 0 | 0 | | | 1.31 KB | 1babc6720c1c760561c72caa562cc73fedf9c2c7e7ef2819bb78e36d46ae83d3 |
spec/spec_helper.rb | 100755 | 0 | 0 | | | 1.81 KB | aa71689bc8d451bc8b04a8abba188aeefdb5fbdf7a83c1d4923a945badeb6d0e |
spec/support/test_configuration.rb | 100644 | 0 | 0 | | | 1.29 KB | 6e07a44bb0f2c336ed6d1baefaf4057391e1d2f3f58be899702af184d5452308 |
spec/unit/channel_connector_spec.rb | 100644 | 0 | 0 | | | 3.23 KB | 44a865bb33ea1b1a1c848a5ce3021e95f719bde4f65cecef0b8bf7dfc22c696d |
spec/unit/configuration_spec.rb | 100644 | 0 | 0 | | | 6.52 KB | 01082daefd00c62be799e8f0cc61e4bee35d4db040bdb97e62cb58e555d5142c |
spec/unit/logging_spec.rb | 100644 | 0 | 0 | | | 4.97 KB | 6d54dfd97e9f6156d9fc40933250a8c12f4cc1d8d32058fc6129520c78eff954 |
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/receiver_spec.rb | 100644 | 0 | 0 | | | 1.55 KB | 5f589a0ebd50adce51f375c84c76aa583128545948df4b2424d0f8d5b73779cb |
spec/unit/send_message_async_job_spec.rb | 100644 | 0 | 0 | | | 1.21 KB | df983b06ef902dff2213aeb616e433df9855abccec714ebea3c0430688b418f1 |
spec/unit/send_message_async_sidekiq_job_spec.rb | 100644 | 0 | 0 | | | 1.23 KB | 8d5895f0c02abdc4db4a75c8ed7966ebd724c18669bf332b30e57594a57f1716 |
spec/unit/test_handler_message_spec.rb | 100644 | 0 | 0 | | | 944 Bytes | 3189cdcb79479a46aa48ba2b1c2335e813e6e3dca0f61e3de02a0c489ef4e50e |
spec/unit/transmitter_spec.rb | 100644 | 0 | 0 | | | 21.1 KB | a3f2305b071ee17125438794536b0f7b218344b2681ad97e0a98feaa18dee9b1 |