Class: Foxbat::Pipeline

Inherits:
Object
  • Object
show all
Includes:
ChannelPipelineFactory
Defined in:
lib/foxbat/pipeline.rb

Instance Method Summary collapse

Constructor Details

#initialize(handler, ssl_context = nil) ⇒ Pipeline

Returns a new instance of Pipeline.



12
13
14
15
 
# File 'lib/foxbat/pipeline.rb', line 12

def initialize(handler, ssl_context=nil)
  @handler = handler
  @context = ssl_context
end

Instance Method Details

#getPipeline ⇒ Object 



17
18
19
20
21
22
23
24
25
 
# File 'lib/foxbat/pipeline.rb', line 17

def getPipeline
  pipeline = Channels.pipeline
  if @context
    engine = Security.create_ssl_engine(@context)
    pipeline.addLast("ssl", SslHandler.new(engine))
  end
  pipeline.addLast("handler", @handler.new)
  pipeline
end