blob: 03764a185cf8cae0e5b8cb7e5d58212ff2c3a831 [file] [log] [blame]
package main
import "gitlabe1.ext.net.nokia.com/ric_dev/nokia-xapps/xapp/pkg/xapp"
type MessageCounter struct {
}
func (m MessageCounter) Consume(mtype, len int, payload []byte) (err error) {
xapp.Logger.Debug("Message received - type=%d len=%d", mtype, len)
xapp.Sdl.Store("myKey", payload)
xapp.Rmr.Send(10005, len, payload)
return nil
}
func main() {
xapp.Run(MessageCounter{})
}