Class: Thrift::SqsServerTransport

Inherits:
BaseServerTransport
  • Object
show all
Defined in:
lib/thrift-sqs-transport.rb

Instance Method Summary collapse

Constructor Details

#initialize(queue_name, aws_key, aws_secret, options = {}) ⇒ SqsServerTransport

Returns a new instance of SqsServerTransport.



6
7
8
9
 
# File 'lib/thrift-sqs-transport.rb', line 6

def initialize(queue_name, aws_key, aws_secret, options = {})
  @queue_name, @aws_key, @aws_secret = queue_name, aws_key, aws_secret
  @options = options
end

Instance Method Details

#accept ⇒ Object 



15
16
17
 
# File 'lib/thrift-sqs-transport.rb', line 15

def accept
  @transport
end

#close ⇒ Object 



19
20
21
 
# File 'lib/thrift-sqs-transport.rb', line 19

def close
  @transport.close if @transport
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


23
24
25
 
# File 'lib/thrift-sqs-transport.rb', line 23

def closed?
   @transport && !@transport.open?
end

#listen ⇒ Object 



11
12
13
 
# File 'lib/thrift-sqs-transport.rb', line 11

def listen
  @transport = SqsTransport.new(@queue_name, @aws_key, @aws_secret, @options)
end