diff --git a/lib/logstash/inputs/jms.rb b/lib/logstash/inputs/jms.rb
index 09f1a41..ecbe826 100644
--- a/lib/logstash/inputs/jms.rb
+++ b/lib/logstash/inputs/jms.rb
@@ -334,6 +334,7 @@ def queue_events(msg, output_queue)
         @properties_setter.call(event, properties)
       end
 
+      decorate(event)
       event
     end.each do |ready_event|
       output_queue << ready_event