Bugfix to HttpUpstreamGateway

It contains a finite loop that keeps trying to send an event on a socket, but would not exit the loop when the sending succeeds, resulting in repeated events.
liflab · May 28, 2020 · be9702c · be9702c
1 parent 33a64a4
commit be9702c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/Http/src/ca/uqac/lif/cep/http/HttpUpstreamGateway.java b/Http/src/ca/uqac/lif/cep/http/HttpUpstreamGateway.java
@@ -115,13 +115,15 @@ protected boolean compute(Object[] inputs, Queue<Object[]> outputs) throws Proce
 		 * called as a result of a push. 
 		 */
 		String payload = (String) inputs[0];
+		boolean success = false;
 		if (m_pushMethod == Method.POST)
 		{
-			for (int i = 0; i < s_numRetries; i++)
+			for (int i = 0; i < s_numRetries && !success; i++)
 			{
 				try 
 				{
 					HttpGateway.sendPost(m_pushUrl, payload);
+					success = true;
 				}
 				catch (ConnectException ce)
 				{