fix(heartbeat): inject ObjectMapper into InstanceHeartbeatService #42
+3
-1
@@ -24,6 +24,9 @@ class InstanceHeartbeatService:
|
|||||||
@Inject
|
@Inject
|
||||||
private var redis: RedisDataSource = uninitialized
|
private var redis: RedisDataSource = uninitialized
|
||||||
|
|
||||||
|
@Inject
|
||||||
|
private var mapper: ObjectMapper = uninitialized
|
||||||
|
|
||||||
@GrpcClient("coordinator-grpc")
|
@GrpcClient("coordinator-grpc")
|
||||||
private var channel: Channel = uninitialized
|
private var channel: Channel = uninitialized
|
||||||
|
|
||||||
@@ -38,7 +41,6 @@ class InstanceHeartbeatService:
|
|||||||
|
|
||||||
private var coordinatorStub: CoordinatorServiceStub = uninitialized
|
private var coordinatorStub: CoordinatorServiceStub = uninitialized
|
||||||
private val log = Logger.getLogger(classOf[InstanceHeartbeatService])
|
private val log = Logger.getLogger(classOf[InstanceHeartbeatService])
|
||||||
private val mapper = ObjectMapper()
|
|
||||||
private var instanceId = ""
|
private var instanceId = ""
|
||||||
private var redisPrefix = "nowchess"
|
private var redisPrefix = "nowchess"
|
||||||
private var streamObserver: Option[StreamObserver[HeartbeatFrame]] = None
|
private var streamObserver: Option[StreamObserver[HeartbeatFrame]] = None
|
||||||
|
|||||||
Reference in New Issue
Block a user