sub := SimulateSubscription([]*protocol.Envelope{
        protocol.NewEnvelope(msg1, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg2, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg3, *utils.GetUnixEpoch(), pubsubTopic1),
        protocol.NewEnvelope(msg4, *utils.GetUnixEpoch(), pubsubTopic1),