fix(distro-vertx) Fix typo in ICacheStoreComponent.
MODIFY
distro/vertx/src/main/resources/overlay/configs/conf-es.json
distro/vertx/src/main/resources/overlay/configs/conf-es.json
"ICacheStoreComponent": {
"class": "io.apiman.gateway.engine.es.ESCacheStoreComponent",
"config": {
+ "client": {
"type": "jest",
"protocol": "${apiman.es.protocol}",
"host": "${apiman.es.host}",
"password": "${apiman.es.password}",
"timeout": "${apiman.es.timeout}"
}
+ }
},
// Execute Blocking Component

MODIFY
gateway/engine/core/src/main/java/io/apiman/gateway/engine/io/ISignalWriteStream.java
gateway/engine/core/src/main/java/io/apiman/gateway/engine/io/ISignalWriteStream.java
@@ -25,7 +25,6 @@ import io.apiman.gateway.engine.async.IAsyncHandler;
public interface ISignalWriteStream extends IWriteStream, IAbortable {
default void drainHandler(IAsyncHandler<Void> drainHandler) {
- throw new UnsupportedOperationException("Drain handler has not been implemented."); //$NON-NLS-1$
}
default boolean isFull() {

MODIFY
gateway/platforms/vertx3/vertx3/src/main/java/io/apiman/gateway/platforms/vertx3/common/config/VertxEngineConfig.java
gateway/platforms/vertx3/vertx3/src/main/java/io/apiman/gateway/platforms/vertx3/common/config/VertxEngineConfig.java
@@ -398,12 +398,6 @@ public class VertxEngineConfig implements IEngineConfig {
return config.getJsonObject(VERTICLES).getJsonObject(verticleType.toLowerCase());
}
- private JsonObject getVariables() {
- return config.getJsonObject(VARIABLES, new JsonObject());
- }
-
-
-
/**
* Gets all properties in the engine configuration that are prefixed
* with the given prefix.
@@ -446,6 +440,10 @@ public class VertxEngineConfig implements IEngineConfig {
return super.lookup(key);
}
}
+
+ private JsonObject getVariables() {
+ return config.getJsonObject(VARIABLES, new JsonObject());
+ }
}
}

fix(distro-vertx) Fix typo in ICacheStoreComponent.