Sha256: 7b07adf3dec7829d84e68ef6537a847c97465339695ff56251ddb09cbd94e1e0

Contents?: true

Size: 670 Bytes

Versions: 1

Compression:

Stored size: 670 Bytes

Contents

module Legion::Extensions::<%= @lex.capitalize %>
  module Transport
    module Messages
      class Conditioner < Legion::Transport::Message
        def initialize(payload, status, options = {})
          @payload = payload
          @options = options
          @status = status
          @routing_key = routing_key
          validate
        end

        def routing_key
          "<%= @lex %>.<%= @name %>"
        end

        #def exchange
        #  Legion::Extensions::Conditioner::Transport::Exchanges::Conditioner
        #end

        def message(payload = @payload, _options = {})
          Legion::JSON.dump(payload)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
legion-cli-0.2.0 lib/legion/cli/lex/templates/message.erb