Class: Qrack::Protocol::Header

Inherits:
Object
  • Object
show all
Defined in:
lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*args) ⇒ Header 



64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 64

def initialize *args
  opts = args.pop if args.last.is_a? Hash
  opts ||= {}
 
  first = args.shift
 
  if first.is_a? ::Class and first.ancestors.include? Protocol::Class
    @klass = first
    @size = args.shift || 0
    @weight = args.shift || 0
    @properties = opts

  elsif first.is_a? Transport::Buffer or first.is_a? String
    buf = first
    buf = Transport::Buffer.new(buf) unless buf.is_a? Transport::Buffer
   
    @klass = Protocol.classes[buf.read(:short)]
    @weight = buf.read(:short)
    @size = buf.read(:longlong)

    props = buf.read(:properties, *klass.properties.map{|type,_| type })
    @properties = Hash[*klass.properties.map{|_,name| name }.zip(props).reject{|k,v| v.nil? }.flatten]

  else
    raise ArgumentError, 'Invalid argument'
  end
 
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(meth, *args, &blk) ⇒ Object 



120
121
122
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 120

def method_missing meth, *args, &blk
  @properties.has_key?(meth) || @klass.properties.find{|_,name| name == meth } ? @properties[meth] : super
end

Instance Attribute Details

#klass ⇒ Object

Returns the value of attribute klass.



92
93
94
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 92

def klass
  @klass
end

#properties ⇒ Object

Returns the value of attribute properties.



92
93
94
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 92

def properties
  @properties
end

#size ⇒ Object

Returns the value of attribute size.



92
93
94
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 92

def size
  @size
end

#weight ⇒ Object

Returns the value of attribute weight.



92
93
94
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 92

def weight
  @weight
end

Instance Method Details

#==(header) ⇒ Object 



114
115
116
117
118
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 114

def == header
  [ :klass, :size, :weight, :properties ].inject(true) do |eql, field|
    eql and __send__(field) == header.__send__(field)
  end
end

#to_binary ⇒ Object 



94
95
96
97
98
99
100
101
102
103
104
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 94

def to_binary
  buf = Transport::Buffer.new
  buf.write :short, klass.id
  buf.write :short, weight # XXX rabbitmq only supports weight == 0
  buf.write :longlong, size
  buf.write :properties, (klass.properties.map do |type, name|
                           [ type, properties[name] || properties[name.to_s] ]
                         end)
  buf.rewind
  buf
end

#to_frame(channel = 0) ⇒ Object 



110
111
112
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 110

def to_frame channel = 0
  Transport::Header.new(self, channel)
end

#to_s ⇒ Object 



106
107
108
 
# File 'lib/ext/bunny-0.6.0/lib/qrack/protocol/protocol08.rb', line 106

def to_s
  to_binary.to_s
end