fix actor serialization (#441)

* substitute json encoder with serializer

Signed-off-by: mikeee <[email protected]>

* substitution for custom serializer

Signed-off-by: mikeee <[email protected]>

---------

Signed-off-by: mikeee <[email protected]>

Author: mikeee

actor/manager/manager.go

@@ -15,7 +15,6 @@ package manager
 
 import (
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
 	"log"
@@ -181,7 +180,7 @@ func (m *DefaultActorManagerContext) InvokeReminder(ctx context.Context, actorID
 		return actorErr.ErrActorFactoryNotSet
 	}
 	reminderParams := &api.ActorReminderParams{}
-	if err := json.Unmarshal(params, reminderParams); err != nil {
+	if err := m.serializer.Unmarshal(params, reminderParams); err != nil {
 		log.Printf("failed to unmarshal reminder param, err: %v ", err)
 		return actorErr.ErrRemindersParamsInvalid
 	}
@@ -204,7 +203,7 @@ func (m *DefaultActorManagerContext) InvokeTimer(ctx context.Context, actorID, t
 		return actorErr.ErrActorFactoryNotSet
 	}
 	timerParams := &api.ActorTimerParam{}
-	if err := json.Unmarshal(params, timerParams); err != nil {
+	if err := m.serializer.Unmarshal(params, timerParams); err != nil {
 		log.Printf("failed to unmarshal reminder param, err: %v ", err)
 		return actorErr.ErrTimerParamsInvalid
 	}

client/actor.go

@@ -15,7 +15,6 @@ package client
 
 import (
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
 	"reflect"
@@ -400,7 +399,7 @@ func (c *GRPCClient) makeCallProxyFunction(actor actor.Client, methodName string
 
 		var data []byte
 		if len(inIArr) > 0 {
-			data, err = json.Marshal(inIArr[0])
+			data, err = serializer.Marshal(inIArr[0])
 		}
 		if err != nil {
 			panic(err)