(ids ...int64)
| 165 | } |
| 166 | |
| 167 | func (m *messageDB) get(ids ...int64) ([]*meta.PushMessage, error) { |
| 168 | log.Debugf("ids:%v", ids) |
| 169 | var mss []*meta.PushMessage |
| 170 | |
| 171 | for _, id := range ids { |
| 172 | v, err := m.stable.Get(util.EncodeInt64(id), nil) |
| 173 | if err != nil { |
| 174 | return nil, errors.Trace(err) |
| 175 | } |
| 176 | |
| 177 | var msg meta.PushMessage |
| 178 | if err = json.Unmarshal(v, &msg); err != nil { |
| 179 | return nil, errors.Trace(err) |
| 180 | } |
| 181 | |
| 182 | mss = append(mss, &msg) |
| 183 | } |
| 184 | |
| 185 | return mss, nil |
| 186 | } |