diff --git a/params/version.go b/params/version.go index 217aaa394362..bedb0d47e438 100644 --- a/params/version.go +++ b/params/version.go @@ -24,7 +24,7 @@ import ( const ( VersionMajor = 5 // Major version component of the current release VersionMinor = 1 // Minor version component of the current release - VersionPatch = 26 // Patch version component of the current release + VersionPatch = 27 // Patch version component of the current release VersionMeta = "mainnet" // Version metadata to append to the version string ) diff --git a/rollup/sync_service/sync_service.go b/rollup/sync_service/sync_service.go index e8efd9a54e53..05f95c47abf6 100644 --- a/rollup/sync_service/sync_service.go +++ b/rollup/sync_service/sync_service.go @@ -220,7 +220,9 @@ func (s *SyncService) fetchMessages() { } for _, msg := range msgs { - queueIndex++ + if msg.QueueIndex > 0 { + queueIndex++ + } // check if received queue index matches expected queue index if msg.QueueIndex != queueIndex { log.Error("Unexpected queue index in SyncService", "expected", queueIndex, "got", msg.QueueIndex, "msg", msg)