ps := pubsub.New()

ps.OnConnect(func(c *pubsub.Connection) {
    log.Printf("OnConnect (ID: %d)\n", c.ID)
})

ps.OnDisconnect(func(c *pubsub.Connection) {
    log.Printf("OnDisconnect (ID: %d)\n", c.ID)
})

ps.OnError(func(c *pubsub.Connection, err error) {
    log.Printf("OnError (ID: %d), err: %s\n", c.ID, err)
})

ps.OnInfo(func(c *pubsub.Connection, str string) {
    log.Printf("OnInfo (ID: %d), str: %s\n", c.ID, str)
})

ps.OnMessage(func(c *pubsub.Connection, msg *pubsub.Answer) {
    log.Printf("OnMessage (ID: %d), msg: %#v\n", c.ID, msg)
})

ps.OnPing(func(c *pubsub.Connection, start time.Time) {
    log.Printf("OnPing (ID: %d), start: %d\n", c.ID, start.Unix())
})

ps.OnPong(func(c *pubsub.Connection, start, end time.Time) {
    log.Printf("OnPong (ID: %d), start: %d, end: %d\n", c.ID, start.Unix(), end.Unix())
})

ps.Listen(context.Background(), "community-points-channel-v1", "<UserID>")

interrupt := make(chan os.Signal, 1)
signal.Notify(interrupt, os.Interrupt)
<-interrupt

ps.Close()