Skip to content

Commit f3e139c

Browse files
Joel-hansonCopilot
andauthored
Apply suggestions from code review
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Signed-off-by: Joel Hanson <joelhanson025@gmail.com>
1 parent 7336ce4 commit f3e139c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/ibm/eventstreams/connect/mqsource/builders/BaseRecordBuilder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,7 @@ private SourceRecord handleBuildException(final Message message, final Map<Strin
330330
final Exception exception) {
331331

332332
// If errors are tolerated but no DLQ is configured, skip the message
333-
if (dlqTopic == null) {
333+
if (dlqTopic == null || dlqTopic.isEmpty()) {
334334
log.debug(
335335
"Skipping message due to conversion error: error tolerance is enabled but DLQ is not configured. Message will not be processed further.");
336336
return null;
@@ -425,7 +425,7 @@ private Optional<byte[]> extractPayload(final Message message) {
425425
* @param message The orginal message
426426
*
427427
* @param originalTopic The original topic name
428-
* @param exception The execption that needs to be included in the header
428+
* @param exception The exception that needs to be included in the header
429429
*
430430
* @return Headers
431431
*/

0 commit comments

Comments
 (0)