class Stomp::Message
Container class for frames, misnamed technically
Attributes
body[RW]
command[RW]
headers[RW]
original[RW]
Public Class Methods
new(frame)
click to toggle source
# File vendor/gems/stomp/message.rb, line 9 def initialize(frame) # p frame # Set default empty values self.command = '' self.headers = {} self.body = '' self.original = frame return self if is_blank?(frame) # Figure out where individual parts of the frame begin and end. command_index = frame.index("\n") raise Stomp::Error::InvalidFormat, 'command index' unless command_index # headers_index = frame.index("\n\n", command_index+1) raise Stomp::Error::InvalidFormat, 'headers index' unless headers_index # lastnull_index = frame.rindex("\0") raise Stomp::Error::InvalidFormat, 'lastnull index' unless lastnull_index # Extract working copies of each frame part work_command = frame[0..command_index-1] raise Stomp::Error::InvalidServerCommand, "invalid command: #{work_command.inspect}" unless @@allowed_commands.include?(work_command) # work_headers = frame[command_index+1..headers_index-1] raise Stomp::Error::InvalidFormat, 'nil headers' unless work_headers # work_body = frame[headers_index+2..lastnull_index-1] raise Stomp::Error::InvalidFormat, 'nil body' unless work_body # Set the frame values self.command = work_command work_headers.split("\n").map do |value| parsed_value = value.match /^([\w|-]*):(.*)$/ raise Stomp::Error::InvalidFormat, 'parsed header value' unless parsed_value self.headers[parsed_value[1].strip] = parsed_value[2].strip if parsed_value end body_length = -1 if self.headers['content-length'] body_length = self.headers['content-length'].to_i raise Stomp::Error::InvalidMessageLength if work_body.length != body_length end self.body = work_body[0..body_length] end
Public Instance Methods
empty?()
click to toggle source
# File vendor/gems/stomp/message.rb, line 58 def empty? is_blank?(command) && is_blank?(headers) && is_blank?(body) end
to_s()
click to toggle source
# File vendor/gems/stomp/message.rb, line 54 def to_s "<Stomp::Message headers=#{headers.inspect} body='#{body}' command='#{command}' >" end
Private Instance Methods
is_blank?(value)
click to toggle source
# File vendor/gems/stomp/message.rb, line 63 def is_blank?(value) value.nil? || (value.respond_to?(:empty?) && value.empty?) end