From cabefa74fab371bc0ce35990435b762ef49b8ec1 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 4 Mar 2024 15:35:49 -0500 Subject: [PATCH] Adjust Pulsar binder code for Boot 3.2/3.3 --- .../stream/binder/pulsar/PulsarMessageChannelBinder.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/PulsarMessageChannelBinder.java b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/PulsarMessageChannelBinder.java index 342b443f5..c933d5bd4 100644 --- a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/PulsarMessageChannelBinder.java +++ b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/PulsarMessageChannelBinder.java @@ -1,5 +1,5 @@ /* - * Copyright 2022-2023 the original author or authors. + * Copyright 2022-2024 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -19,7 +19,6 @@ package org.springframework.cloud.stream.binder.pulsar; import java.util.Optional; import java.util.Set; -import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.common.schema.SchemaType; @@ -290,7 +289,7 @@ public class PulsarMessageChannelBinder extends .sendAsync(); // @formatter:on } - catch (PulsarClientException ex) { + catch (Exception ex) { logger.trace(ex, "Failed to send message to destination: " + this.destination); } }