Class: WampClient::Message::Subscribed
- Defined in:
- lib/wamp_client/message.rb
Overview
Subscribed Acknowledge sent by a Broker to a Subscriber to acknowledge a subscription. Formats:
[SUBSCRIBED, SUBSCRIBE.Request|id, Subscription|id]
Instance Attribute Summary collapse
-
#subscribe_request ⇒ Object
Returns the value of attribute subscribe_request.
-
#subscription ⇒ Object
Returns the value of attribute subscription.
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(subscribe_request, subscription) ⇒ Subscribed
constructor
A new instance of Subscribed.
- #payload ⇒ Object
- #to_s ⇒ Object
Methods included from Check
Constructor Details
#initialize(subscribe_request, subscription) ⇒ Subscribed
Returns a new instance of Subscribed.
542 543 544 545 546 547 548 549 550 |
# File 'lib/wamp_client/message.rb', line 542 def initialize(subscribe_request, subscription) self.class.check_id('subscribe_request', subscribe_request) self.class.check_id('subscription', subscription) self.subscribe_request = subscribe_request self.subscription = subscription end |
Instance Attribute Details
#subscribe_request ⇒ Object
Returns the value of attribute subscribe_request.
540 541 542 |
# File 'lib/wamp_client/message.rb', line 540 def subscribe_request @subscribe_request end |
#subscription ⇒ Object
Returns the value of attribute subscription.
540 541 542 |
# File 'lib/wamp_client/message.rb', line 540 def subscription @subscription end |
Class Method Details
.parse(params) ⇒ Object
556 557 558 559 560 561 562 563 564 |
# File 'lib/wamp_client/message.rb', line 556 def self.parse(params) self.check_gte('params list', 3, params.count) self.check_equal('message type', self.type, params[0]) params.shift self.new(*params) end |
.type ⇒ Object
552 553 554 |
# File 'lib/wamp_client/message.rb', line 552 def self.type Types::SUBSCRIBED end |
Instance Method Details
#payload ⇒ Object
566 567 568 569 570 571 572 573 |
# File 'lib/wamp_client/message.rb', line 566 def payload payload = [self.class.type] payload.push(self.subscribe_request) payload.push(self.subscription) payload end |
#to_s ⇒ Object
575 576 577 |
# File 'lib/wamp_client/message.rb', line 575 def to_s 'SUBSCRIBED > ' + self.payload.to_s end |