@@ -14,26 +14,26 @@ def payload
14
14
end
15
15
16
16
def as_method_to_h ( free = false )
17
- # TODO: raise correct error class with enough info for appropriate action
18
- raise "Wrong frame type for method frame of event: #{ self [ :frame_type ] } " \
19
- unless self [ :frame_type ] == :method
17
+ raise FFI :: Error :: BadAmqpData ,
18
+ "Wrong frame type for method frame of event: #{ self [ :frame_type ] } " \
19
+ unless self [ :frame_type ] == :method
20
20
21
21
payload . to_h ( free ) . merge ( channel : self [ :channel ] )
22
22
end
23
23
24
24
def as_header_to_h ( free = false )
25
- # TODO: raise correct error class with enough info for appropriate action
26
- raise "Wrong frame type for header frame of multiframe event: #{ self [ :frame_type ] } " \
27
- unless self [ :frame_type ] == :header
25
+ raise FFI :: Error :: BadAmqpData ,
26
+ "Wrong frame type for header frame of multiframe event: #{ self [ :frame_type ] } " \
27
+ unless self [ :frame_type ] == :header
28
28
29
29
properties = self [ :payload ] [ :properties ]
30
30
{ header : properties . decoded . to_h ( free ) , body_size : properties [ :body_size ] }
31
31
end
32
32
33
33
def as_body_to_s ( free = false )
34
- # TODO: raise correct error class with enough info for appropriate action
35
- raise "Wrong frame type for body frame of multiframe event: #{ self [ :frame_type ] } " \
36
- unless self [ :frame_type ] == :body
34
+ raise FFI :: Error :: BadAmqpData ,
35
+ "Wrong frame type for body frame of multiframe event: #{ self [ :frame_type ] } " \
36
+ unless self [ :frame_type ] == :body
37
37
38
38
self [ :payload ] [ :body_fragment ] . to_s ( free )
39
39
end
0 commit comments