Class: Bunny::DeliveryInfo

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/bunny/delivery_info.rb

Overview

Wraps AMQ::Protocol::Basic::Deliver to provide access to the delivery properties as immutable hash as well as methods.

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#channelBunny::Channel (readonly)

Returns Channel this delivery is on

Returns:



22
23
24
# File 'lib/bunny/delivery_info.rb', line 22

def channel
  @channel
end

#consumerBunny::Consumer (readonly)

Returns Consumer this delivery is for

Returns:



20
21
22
# File 'lib/bunny/delivery_info.rb', line 20

def consumer
  @consumer
end

Instance Method Details

#[](k) ⇒ Object

Accesses delivery properties by key

See Also:

  • Hash#[]


48
49
50
# File 'lib/bunny/delivery_info.rb', line 48

def [](k)
  @hash[k]
end

#consumer_tagString

Returns Consumer tag this delivery is for

Returns:

  • (String)

    Consumer tag this delivery is for



68
69
70
# File 'lib/bunny/delivery_info.rb', line 68

def consumer_tag
  @basic_deliver.consumer_tag
end

#delivery_tagString

Returns Delivery identifier that is used to acknowledge, reject and nack deliveries

Returns:

  • (String)

    Delivery identifier that is used to acknowledge, reject and nack deliveries



73
74
75
# File 'lib/bunny/delivery_info.rb', line 73

def delivery_tag
  @basic_deliver.delivery_tag
end

#each(*args, &block) ⇒ Object

Iterates over the delivery properties

See Also:

  • Enumerable#each


42
43
44
# File 'lib/bunny/delivery_info.rb', line 42

def each(*args, &block)
  @hash.each(*args, &block)
end

#exchangeString

Returns Name of the exchange this message was published to

Returns:

  • (String)

    Name of the exchange this message was published to



84
85
86
# File 'lib/bunny/delivery_info.rb', line 84

def exchange
  @basic_deliver.exchange
end

#redeliveredBoolean Also known as: redelivered?

Returns true if this delivery is a redelivery (the message was requeued at least once)

Returns:

  • (Boolean)

    true if this delivery is a redelivery (the message was requeued at least once)



78
79
80
# File 'lib/bunny/delivery_info.rb', line 78

def redelivered
  @basic_deliver.redelivered
end

#routing_keyString

Returns Routing key this message was published with

Returns:

  • (String)

    Routing key this message was published with



89
90
91
# File 'lib/bunny/delivery_info.rb', line 89

def routing_key
  @basic_deliver.routing_key
end

#to_hashHash

Returns Hash representation of this delivery info

Returns:

  • (Hash)

    Hash representation of this delivery info



53
54
55
# File 'lib/bunny/delivery_info.rb', line 53

def to_hash
  @hash
end