Module: Wamp::Client

Defined in:
lib/wamp/client.rb,
lib/wamp/client/auth.rb,
lib/wamp/client/check.rb,
lib/wamp/client/event.rb,
lib/wamp/client/logging.rb,
lib/wamp/client/message.rb,
lib/wamp/client/session.rb,
lib/wamp/client/version.rb,
lib/wamp/client/response.rb,
lib/wamp/client/connection.rb,
lib/wamp/client/serializer.rb,
lib/wamp/client/manager/base.rb,
lib/wamp/client/request/base.rb,
lib/wamp/client/request/call.rb,
lib/wamp/client/transport/base.rb,
lib/wamp/client/request/publish.rb,
lib/wamp/client/request/register.rb,
lib/wamp/client/manager/establish.rb,
lib/wamp/client/request/subscribe.rb,
lib/wamp/client/request/unregister.rb,
lib/wamp/client/request/unsubscribe.rb,
lib/wamp/client/manager/registration.rb,
lib/wamp/client/manager/subscription.rb,
lib/wamp/client/manager/base_multiple.rb,
lib/wamp/client/transport/faye_web_socket.rb,
lib/wamp/client/transport/event_machine_base.rb,
lib/wamp/client/transport/web_socket_event_machine.rb

Defined Under Namespace

Modules: Auth, Check, Event, Logging, Manager, Message, Request, Response, Serializer, Transport Classes: Connection, Session

Constant Summary collapse

CLOSED_SESSION_METHOD_LOOKUP = 
{
    Message::Types::WELCOME => -> s, m { s.establish.welcome(m) },
    Message::Types::CHALLENGE => -> s, m { s.establish.challenge(m) },
    Message::Types::ABORT => -> s, m { s.establish.abort(m) },
}
OPEN_SESSION_METHOD_LOOKUP = 
{
    # Establish Response
    Message::Types::GOODBYE => -> s, m { s.establish.goodbye(m) },

    # Error Responses
    Message::Types::SUBSCRIBE => -> s, m { s.request[:subscribe].error(m) },
    Message::Types::UNSUBSCRIBE => -> s, m { s.request[:unsubscribe].error(m) },
    Message::Types::PUBLISH => -> s, m { s.request[:publish].error(m) },
    Message::Types::REGISTER => -> s, m { s.request[:register].error(m) },
    Message::Types::UNREGISTER => -> s, m { s.request[:unregister].error(m) },
    Message::Types::CALL => -> s, m { s.request[:call].error(m) },

    # Result Responses
    Message::Types::SUBSCRIBED => -> s, m { s.request[:subscribe].success(m) },
    Message::Types::UNSUBSCRIBED => -> s, m { s.request[:unsubscribe].success(m) },
    Message::Types::PUBLISHED => -> s, m { s.request[:publish].success(m) },
    Message::Types::EVENT => -> s, m { s.subscription.event(m) },
    Message::Types::REGISTERED => -> s, m { s.request[:register].success(m) },
    Message::Types::UNREGISTERED => -> s, m { s.request[:unregister].success(m) },
    Message::Types::INVOCATION => -> s, m { s.registration.invoke(m) },
    Message::Types::INTERRUPT => -> s, m { s.registration.interrupt(m) },
    Message::Types::RESULT => -> s, m { s.request[:call].success(m) },
}
VERSION = 
'0.2.2'

Class Method Summary collapse

Class Method Details

.log_level=(log_level) ⇒ Object

Sets the log level

Parameters:

  • log_level (Symbol) —

    • the desired log level



22
23
24
 
# File 'lib/wamp/client.rb', line 22

def self.log_level=(log_level)
  Logging.log_level = log_level
end

.logger ⇒ Object

Returns the logger object



15
16
17
 
# File 'lib/wamp/client.rb', line 15

def self.logger
  Logging.logger
end