TCK Challenge: RepeatedCasterResource#send fixes #1196

Signed-off-by: Jorge Bescos Gascon <[email protected]>

.gitignore

@@ -1,5 +1,6 @@
 target/
 .classpath
+.factorypath
 .project
 .settings/
 *.iml

jaxrs-tck/src/main/java/ee/jakarta/tck/ws/rs/jaxrs21/ee/sse/sseeventsource/JAXRSClientIT.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017, 2020 Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2017, 2023 Oracle and/or its affiliates. All rights reserved.
  *
  * This program and the accompanying materials are made available under the
  * terms of the Eclipse Public License v. 2.0, which is available at
@@ -633,8 +633,6 @@ public void closeTest() throws Fault {
     source.open();
     sleepUntilHolderGetsFilled(holder);
     assertNotNull(holder.get(), "Message was not received");
-    for (InboundSseEvent e : holder)
-      logMsg("Received message no", e.readData());
 
     // check the session is opened
     setProperty(Property.REQUEST, buildRequest(Request.GET, "repeat/isopen"));

jaxrs-tck/src/main/java/ee/jakarta/tck/ws/rs/jaxrs21/ee/sse/sseeventsource/RepeatedCasterResource.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017, 2020 Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2017, 2023 Oracle and/or its affiliates. All rights reserved.
  *
  * This program and the accompanying materials are made available under the
  * terms of the Eclipse Public License v. 2.0, which is available at
@@ -54,10 +54,10 @@ public void run() {
           isOpen = !sink.isClosed();
         }
         while (!sink.isClosed() && cast) {
-          sink.send(sse.newEvent(String.valueOf(cnt++)));
           try {
-            Thread.sleep(500L);
-          } catch (InterruptedException e1) {
+            sink.send(sse.newEvent(String.valueOf(cnt++)));
+            Thread.sleep(1L);
+          } catch (Exception e1) {
             cast = false;
           }
           synchronized (isOpen) {