Skip to content

Commit 037cc58

Browse files
committed
Update various plugin dependencies
- commons-codec to 1.18.0 - commons-compress to 1.26.2 - Javaformat to 0.0.47 Also fixes format due to new javaformat rules. Resolves #1164 Signed-off-by: Chris Bono <[email protected]>
1 parent 6ad590e commit 037cc58

File tree

7 files changed

+19
-17
lines changed

7 files changed

+19
-17
lines changed

gradle/build-libs.versions.toml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
[versions]
22
asciidoc-gradle = "3.3.2"
3-
commons-codec = "1.16.0"
4-
commons-compress = "1.25.0"
3+
commons-codec = "1.18.0"
4+
commons-compress = "1.26.2"
55
groovy = "2.5.17"
66
jackson = "2.19.1"
7-
javaformat = "0.0.41"
7+
javaformat = "0.0.47"
88
jfrog = "4.31.9"
99
maven = "3.6.3"
1010
nexus-publish = "1.3.0"

spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/listener/ReactivePulsarMessageHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
*
2222
* @author Christophe Bornet
2323
*/
24-
public sealed interface ReactivePulsarMessageHandler permits ReactivePulsarOneByOneMessageHandler, ReactivePulsarStreamingHandler {
24+
public sealed interface ReactivePulsarMessageHandler
25+
permits ReactivePulsarOneByOneMessageHandler, ReactivePulsarStreamingHandler {
2526

2627
}

spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/listener/ReactivePulsarMessageListenerContainer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@
2626
* @param <T> message type.
2727
* @author Christophe Bornet
2828
*/
29-
public sealed interface ReactivePulsarMessageListenerContainer<T>
30-
extends MessageListenerContainer permits DefaultReactivePulsarMessageListenerContainer {
29+
public sealed interface ReactivePulsarMessageListenerContainer<T> extends MessageListenerContainer
30+
permits DefaultReactivePulsarMessageListenerContainer {
3131

3232
void setupMessageHandler(ReactivePulsarMessageHandler messageListener);
3333

spring-pulsar/src/main/java/org/springframework/pulsar/listener/PulsarMessageListenerContainer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,8 @@
2727
*
2828
* @author Soby Chacko
2929
*/
30-
public sealed interface PulsarMessageListenerContainer
31-
extends MessageListenerContainer permits AbstractPulsarMessageListenerContainer {
30+
public sealed interface PulsarMessageListenerContainer extends MessageListenerContainer
31+
permits AbstractPulsarMessageListenerContainer {
3232

3333
void setupMessageListener(Object messageListener);
3434

spring-pulsar/src/main/java/org/springframework/pulsar/reader/PulsarMessageReaderContainer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,8 @@
2626
*
2727
* @author Soby Chacko
2828
*/
29-
public sealed interface PulsarMessageReaderContainer
30-
extends SmartLifecycle, DisposableBean permits AbstractPulsarMessageReaderContainer {
29+
public sealed interface PulsarMessageReaderContainer extends SmartLifecycle, DisposableBean
30+
permits AbstractPulsarMessageReaderContainer {
3131

3232
void setupReaderListener(Object messageListener);
3333

spring-pulsar/src/test/java/org/springframework/pulsar/function/PulsarFunctionAdministrationTests.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -229,8 +229,8 @@ void provideFunctionsToBeanFactory() {
229229
void createAdminClientFails() throws PulsarClientException {
230230
when(springPulsarAdmin.createAdminClient()).thenThrow(new PulsarClientException("NOPE"));
231231
assertThatThrownBy(() -> functionAdmin.createOrUpdateUserDefinedFunctions())
232-
.isInstanceOf(PulsarException.class)
233-
.hasMessageContaining("Unable to create/update functions - could not create PulsarAdmin: NOPE");
232+
.isInstanceOf(PulsarException.class)
233+
.hasMessageContaining("Unable to create/update functions - could not create PulsarAdmin: NOPE");
234234
}
235235

236236
@Nested
@@ -472,8 +472,9 @@ void setStopPolicyOnFunctionsAndAddToProcessedList() {
472472
void createAdminClientFails() throws PulsarClientException {
473473
when(springPulsarAdmin.createAdminClient()).thenThrow(new PulsarClientException("NOPE"));
474474
assertThatThrownBy(() -> functionAdmin.enforceStopPolicyOnUserDefinedFunctions())
475-
.isInstanceOf(PulsarException.class).hasMessageContaining(
476-
"Unable to enforce stop policy on functions - could not create PulsarAdmin: NOPE");
475+
.isInstanceOf(PulsarException.class)
476+
.hasMessageContaining(
477+
"Unable to enforce stop policy on functions - could not create PulsarAdmin: NOPE");
477478
}
478479

479480
@Test

spring-pulsar/src/test/java/org/springframework/pulsar/function/PulsarFunctionsTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ void getIfExistsWithExistingFunction() throws PulsarAdminException {
103103
@Test
104104
void getIfExistsWithNonExistentFunction() throws PulsarAdminException {
105105
when(pulsarAdmin.functions().getFunction(anyString(), anyString(), anyString()))
106-
.thenThrow(new NotFoundException(null, "400", 400));
106+
.thenThrow(new NotFoundException(null, "400", 400));
107107
assertThat(function.getIfExists(pulsarAdmin)).isEmpty();
108108
assertThat(function.functionExists(pulsarAdmin)).isFalse();
109109
}
@@ -217,7 +217,7 @@ void getIfExistsWithExistingSink() throws PulsarAdminException {
217217
@Test
218218
void getIfExistsWithNonExistentSink() throws PulsarAdminException {
219219
when(pulsarAdmin.sinks().getSink(anyString(), anyString(), anyString()))
220-
.thenThrow(new NotFoundException(null, "400", 400));
220+
.thenThrow(new NotFoundException(null, "400", 400));
221221
assertThat(sink.getIfExists(pulsarAdmin)).isEmpty();
222222
assertThat(sink.functionExists(pulsarAdmin)).isFalse();
223223
}
@@ -331,7 +331,7 @@ void getIfExistsWithExistingSource() throws PulsarAdminException {
331331
@Test
332332
void getIfExistsWithNonExistentSource() throws PulsarAdminException {
333333
when(pulsarAdmin.sources().getSource(anyString(), anyString(), anyString()))
334-
.thenThrow(new NotFoundException(null, "400", 400));
334+
.thenThrow(new NotFoundException(null, "400", 400));
335335
assertThat(source.getIfExists(pulsarAdmin)).isEmpty();
336336
assertThat(source.functionExists(pulsarAdmin)).isFalse();
337337
}

0 commit comments

Comments
 (0)