Class: ActiveMessaging::Adapters::Sqs::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/activemessaging/adapters/sqs.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, url, vt = nil) ⇒ Queue 



439
440
441
 
# File 'lib/activemessaging/adapters/sqs.rb', line 439

def initialize name, url, vt=nil
  @name, @url, @visibility_timeout = name, url, vt
end

Instance Attribute Details

#domain ⇒ Object

Returns the value of attribute domain.



426
427
428
 
# File 'lib/activemessaging/adapters/sqs.rb', line 426

def domain
  @domain
end

#name ⇒ Object

Returns the value of attribute name.



426
427
428
 
# File 'lib/activemessaging/adapters/sqs.rb', line 426

def name
  @name
end

#pathinfo ⇒ Object

Returns the value of attribute pathinfo.



426
427
428
 
# File 'lib/activemessaging/adapters/sqs.rb', line 426

def pathinfo
  @pathinfo
end

#url ⇒ Object

Returns the value of attribute url.



426
427
428
 
# File 'lib/activemessaging/adapters/sqs.rb', line 426

def url
  @url
end

#visibility_timeout ⇒ Object

Returns the value of attribute visibility_timeout.



426
427
428
 
# File 'lib/activemessaging/adapters/sqs.rb', line 426

def visibility_timeout
  @visibility_timeout
end

Class Method Details

.from_url(url) ⇒ Object 



428
429
430
431
432
433
 
# File 'lib/activemessaging/adapters/sqs.rb', line 428

def self.from_url url
  uri = URI.parse(url)
  name = uri.path.split('/').last
  domain = uri.host
  return Queue.new(name, uri)
end

Instance Method Details

#queue_url ⇒ Object 



435
436
437
 
# File 'lib/activemessaging/adapters/sqs.rb', line 435

def queue_url
  url.to_s
end

#to_s ⇒ Object 



443
444
445
 
# File 'lib/activemessaging/adapters/sqs.rb', line 443

def to_s
  "<AmazonSQS::Queue name='#{name}' url='#{url}' visibility_timeout='#{visibility_timeout}'>"
end