generators/outboxer/templates/bin/publisher.rb in outboxer-0.1.0 vs generators/outboxer/templates/bin/publisher.rb in outboxer-0.1.1
- old
+ new
@@ -1,7 +1,14 @@
#!/usr/bin/env ruby
require_relative "../config/environment"
Outboxer::Publisher.publish do |args|
- # Worker.perform_async({ message_id: args.message.id })
+ logger = args.logger
+ message = args.message
+
+ logger.info("[#{message.id}] publishing")
+
+ HardJob.perform_async({ "message_id" => message.id })
+
+ logger.info("[#{message.id}] published")
end