require "al_worker_message"
require "al_worker_tcp"

class AlWorker1 < AlWorker
  def initialize2()
    @msg = NumberedMessage.new()
    @tcp = Tcp.new.run( self )
    @tid = 1
  end

  # メッセージ送信コマンド
  def tcp_send( sock, param )
    @tid = @msg.send( {:message=>param[""]} )
    return true
  end

  # メッセージ受信コマンド
  #  receive() コマンドの使用例
  def tcp_a_recv( sock, param )
    tid = @tid
    loop {
      m = @msg.receive( tid )
      sock.puts m.to_s
      tid += 1
    }
  end

  # メッセージ受信コマンド
  #  cycle() メソッドの使用例
  def tcp_a_recv2( sock, param )
    @msg.cycle( @tid ) { |m|
      sock.puts m.to_s
    }
  end
end

AlWorker1.new.run