diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketStrategies.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketStrategies.java index e41f77c078..1c2698bdaa 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketStrategies.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketStrategies.java @@ -204,7 +204,7 @@ final class DefaultRSocketStrategies implements RSocketStrategies { } @Override - public Builder metadataExtractors(Consumer consumer) { + public Builder metadataExtractorRegistry(Consumer consumer) { this.metadataExtractors.add(consumer); return this; } diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java index 74848846a8..bd3b81c428 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java @@ -223,7 +223,7 @@ public interface RSocketStrategies { * Apply the consumer to the {@link MetadataExtractorRegistry} in order * to register extra metadata entry extractors. */ - Builder metadataExtractors(Consumer extractorRegistry); + Builder metadataExtractorRegistry(Consumer consumer); /** * Build the {@code RSocketStrategies} instance. diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketStrategiesTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketStrategiesTests.java index 8a4f08103c..39032778ca 100644 --- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketStrategiesTests.java +++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketStrategiesTests.java @@ -110,7 +110,7 @@ class DefaultRSocketStrategiesTests { @SuppressWarnings("unchecked") void applyMetadataExtractors() { Consumer consumer = (Consumer) mock(Consumer.class); - RSocketStrategies strategies = RSocketStrategies.builder().metadataExtractors(consumer).build(); + RSocketStrategies strategies = RSocketStrategies.builder().metadataExtractorRegistry(consumer).build(); verify(consumer, times(1)).accept(any()); }