Skip to content

Commit

Permalink
Adapt to latest changes
Browse files Browse the repository at this point in the history
  • Loading branch information
vietj committed Sep 18, 2023
1 parent 983c149 commit 7681aac
Showing 1 changed file with 0 additions and 93 deletions.
93 changes: 0 additions & 93 deletions src/main/java/io/vertx/ext/consul/ConsulClientOptions.java
Original file line number Diff line number Diff line change
Expand Up @@ -519,17 +519,6 @@ public ConsulClientOptions setConnectTimeout(int connectTimeout) {
return (ConsulClientOptions) super.setConnectTimeout(connectTimeout);
}

/**
* Set the maximum pool size for connections
*
* @param maxPoolSize the maximum pool size
* @return a reference to this, so the API can be used fluently
*/
@Override
public ConsulClientOptions setMaxPoolSize(int maxPoolSize) {
return (ConsulClientOptions) super.setMaxPoolSize(maxPoolSize);
}

/**
* Set a client limit of the number concurrent streams for each HTTP/2 connection, this limits the number
* of streams the client can create for a connection. The effective number of streams for a
Expand All @@ -546,17 +535,6 @@ public ConsulClientOptions setHttp2MultiplexingLimit(int limit) {
return (ConsulClientOptions) super.setHttp2MultiplexingLimit(limit);
}

/**
* Set the maximum pool size for HTTP/2 connections
*
* @param max the maximum pool size
* @return a reference to this, so the API can be used fluently
*/
@Override
public ConsulClientOptions setHttp2MaxPoolSize(int max) {
return (ConsulClientOptions) super.setHttp2MaxPoolSize(max);
}

/**
* Set the default HTTP/2 connection window size. It overrides the initial window
* size set by {@link Http2Settings#getInitialWindowSize}, so the connection window size
Expand Down Expand Up @@ -627,30 +605,6 @@ public ConsulClientOptions setTryUseCompression(boolean tryUseCompression) {
return (ConsulClientOptions) super.setTryUseCompression(tryUseCompression);
}

/**
* Set true when the client wants to skip frame masking.
* You may want to set it true on server by server websocket communication: In this case you are by passing RFC6455 protocol.
* It's false as default.
*
* @param sendUnmaskedFrames true if enabled
* @return a reference to this, so the API can be used fluently
*/
@Override
public ConsulClientOptions setSendUnmaskedFrames(boolean sendUnmaskedFrames) {
return (ConsulClientOptions) super.setSendUnmaskedFrames(sendUnmaskedFrames);
}

/**
* Set the max websocket frame size
*
* @param maxWebsocketFrameSize the max frame size, in bytes
* @return a reference to this, so the API can be used fluently
*/
@Override
public ConsulClientOptions setMaxWebSocketFrameSize(int maxWebsocketFrameSize) {
return (ConsulClientOptions) super.setMaxWebSocketFrameSize(maxWebsocketFrameSize);
}

/**
* Set the default host name to be used by this client in requests if none is provided when making the request.
*
Expand Down Expand Up @@ -714,17 +668,6 @@ public ConsulClientOptions setMaxHeaderSize(int maxHeaderSize) {
return (ConsulClientOptions) super.setMaxHeaderSize(maxHeaderSize);
}

/**
* Set the maximum requests allowed in the wait queue, any requests beyond the max size will result in
* a ConnectionPoolTooBusyException. If the value is set to a negative number then the queue will be unbounded.
* @param maxWaitQueueSize the maximum number of waiting requests
* @return a reference to this, so the API can be used fluently
*/
@Override
public ConsulClientOptions setMaxWaitQueueSize(int maxWaitQueueSize) {
return (ConsulClientOptions) super.setMaxWaitQueueSize(maxWaitQueueSize);
}

/**
* Set the HTTP/2 connection settings immediately sent by to the server when the client connects.
*
Expand Down Expand Up @@ -886,17 +829,6 @@ public ConsulClientOptions setFollowRedirects(boolean followRedirects) {
return (ConsulClientOptions) super.setFollowRedirects(followRedirects);
}

/**
* Set the max websocket message size
*
* @param maxWebsocketMessageSize the max message size, in bytes
* @return a reference to this, so the API can be used fluently
*/
@Override
public ConsulClientOptions setMaxWebSocketMessageSize(int maxWebsocketMessageSize) {
return (ConsulClientOptions) super.setMaxWebSocketMessageSize(maxWebsocketMessageSize);
}

/**
* Add an enabled cipher suite, appended to the ordered suites.
*
Expand Down Expand Up @@ -979,11 +911,6 @@ public ConsulClientOptions setKeepAliveTimeout(int keepAliveTimeout) {
return (ConsulClientOptions) super.setKeepAliveTimeout(keepAliveTimeout);
}

@Override
public ConsulClientOptions setPoolCleanerPeriod(int poolCleanerPeriod) {
return (ConsulClientOptions) super.setPoolCleanerPeriod(poolCleanerPeriod);
}

@Override
public ConsulClientOptions setEnabledSecureTransportProtocols(Set<String> enabledSecureTransportProtocols) {
return (ConsulClientOptions) super.setEnabledSecureTransportProtocols(enabledSecureTransportProtocols);
Expand All @@ -998,24 +925,4 @@ public ConsulClientOptions setSslHandshakeTimeout(long sslHandshakeTimeout) {
public ConsulClientOptions setSslHandshakeTimeoutUnit(TimeUnit sslHandshakeTimeoutUnit) {
return (ConsulClientOptions) super.setSslHandshakeTimeoutUnit(sslHandshakeTimeoutUnit);
}

@Override
public ConsulClientOptions setTryUsePerMessageWebSocketCompression(boolean offer) {
return (ConsulClientOptions) super.setTryUsePerMessageWebSocketCompression(offer);
}

@Override
public ConsulClientOptions setWebSocketCompressionLevel(int compressionLevel) {
return (ConsulClientOptions) super.setWebSocketCompressionLevel(compressionLevel);
}

@Override
public ConsulClientOptions setWebSocketCompressionAllowClientNoContext(boolean offer) {
return (ConsulClientOptions) super.setWebSocketCompressionAllowClientNoContext(offer);
}

@Override
public ConsulClientOptions setWebSocketCompressionRequestServerNoContext(boolean offer) {
return (ConsulClientOptions) super.setWebSocketCompressionRequestServerNoContext(offer);
}
}

0 comments on commit 7681aac

Please sign in to comment.