new_subscriber.go

func main() {
  // シグナルを受け取るまで待ち受けるためのChannel
  doneCh := make(chan struct{}
  
  t := tebata.New(syscall.SIGINT, syscall.SIGTERM)
  t.Reserve(func(doneCh chan struct{}){
    doneCh <- struct{}{}
  }, doneCh)
  
  // メッセージを受け取る処理をgoroutineで動かす
  go receive()
  
  // シグナルを受け取るまで待ち受ける
  <-doneCh
}

func receive() {
  for {
    select {
    // case msg := <-hoge(): メッセージを受け取って何か処理を行なう
  }
}