Class: Foxbat::Pipeline

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

Instance Method Summary collapse

Constructor Details

#initialize(handler, options = {}, ssl_context = nil, &block) ⇒ Pipeline

Returns a new instance of Pipeline.



13
14
15
16
17
18
 
# File 'lib/foxbat/pipeline.rb', line 13

def initialize(handler, options={}, ssl_context=nil, &block)
  @options = options
  @handler = handler
  @block = block
  @context = ssl_context
end

Instance Method Details

#getPipeline ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/foxbat/pipeline.rb', line 20

def getPipeline
  pipeline = Channels.pipeline
  if @context
    engine = Security.create_ssl_engine(@context)
    pipeline.addLast("ssl", SslHandler.new(engine))
  end
  h = @handler.new(@options)
  @block.call(h) if @block
  connection = NettyConnection.new(h)
  pipeline.addLast("handler", connection)
  pipeline
end