Added new implementation for the following feature requests:
1. Transaction ID support for message sending
2. Exposing rmr_mbuf_t to applications – message receiving
3. Exposing rmr_mbuf_t to applcations – message sending
4. Support functions
Contribution also from: Juha Hyttinen <juha.hyttinen@nokia.com>
Change-Id: I0fcf10b4e8af50c3b68c31cc4f800a00cd79b8f0
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>
diff --git a/pkg/xapp/xapp_test.go b/pkg/xapp/xapp_test.go
index 84a910f..65c6b98 100755
--- a/pkg/xapp/xapp_test.go
+++ b/pkg/xapp/xapp_test.go
@@ -32,8 +32,9 @@
type Consumer struct {
}
-func (m Consumer) Consume(mtype, sid int, payload []byte, meid *RMRMeid) (err error) {
- Sdl.Store("myKey", payload)
+func (m Consumer) Consume(params *RMRParams) (err error) {
+ //Logger.Info("Message received - type=%d subId=%d meid=%v xid=%s src=%s", params.Mtype, params.SubId, params.Meid, params.Xid, params.Src)
+ Sdl.Store("myKey", params.Payload)
return nil
}
@@ -100,7 +101,13 @@
func TestMessagesReceivedSuccessfully(t *testing.T) {
for i := 0; i < 100; i++ {
- Rmr.Send(10004, 1111, []byte{1, 2, 3, 4, 5, 6}, &RMRMeid{PlmnID: "1234", EnbID: "7788"})
+ params := &RMRParams{}
+ params.Mtype = 10004
+ params.SubId = -1
+ params.Payload = []byte{1, 2, 3, 4, 5, 6}
+ params.Meid = &RMRMeid{PlmnID: "1234", EnbID: "7788"}
+ params.Xid = "TestXID"
+ Rmr.SendMsg(params)
}
// Allow time to process the messages