Fix flapping tests

Signed-off-by: Derek Collison <derek@nats.io>

server/jetstream_cluster_3_test.go

@@ -2742,11 +2742,7 @@ func TestJetStreamClusterInterestPolicyEphemeral(t *testing.T) {
 			// This happens only if we start publishing messages after consumer was created.
 			go func() {
 				for i := 0; i < msgs; i++ {
-					js.PublishAsync(test.subject, []byte("DATA"))
-				}
-				select {
-				case <-js.PublishAsyncComplete():
-				case <-time.After(5 * inactiveThreshold):
+					js.Publish(test.subject, []byte("DATA"))
 				}
 			}()
 

server/jetstream_super_cluster_test.go

@@ -2082,14 +2082,9 @@ func TestJetStreamSuperClusterMovingStreamAndMoveBack(t *testing.T) {
 
 			toSend := 10_000
 			for i := 0; i < toSend; i++ {
-				_, err := js.PublishAsync("TEST", []byte("HELLO WORLD"))
+				_, err := js.Publish("TEST", []byte("HELLO WORLD"))
 				require_NoError(t, err)
 			}
-			select {
-			case <-js.PublishAsyncComplete():
-			case <-time.After(5 * time.Second):
-				t.Fatalf("Did not receive completion signal")
-			}
 
 			_, err = js.UpdateStream(&nats.StreamConfig{
 				Name:      "TEST",