Class: AMQP::Broker

Inherits:

Object

• Object
• AMQP::Broker

show all

Defined in:

lib/amqp/broker.rb

Overview

Constant Summary

RABBITMQ_PRODUCT =

API

"RabbitMQ".freeze

Instance Attribute Summary (collapse)

• - (Hash) properties readonly

  Broker information.

Product information (collapse)

• - (String) product

  Broker product information.

• - (Boolean) rabbitmq?

  True if broker is RabbitMQ.

• - (String) version

  Broker version.

Product capabilities (collapse)

• - (Boolean) supports_basic_nack?
• - (Boolean) supports_consumer_cancel_notifications?
• - (Boolean) supports_exchange_to_exchange_bindings?
• - (Boolean) supports_publisher_confirmations?

Instance Method Summary (collapse)

• - (Hash) initialize(properties) constructor

  Properties Broker information.

20
21
22

# File 'lib/amqp/broker.rb', line 20

def initialize(properties)
  @properties = properties
end

16
17
18

# File 'lib/amqp/broker.rb', line 16

def properties
  @properties
end

32
33
34

# File 'lib/amqp/broker.rb', line 32

def product
  @product ||= @properties["product"]
end

27
28
29

# File 'lib/amqp/broker.rb', line 27

def rabbitmq?
  self.product == RABBITMQ_PRODUCT
end

53
54
55

# File 'lib/amqp/broker.rb', line 53

def supports_basic_nack?
  @properties["capabilities"]["basic.nack"]
end

58
59
60

# File 'lib/amqp/broker.rb', line 58

def supports_consumer_cancel_notifications?
  @properties["capabilities"]["consumer_cancel_notify"]
end

63
64
65

# File 'lib/amqp/broker.rb', line 63

def supports_exchange_to_exchange_bindings?
  @properties["capabilities"]["exchange_exchange_bindings"]
end

48
49
50

# File 'lib/amqp/broker.rb', line 48

def supports_publisher_confirmations?
  @properties["capabilities"]["publisher_confirms"]
end

37
38
39

# File 'lib/amqp/broker.rb', line 37

def version
  @version ||= @properties["version"]
end