SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adjust Pulsar binder code for Boot 3.2/3.3

Browse Source
This commit is contained in:
Soby Chacko
2024-03-04 15:35:49 -05:00
parent 6e168d92e6
commit cabefa74fa
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/main/java/org/springframework/cloud/stream/binder/pulsar/PulsarMessageChannelBinder.java
View File

@@ -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);
}
}