Class: ActiveMessaging::Adapters::AmazonSqs::Queue

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

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

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

Returns a new instance of Queue.



391
392
393
 
# File 'lib/activemessaging/adapters/asqs.rb', line 391

def initialize name, domain, vt=nil
  @name, @pathinfo, @domain, @visibility_timeout = name, pathinfo, domain, vt
end

Instance Attribute Details

#domain ⇒ Object

Returns the value of attribute domain.



378
379
380
 
# File 'lib/activemessaging/adapters/asqs.rb', line 378

def domain
  @domain
end

#name ⇒ Object

Returns the value of attribute name.



378
379
380
 
# File 'lib/activemessaging/adapters/asqs.rb', line 378

def name
  @name
end

#pathinfo ⇒ Object

Returns the value of attribute pathinfo.



378
379
380
 
# File 'lib/activemessaging/adapters/asqs.rb', line 378

def pathinfo
  @pathinfo
end

#visibility_timeout ⇒ Object

Returns the value of attribute visibility_timeout.



378
379
380
 
# File 'lib/activemessaging/adapters/asqs.rb', line 378

def visibility_timeout
  @visibility_timeout
end

Class Method Details

.from_url(url) ⇒ Object 



380
381
382
383
384
385
 
# File 'lib/activemessaging/adapters/asqs.rb', line 380

def self.from_url url
  u = URI.parse(url)
  name = u.path.gsub(/\//, "")
  domain  = u.host
  return Queue.new(name,domain) 
end

Instance Method Details

#queue_url ⇒ Object 



387
388
389
 
# File 'lib/activemessaging/adapters/asqs.rb', line 387

def queue_url
  "#{pathinfo}/#{name}"
end

#to_s ⇒ Object 



395
396
397
 
# File 'lib/activemessaging/adapters/asqs.rb', line 395

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