Module: Wampproto::Message

Defined in:
lib/wampproto/message.rb,
lib/wampproto/message/base.rb,
lib/wampproto/message/call.rb,
lib/wampproto/message/abort.rb,
lib/wampproto/message/error.rb,
lib/wampproto/message/event.rb,
lib/wampproto/message/hello.rb,
lib/wampproto/message/yield.rb,
lib/wampproto/message/result.rb,
lib/wampproto/message/goodbye.rb,
lib/wampproto/message/publish.rb,
lib/wampproto/message/welcome.rb,
lib/wampproto/message/register.rb,
lib/wampproto/message/challenge.rb,
lib/wampproto/message/published.rb,
lib/wampproto/message/subscribe.rb,
lib/wampproto/message/invocation.rb,
lib/wampproto/message/registered.rb,
lib/wampproto/message/subscribed.rb,
lib/wampproto/message/unregister.rb,
lib/wampproto/message/unsubscribe.rb,
lib/wampproto/message/authenticate.rb,
lib/wampproto/message/unregistered.rb,
lib/wampproto/message/unsubscribed.rb

Overview

message root

Defined Under Namespace

Modules: Type Classes: Abort, Authenticate, Base, Call, Challenge, Error, Event, Goodbye, Hello, Invocation, Publish, Published, Register, Registered, Result, Subscribe, Subscribed, Unregister, Unregistered, Unsubscribe, Unsubscribed, Welcome, Yield

Constant Summary collapse

HANDLER = 
{
  Type::HELLO => Hello,
  Type::WELCOME => Welcome,
  Type::ABORT => Abort,
  Type::CHALLENGE => Challenge,
  Type::AUTHENTICATE => Authenticate,
  Type::GOODBYE => Goodbye,

  Type::ERROR => Error,

  Type::PUBLISH => Publish,
  Type::PUBLISHED => Published,

  Type::SUBSCRIBE => Subscribe,
  Type::SUBSCRIBED => Subscribed,
  Type::UNSUBSCRIBE => Unsubscribe,
  Type::UNSUBSCRIBED => Unsubscribed,
  Type::EVENT => Event,

  Type::CALL => Call,
  Type::RESULT => Result,

  Type::REGISTER => Register,
  Type::REGISTERED => Registered,
  Type::UNREGISTER => Unregister,
  Type::UNREGISTERED => Unregistered,
  Type::INVOCATION => Invocation,
  Type::YIELD => Yield
}.freeze

Class Method Summary collapse

Class Method Details

.resolve(wamp_message) ⇒ Object 



98
99
100
101
102
103
104
105
106
 
# File 'lib/wampproto/message.rb', line 98

def self.resolve(wamp_message)
  type, = Validate.array!("Wamp Message", wamp_message)
  begin
    HANDLER[type].parse(wamp_message)
  rescue StandardError => e
    p wamp_message
    raise e
  end
end