Non-blocking RMR init ...
[ric-plt/alarm-go.git] / alarm / alarm_test.go
index ea56b00..1f7a071 100755 (executable)
@@ -25,7 +25,7 @@ import (
        "testing"
        "time"
 
-       "gerrit.o-ran-sc.org/r/ric-plt/alarm-go/alarm"
+       "gerrit.o-ran-sc.org/r/ric-plt/alarm-go.git/alarm"
 )
 
 var alarmer *alarm.RICAlarm
@@ -37,6 +37,7 @@ func TestAlarmInitSuccess(t *testing.T) {
        assert.Equal(t, false, a == nil)
 
        alarmer = a
+       time.Sleep(time.Duration(5 * time.Second))
 }
 
 func TestAlarmRaiseSuccess(t *testing.T) {
@@ -81,7 +82,20 @@ func TestAlarmSendSuccess(t *testing.T) {
        go alarmer.ReceiveMessage(consumer)
        time.Sleep(time.Duration(1 * time.Second))
 
-       m := alarmer.NewAlarmMessage(a, alarm.AlarmActionRaise)
-       err := alarmer.SendMessage(m)
+       err := alarmer.Raise(a)
        assert.Nil(t, err, "send failed")
 }
+
+func TestSetManagedObjectIdSuccess(t *testing.T) {
+       alarmer.SetManagedObjectId("new-pod")
+
+       a := alarmer.NewAlarm(1234, alarm.SeverityMajor, "Some App data", "eth 0 1")
+       assert.Equal(t, a.ManagedObjectId, "new-pod")
+}
+
+func TestSetApplicationIdSuccess(t *testing.T) {
+       alarmer.SetApplicationId("new-app")
+
+       a := alarmer.NewAlarm(1234, alarm.SeverityMajor, "Some App data", "eth 0 1")
+       assert.Equal(t, a.ApplicationId, "new-app")
+}