Class: AzureClient::BufferedQueueMessage

Inherits:
Object
  • Object
show all
Defined in:
lib/azure_client/buffered_queue_message.rb

Instance Method Summary collapse

Constructor Details

#initialize(message, container, retry_policy = ExponentialRetryPolicy.new(5,1,2)) ⇒ BufferedQueueMessage

Returns a new instance of BufferedQueueMessage.



4
5
6
7
8
9
10
 
# File 'lib/azure_client/buffered_queue_message.rb', line 4

def initialize(message, container, retry_policy = ExponentialRetryPolicy.new(5,1,2))
  @message = message
  @parsed_message = parse
  @container = container
  @retry_policy = retry_policy
  @blob = get_blob
end

Instance Method Details

#delete(retry_policy = @retry_policy) ⇒ Object 



24
25
26
27
28
29
30
 
# File 'lib/azure_client/buffered_queue_message.rb', line 24

def delete(retry_policy = @retry_policy)
  if @blob
    @blob.delete(@retry_policy)
  else
    @message.delete(@retry_policy)
  end
end

#get_content ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/azure_client/buffered_queue_message.rb', line 12

def get_content
  if @blob
    @blob.get_content
  else
    @parsed_message["content"]
  end
end

#get_metadata ⇒ Object 



20
21
22
 
# File 'lib/azure_client/buffered_queue_message.rb', line 20

def get_metadata
  @parsed_message["metadata"]
end