ESDK-4275 Fixed the ReactorWatchlistJUnitNew.dictionaryRecoveryTest() method to handle WRITE_CALL_AGAIN from the ReactorChannel.submit() method.

soranat · soranat · commit a75869a36277 · 2020-08-27T16:43:46.000-05:00
diff --git a/Java/Eta/ValueAdd/src/test/java/com/thomsonreuters/upa/valueadd/reactor/ReactorWatchlistJUnitNew.java b/Java/Eta/ValueAdd/src/test/java/com/thomsonreuters/upa/valueadd/reactor/ReactorWatchlistJUnitNew.java
@@ -19865,7 +19865,15 @@ public void dictionaryRecoveryTest()
     	eIter.setBufferAndRWFVersion(buffer, provider.reactorChannel().majorVersion(), provider.reactorChannel().majorVersion());
         assertEquals(CodecReturnCodes.SUCCESS, dictionaryRefresh.encode(eIter));
         submitOptions.clear();
-        assertTrue(provider.reactorChannel().submit(buffer, submitOptions, errorInfo) >= ReactorReturnCodes.SUCCESS);
+        
+        int ret = 0;
+        
+        do
+        {
+        	ret = provider.reactorChannel().submit(buffer, submitOptions, errorInfo);
+        }while(ret == ReactorReturnCodes.WRITE_CALL_AGAIN);
+        
+        assertTrue(ret >= ReactorReturnCodes.SUCCESS);
         providerReactor.dispatch(0);
 
         /* Consumer receives refresh. */
