Skip to content
This repository has been archived by the owner on Apr 4, 2024. It is now read-only.

Commit

Permalink
service name
Browse files Browse the repository at this point in the history
  • Loading branch information
yihuang committed Aug 11, 2022
1 parent c1e299e commit a6fc34a
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions server/indexer_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ import (
)

const (
Subscriber = "EVMIndexerService"
ServiceName = "EVMIndexerService"

NewBlockWaitTimeout = 60 * time.Second
)
Expand All @@ -31,7 +31,7 @@ func NewEVMIndexerService(
client rpcclient.Client,
) *EVMIndexerService {
is := &EVMIndexerService{txIdxr: txIdxr, client: client}
is.BaseService = *service.NewBaseService(nil, "EVMIndexerService", is)
is.BaseService = *service.NewBaseService(nil, ServiceName, is)
return is
}

Expand All @@ -51,7 +51,7 @@ func (eis *EVMIndexerService) OnStart() error {
// sometimes happen when there are no other subscribers.
blockHeadersChan, err := eis.client.Subscribe(
ctx,
Subscriber,
ServiceName,
types.QueryForEvent(types.EventNewBlockHeader).String(),
0)
if err != nil {
Expand Down

0 comments on commit a6fc34a

Please sign in to comment.