package xstream

//// func Example() {
//// 	var (
//// 		m      = model.NewModelDefault()
//// 		queue  = "coreserver.newaccount"
//// 		msgval = map[string]interface{}{
//// 			"sign":    "",
//// 			"appid":   c.AppId,
//// 			"userid":  c.UserId,
//// 			"account": input.Address,
//// 		}
//// 		msgstr, _ = json.Marshal(msgval)
//// 	)
//// 	defer m.Close()
////
//// 	if _, err = m.Redis.Do("XADD", queue, "*", "msg", msgstr); err != nil {
//// 		log.Warningf("!!!!FAILED add newaccount to redis queue, msg is:'%s'", msgstr)
//// 	}
//// }