diff --git a/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectIoTDAServerExample.java b/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectIoTDAServerExample.java new file mode 100644 index 0000000..77a8c63 --- /dev/null +++ b/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectIoTDAServerExample.java @@ -0,0 +1,22 @@ +package io.github.protocol.mtconnect.examples; + +import io.github.openfacade.http.HttpServerConfig; +import io.github.openfacade.http.HttpServerEngine; +import io.github.protocol.mtconnect.server.MtConnectServer; +import io.github.protocol.mtconnect.server.MtConnectServerConfiguration; +import io.github.protocol.mtconnect.server.impl.IoTDAMtProcessor; + +public class MtConnectIoTDAServerExample { + public static void main(String[] args) { + MtConnectServerConfiguration configuration = new MtConnectServerConfiguration(); + HttpServerConfig httpServerConfig = new HttpServerConfig.Builder() + .engine(HttpServerEngine.Vertx) + .host("127.0.0.1") + .port(36633) + .build(); + configuration.setHttpConfig(httpServerConfig); + configuration.setMtProcessor(new IoTDAMtProcessor("your_ak", "your_sk")); + MtConnectServer mtConnectServer = new MtConnectServer(configuration); + mtConnectServer.start().join(); + } +} diff --git a/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectServerExample.java b/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectMemoryServerExample.java similarity index 95% rename from mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectServerExample.java rename to mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectMemoryServerExample.java index e31dc67..4360075 100644 --- a/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectServerExample.java +++ b/mtconnect-examples/src/main/java/io/github/protocol/mtconnect/examples/MtConnectMemoryServerExample.java @@ -6,7 +6,7 @@ import io.github.protocol.mtconnect.server.MtConnectServerConfiguration; import io.github.protocol.mtconnect.server.impl.MemoryMtProcessor; -public class MtConnectServerExample { +public class MtConnectMemoryServerExample { public static void main(String[] args) { MtConnectServerConfiguration configuration = new MtConnectServerConfiguration(); HttpServerConfig httpServerConfig = new HttpServerConfig.Builder() diff --git a/mtconnect-server/pom.xml b/mtconnect-server/pom.xml index 8409247..8d992e6 100644 --- a/mtconnect-server/pom.xml +++ b/mtconnect-server/pom.xml @@ -17,6 +17,11 @@ mtconnect-common ${project.version} + + com.huaweicloud.sdk + huaweicloud-sdk-iotda + ${huaweicloud-sdk.version} + io.github.openfacade http-facade diff --git a/mtconnect-server/src/main/java/io/github/protocol/mtconnect/server/impl/IoTDAMtProcessor.java b/mtconnect-server/src/main/java/io/github/protocol/mtconnect/server/impl/IoTDAMtProcessor.java new file mode 100644 index 0000000..8a9cba1 --- /dev/null +++ b/mtconnect-server/src/main/java/io/github/protocol/mtconnect/server/impl/IoTDAMtProcessor.java @@ -0,0 +1,21 @@ +package io.github.protocol.mtconnect.server.impl; + +import io.github.protocol.mtconnect.api.AssetRequest; +import io.github.protocol.mtconnect.api.AssetResponse; +import io.github.protocol.mtconnect.server.MtProcessor; + +public class IoTDAMtProcessor implements MtProcessor { + private final String ak; + + private final String sk; + + public IoTDAMtProcessor(String ak, String sk) { + this.ak = ak; + this.sk = sk; + } + + @Override + public AssetResponse asset(AssetRequest assetRequest) { + return null; + } +} diff --git a/pom.xml b/pom.xml index ab5cc5f..318af74 100644 --- a/pom.xml +++ b/pom.xml @@ -24,6 +24,7 @@ src/main/java 0.2.0 + 3.1.117 2.17.2 5.11.0 2.20.0