Skip to content

Commit d568d72

Browse files
committed
Remove deprecated Netty-related settings
Fixes #376
1 parent e7ae0d2 commit d568d72

File tree

3 files changed

+0
-93
lines changed

3 files changed

+0
-93
lines changed

src/main/java/com/rabbitmq/stream/ChannelCustomizer.java

-39
This file was deleted.

src/main/java/com/rabbitmq/stream/EnvironmentBuilder.java

-33
Original file line numberDiff line numberDiff line change
@@ -187,39 +187,6 @@ public interface EnvironmentBuilder {
187187
*/
188188
EnvironmentBuilder requestedMaxFrameSize(int requestedMaxFrameSize);
189189

190-
/**
191-
* The Netty {@link EventLoopGroup} instance to use.
192-
*
193-
* <p>The environment uses its own instance by default. It is the developer's responsibility to
194-
* close the {@link EventLoopGroup} they provide.
195-
*
196-
* @param eventLoopGroup
197-
* @return this builder instance
198-
* @deprecated use {@link NettyConfiguration#eventLoopGroup(EventLoopGroup)} from {@link #netty()}
199-
* instead
200-
*/
201-
EnvironmentBuilder eventLoopGroup(EventLoopGroup eventLoopGroup);
202-
203-
/**
204-
* Netty's {@link io.netty.buffer.ByteBuf} allocator.
205-
*
206-
* @param byteBufAllocator
207-
* @return this builder instance
208-
* @deprecated use {@link NettyConfiguration#byteBufAllocator(ByteBufAllocator)} from {@link
209-
* #netty()} instead
210-
*/
211-
EnvironmentBuilder byteBufAllocator(ByteBufAllocator byteBufAllocator);
212-
213-
/**
214-
* An extension point to customize Netty's {@link io.netty.channel.Channel}s used for connection.
215-
*
216-
* @param channelCustomizer
217-
* @return this builder instance
218-
* @deprecated use {@link NettyConfiguration#channelCustomizer(Consumer)} from {@link #netty()}
219-
* instead
220-
*/
221-
EnvironmentBuilder channelCustomizer(ChannelCustomizer channelCustomizer);
222-
223190
/**
224191
* The checksum strategy used for chunk checksum.
225192
*

src/main/java/com/rabbitmq/stream/impl/StreamEnvironmentBuilder.java

-21
Original file line numberDiff line numberDiff line change
@@ -134,26 +134,12 @@ public EnvironmentBuilder compressionCodecFactory(
134134
return this;
135135
}
136136

137-
@SuppressWarnings("deprecation")
138-
@Override
139-
public EnvironmentBuilder eventLoopGroup(EventLoopGroup eventLoopGroup) {
140-
this.netty().eventLoopGroup(eventLoopGroup);
141-
return this;
142-
}
143-
144137
@Override
145138
public EnvironmentBuilder id(String id) {
146139
this.id = id;
147140
return this;
148141
}
149142

150-
@SuppressWarnings("deprecation")
151-
@Override
152-
public EnvironmentBuilder byteBufAllocator(ByteBufAllocator byteBufAllocator) {
153-
this.netty().byteBufAllocator(byteBufAllocator);
154-
return this;
155-
}
156-
157143
@Override
158144
public EnvironmentBuilder rpcTimeout(Duration timeout) {
159145
this.clientParameters.rpcTimeout(timeout);
@@ -195,13 +181,6 @@ public StreamEnvironmentBuilder requestedMaxFrameSize(int requestedMaxFrameSize)
195181
return this;
196182
}
197183

198-
@SuppressWarnings("deprecation")
199-
public StreamEnvironmentBuilder channelCustomizer(
200-
com.rabbitmq.stream.ChannelCustomizer channelCustomizer) {
201-
this.netty().channelCustomizer(ch -> channelCustomizer.customize(ch));
202-
return this;
203-
}
204-
205184
public StreamEnvironmentBuilder chunkChecksum(ChunkChecksum chunkChecksum) {
206185
this.clientParameters.chunkChecksum(chunkChecksum);
207186
return this;

0 commit comments

Comments
 (0)