diff --git a/app/plugins/contactRetry_test.go b/app/plugins/contactRetry_test.go index 0ebbd72..407f08a 100644 --- a/app/plugins/contactRetry_test.go +++ b/app/plugins/contactRetry_test.go @@ -63,6 +63,8 @@ func TestContactRetryQueue(t *testing.T) { // Publish an unrelated event to trigger the Plugin to go through a queuing cycle // If we didn't do this we would have to wait 30 seconds for a check-in bus.Publish(event.NewEvent(event.PeerStateChange, map[event.Field]string{event.RemotePeer: "test2", event.ConnectionState: "Disconnected"})) + bus.Publish(event.NewEvent(event.QueuePeerRequest, map[event.Field]string{event.RemotePeer: testOnion, event.LastSeen: time.Now().Format(time.RFC3339Nano)})) + time.Sleep(time.Second) pinf, _ = cr.connections.Load(testOnion) if pinf.(*contact).state != 1 {