Module: Wamp::Client

Defined in:
lib/wamp/client.rb,
lib/wamp/client/auth.rb,
lib/wamp/client/check.rb,
lib/wamp/client/defer.rb,
lib/wamp/client/message.rb,
lib/wamp/client/session.rb,
lib/wamp/client/version.rb,
lib/wamp/client/connection.rb,
lib/wamp/client/serializer.rb,
lib/wamp/client/transport/base.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, Defer, Message, Serializer, Transport Classes: Call, CallError, CallResult, Connection, Registration, Session, Subscription

Constant Summary collapse

WAMP_FEATURES = 
{
    caller: {
        features: {
            caller_identification: true,
            call_timeout: true,
            call_canceling: true,
            progressive_call_results: true
        }
    },
    callee: {
        features: {
            caller_identification: true,
            ##call_trustlevels: true,
            pattern_based_registration: true,
            shared_registration: true,
            ##call_timeout: true,
            call_canceling: true,
            progressive_call_results: true,
            registration_revocation: true
        }
    },
    publisher: {
        features: {
            publisher_identification: true,
            subscriber_blackwhite_listing: true,
            publisher_exclusion: true
        }
    },
    subscriber: {
        features: {
            publisher_identification: true,
            ##publication_trustlevels: true,
            pattern_based_subscription: true,
            subscription_revocation: true
            ##event_history: true,
        }
    }
}
HANDLER_LOOKUP = 
{
    # Error Responses
    Message::Types::SUBSCRIBE => -> s,m { s._process_SUBSCRIBE_error(m) },
    Message::Types::UNSUBSCRIBE => -> s,m { s._process_UNSUBSCRIBE_error(m) },
    Message::Types::PUBLISH => -> s,m { s._process_PUBLISH_error(m) },
    Message::Types::REGISTER => -> s,m { s._process_REGISTER_error(m) },
    Message::Types::UNREGISTER => -> s,m { s._process_UNREGISTER_error(m) },
    Message::Types::CALL => -> s,m { s._process_CALL_error(m) },

    # Result Responses
    Message::Types::SUBSCRIBED => -> s,m { s._process_SUBSCRIBED(m) },
    Message::Types::UNSUBSCRIBED => -> s,m { s._process_UNSUBSCRIBED(m) },
    Message::Types::PUBLISHED => -> s,m { s._process_PUBLISHED(m) },
    Message::Types::EVENT => -> s,m { s._process_EVENT(m) },
    Message::Types::REGISTERED => -> s,m { s._process_REGISTERED(m) },
    Message::Types::UNREGISTERED => -> s,m { s._process_UNREGISTERED(m) },
    Message::Types::INVOCATION => -> s,m { s._process_INVOCATION(m) },
    Message::Types::INTERRUPT => -> s,m { s._process_INTERRUPT(m) },
    Message::Types::RESULT => -> s,m { s._process_RESULT(m) },
}
VERSION = 
'0.1.3'

Class Method Summary collapse

Class Method Details

.log_level=(log_level) ⇒ Object

Sets the log level

Parameters:

  • log_level (Symbol) —

    • the desired log level



53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
 
# File 'lib/wamp/client.rb', line 53

def self.log_level=(log_level)
  level =
      case log_level
      when :error
        Logger::ERROR
      when :debug
        Logger::DEBUG
      when :fatal
        Logger::FATAL
      when :warn
        Logger::WARN
      else
        Logger::INFO
      end
  self.logger.level = level
end

.logger ⇒ Object

Returns the logger object



42
43
44
45
46
47
48
 
# File 'lib/wamp/client.rb', line 42

def self.logger
  unless defined?(@logger)
    @logger = Logger.new(STDOUT)
    @logger.level = Logger::INFO
  end
  @logger
end