}, time.Now().Add(networkLatency))
		}
	}

	return network.NewConnection(dest.Name(), request)
}

func (m *Instance) ShutDown() {
	m.networkQ.ShutDown()
	m.nodes.ShutDown()
}

func (m *Instance) NewNodes(count int, serviceTime time.Duration, enableQueueLatency bool, locality locality.Instance) Nodes {
	out := make(Nodes, 0, count)
	for i := 0; i < count; i++ {
		name := fmt.Sprintf("%s_%d", locality, i)