What happened?

When using JmsIO for publishing messages, we found out that messages are not being published when the connection is closed due to any reason (Network, Broker down ...). Even though we have the option to get failed published messages we don't have a way to have a retry policy.

 var failedPublishedMessages = messages.apply(getWriter(sinkOptions)).getFailedMessages();
 failedPublishedMessages.apply(REPUBLISH_FAILED_MESSAGE_NAME, getWriter(sinkOptions));
 return PDone.in(cdpMessages.getPipeline());

Note: the function getWriter returns JMS writer JmsIO.Write<Message>

Issue Priority

Priority: 1 (data loss / total loss of function)

Issue Components

• Component: IO connector