Class: AMQ::Protocol::Method
- Inherits:
-
Object
- Object
- AMQ::Protocol::Method
show all
- Defined in:
- lib/amq/protocol/client.rb
Direct Known Subclasses
Basic::Ack, Basic::Cancel, Basic::CancelOk, Basic::Consume, Basic::ConsumeOk, Basic::Deliver, Basic::Get, Basic::GetEmpty, Basic::GetOk, Basic::Nack, Basic::Publish, Basic::Qos, Basic::QosOk, Basic::Recover, Basic::RecoverAsync, Basic::RecoverOk, Basic::Reject, Basic::Return, Channel::Close, Channel::CloseOk, Channel::Flow, Channel::FlowOk, Channel::Open, Channel::OpenOk, Confirm::Select, Confirm::SelectOk, Connection::Close, Connection::CloseOk, Connection::Open, Connection::OpenOk, Connection::Secure, Connection::SecureOk, Connection::Start, Connection::StartOk, Connection::Tune, Connection::TuneOk, Exchange::Bind, Exchange::BindOk, Exchange::Declare, Exchange::DeclareOk, Exchange::Delete, Exchange::DeleteOk, Exchange::Unbind, Exchange::UnbindOk, Queue::Bind, Queue::BindOk, Queue::Declare, Queue::DeclareOk, Queue::Delete, Queue::DeleteOk, Queue::Purge, Queue::PurgeOk, Queue::Unbind, Queue::UnbindOk, Tx::Commit, Tx::CommitOk, Tx::Rollback, Tx::RollbackOk, Tx::Select, Tx::SelectOk
Class Method Summary
collapse
Class Method Details
.encode_body(body, channel, frame_size) ⇒ Object
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
|
# File 'lib/amq/protocol/client.rb', line 246
def self.encode_body(body, channel, frame_size)
return [BodyFrame.new(body, channel)] if body.empty?
limit = frame_size - 8
limit_plus_1 = limit + 1
array = Array.new
while body
payload, body = body[0, limit_plus_1], body[limit_plus_1, body.length - limit]
array << BodyFrame.new(payload, channel)
end
array
end
|
.index ⇒ Object
218
219
220
|
# File 'lib/amq/protocol/client.rb', line 218
def self.index
@index
end
|
.inherited(base) ⇒ Object
222
223
224
225
226
|
# File 'lib/amq/protocol/client.rb', line 222
def self.inherited(base)
if self == Protocol::Method
@methods << base
end
end
|
.instantiate(*args, &block) ⇒ Object
We can return different:
-
instantiate given subclass of Method
-
create an OpenStruct object
-
create a hash
-
yield params into the block rather than just return
269
270
271
272
273
274
|
# File 'lib/amq/protocol/client.rb', line 269
def self.instantiate(*args, &block)
self.new(*args, &block)
end
|
.method_id ⇒ Object
210
211
212
|
# File 'lib/amq/protocol/client.rb', line 210
def self.method_id
@method_id
end
|
.methods ⇒ Object
228
229
230
|
# File 'lib/amq/protocol/client.rb', line 228
def self.methods
@methods
end
|
.name ⇒ Object
214
215
216
|
# File 'lib/amq/protocol/client.rb', line 214
def self.name
@name
end
|
232
233
234
235
236
237
238
239
240
241
242
243
244
|
# File 'lib/amq/protocol/client.rb', line 232
def self.()
properties, = {}, {}
.each do |key, value|
if Basic::PROPERTIES.include?(key)
properties[key] = value
else
[key] = value
end
end
return [properties, ]
end
|