lib/vx/consumer/subscribe.rb in vx-consumer-0.1.3 vs lib/vx/consumer/subscribe.rb in vx-consumer-0.1.4

@@ -31,10 +31,12 @@
         }
 
         with_middlewares :sub, instrumentation do
           instrument("start_processing", instrumentation)
           instrument("process", instrumentation) do
-            run_instance delivery_info, properties, payload, channel
+            allocate_pub_channel do
+              run_instance delivery_info, properties, payload, channel
+            end
           end
         end
       end
 
       def run_instance(delivery_info, properties, payload, channel)