Contents

require 'rubygems'
require 'json/ext'

module Factor
  module Runtime
    class ListenerMessage
      attr_accessor :command,:workflow
      def initialize(command=nil,workflow=nil)
        @command=command
        @workflow=workflow
      end


      def route
        # "#{workflow}.#{position.join('.')}"
        "listener"
      end
    
      def payload
        JSON.generator = JSON::Ext::Generator
        obj = {"command"=>@command, "workflow"=>@workflow}
        JSON.generate(obj)
      end
    
      def from_queue payload
        message=JSON.parse(payload)
        @command=message["command"]
        @workflow=message["workflow"]
      end
      # def from_queue payload
      #   
      #   @workflow = message["workflow"]
      #   @position=message["position"]
      #   @body=message["body"]
      #   @workflow_instance_id=message["workflow_instance_id"]
      #   @step_id=message["step_id"]
      #   @last_step_id=message["last_step_id"]
      # end
    
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
factor-0.1.10	lib/runtime/listener_message.rb