Class: Isimud::Client Abstract

Inherits:

Object

• Object
• Isimud::Client

show all

Includes:

Logging

Defined in:

lib/isimud/client.rb

Overview

Instance Method Summary (collapse)

• - (Object) bind(queue_name, exchange_name, *keys, &method)
• - (Object) channel
• - (Object) close
• - (Object) connect
• - (Boolean) connected?
• - (Object) create_queue(queue_name, exchange_name, options = {})
• - (Object) delete_queue(queue_name)
• - (Object) find_queue(queue_name, options = {})
• - (Client) initialize(server = nil, options = nil) constructor

  A new instance of Client.

• - (Object) on_exception {|e| ... }

  Declare a proc to be run whenever an uncaught exception is raised within a message processing block.

• - (Object) publish(exchange, routing_key, payload)
• - (Object) reconnect
• - (Object) reset
• - (Object) run_exception_handlers(exception)

  Call each of the exception handlers declared by #on_exception.

• - (Object) subscribe(queue, options = {}, &block)

Methods included from Logging

#log, #logger

6
7

# File 'lib/isimud/client.rb', line 6

def initialize(server = nil, options = nil)
end

9
10

# File 'lib/isimud/client.rb', line 9

def bind(queue_name, exchange_name, *keys, &method)
end

12
13

# File 'lib/isimud/client.rb', line 12

def channel
end

15
16

# File 'lib/isimud/client.rb', line 15

def close
end

18
19

# File 'lib/isimud/client.rb', line 18

def connect
end

21
22

# File 'lib/isimud/client.rb', line 21

def connected?
end

24
25

# File 'lib/isimud/client.rb', line 24

def create_queue(queue_name, exchange_name, options = {})
end

27
28

# File 'lib/isimud/client.rb', line 27

def delete_queue(queue_name)
end

30
31

# File 'lib/isimud/client.rb', line 30

def find_queue(queue_name, options = {})
end

36
37
38

# File 'lib/isimud/client.rb', line 36

def on_exception(&block)
  exception_handlers << block
end

46
47

# File 'lib/isimud/client.rb', line 46

def publish(exchange, routing_key, payload)
end

49
50

# File 'lib/isimud/client.rb', line 49

def reconnect
end

52
53

# File 'lib/isimud/client.rb', line 52

def reset
end

42
43
44

# File 'lib/isimud/client.rb', line 42

def run_exception_handlers(exception)
  exception_handlers.each{|handler| handler.call(exception)}
end

55
56

# File 'lib/isimud/client.rb', line 55

def subscribe(queue, options = {}, &block)
end