f

Author: JustSnow

Gemfile.lock

@@ -1,6 +1,6 @@
 GIT
   remote: https://github.com/umbrellio/rabbit_messaging.git
-  revision: 975cdf925ab5102c0234bfcf2732dbaaa49a0ed3
+  revision: f4bad61660daf33fdb038e533556290c7d6ad9d8
   branch: compression-for-publisher-and-reciver
   specs:
     rabbit_messaging (1.8.0)

lib/table_sync/publishing/message/raw.rb

@@ -21,7 +21,7 @@ def initialize(params = {})
       self.headers             = params[:headers]
       self.custom_version      = params[:custom_version]
       self.event               = params[:event]
-      self.compress            = params.fetch(:compress, false)
+      self.compress            = params.dig(:headers, :compress) || false
     end
 
     def publish