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{}) | |
} |