diff --git a/pubsub/pstest/fake.go b/pubsub/pstest/fake.go index d4894192e625..463881e4210a 100644 --- a/pubsub/pstest/fake.go +++ b/pubsub/pstest/fake.go @@ -1166,7 +1166,7 @@ func orderMsgs(msgs map[string]*message, enableMessageOrdering bool) map[string] if orderingKey == "" { orderingKey = id } - if val, ok := orderingKeyMap[orderingKey]; !ok || m.proto.Message.PublishTime.AsTime().Before(val.m.proto.Message.PublishTime.AsTime()) { + if val, ok := orderingKeyMap[orderingKey]; !ok || m.publishTime.Before(val.m.publishTime) { orderingKeyMap[orderingKey] = msg{m: m, id: id} } }