Update queues example

tmiddlet2666 · May 17, 2024 · ccc9ec5 · ccc9ec5
1 parent 253893a
commit ccc9ec5
Show file tree

Hide file tree

Showing 48 changed files with 409 additions and 24 deletions.
diff --git a/go/go-queues/common/common.go b/go/go-queues/common/common.go
diff --git a/go/go-queues/README.md → go/queues/README.md b/go/go-queues/README.md → go/queues/README.md
@@ -7,8 +7,9 @@ access Coherence Queues from  Go.
 
 1. Docker setup using either Docker or Rancher Desktop
 2. Go 1.20 or above 
+3. Java 17+ and Maven 3.8.5+
 
-## Run the Demo
+## Run the Demo using Just Go
 
 ### Start a Coherence cluster
 
@@ -32,3 +33,24 @@ For example to start a order 1 and publish 100 orders use the following:
 ```bash
 go run publisher/main.go 1 100
 ```
+
+## Run the example using Java and Go
+
+### Build the Docker image 
+
+Because we want to read the data from Java, we need to build a customer docker image.
+
+Explain here::
+
+                            
+```bash
+mvn compile jib:dockerBuild
+```
+
+This will build the imaged `queues-demo-24.03`
+
+### Run the docker image
+             
+```bash
+docker run -p 30000:30000 -p 8888:8888 -p 1408:1408 queues-demo-24.03
+```
diff --git a/go/queues/common/common.go b/go/queues/common/common.go
@@ -0,0 +1,13 @@
+package common
+
+const QueueName = "orders-queue"
+
+// Order represents a fictitious order.
+type Order struct {
+	OrderNumber  int     `json:"orderNumber"`
+	Customer     string  `json:"customer"`
+	OrderStatus  string  `json:"orderStatus"`
+	OrderTotal   float32 `json:"orderTotal"`
+	CreateTime   int64   `json:"createTime"`
+	CompleteTime int64   `json:"completeTime"`
+}
diff --git a/go/go-queues/go.mod → go/queues/go.mod b/go/go-queues/go.mod → go/queues/go.mod
@@ -2,7 +2,7 @@ module queue-demo
 
 go 1.20
 
-require github.com/oracle/coherence-go-client v1.2.0
+require github.com/oracle/coherence-go-client v1.2.1
 
 require (
 	github.com/golang/protobuf v1.5.3 // indirect

diff --git a/go/go-queues/go.sum → go/queues/go.sum b/go/go-queues/go.sum → go/queues/go.sum
@@ -6,8 +6,8 @@ github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
 github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
 github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE=
-github.com/oracle/coherence-go-client v1.2.0 h1:Ov+qk99Qg+Opyl+XYlPPROK1NDz9FbBG+SLPnO/7+6g=
-github.com/oracle/coherence-go-client v1.2.0/go.mod h1:8wy6v4KvDGJv6iIiCD95aU0g8UL34DaKRHs3zqQN/Bg=
+github.com/oracle/coherence-go-client v1.2.1 h1:uDMiq5JkI03zWh7sK4SapXopmedbAAHn+mlGSt5WCyY=
+github.com/oracle/coherence-go-client v1.2.1/go.mod h1:8wy6v4KvDGJv6iIiCD95aU0g8UL34DaKRHs3zqQN/Bg=
 golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=
 golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
 golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=

diff --git a/go/queues/java/pom.xml b/go/queues/java/pom.xml
@@ -0,0 +1,86 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <groupId>com.oracle.coherence.demo</groupId>
+  <artifactId>queues-demo</artifactId>
+  <packaging>jar</packaging>
+  <version>1.0.0</version>
+
+  <description>Oracle Coherence Queues Demo</description>
+  <name>queues-demo</name>
+
+  <properties>
+    <revision>1.0.0</revision>
+    <operator.version>${project.version}</operator.version>
+
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
+
+    <coherence.group.id>com.oracle.coherence.ce</coherence.group.id>
+    <coherence.version>24.03</coherence.version>
+
+    <coherence.test.base.image>gcr.io/distroless/java17</coherence.test.base.image>
+
+    <!-- library dependency versions -->
+    <version.plugin.jib>3.4.2</version.plugin.jib>
+    <version.plugin.maven.assembly>3.3.0</version.plugin.maven.assembly>
+    <version.plugin.maven.compiler>3.7.0</version.plugin.maven.compiler>
+
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>${coherence.group.id}</groupId>
+      <artifactId>coherence</artifactId>
+      <version>${coherence.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>${coherence.group.id}</groupId>
+      <artifactId>coherence-json</artifactId>
+      <version>${coherence.version}</version>
+    </dependency>
+    <dependency>
+      <groupId>${coherence.group.id}</groupId>
+      <artifactId>coherence-grpc-proxy</artifactId>
+      <version>${coherence.version}</version>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>com.google.cloud.tools</groupId>
+        <artifactId>jib-maven-plugin</artifactId>
+        <version>${version.plugin.jib}</version>
+        <configuration>
+          <from>
+            <image>${coherence.test.base.image}</image>
+          </from>
+          <to>
+            <image>${project.artifactId}-${coherence.version}</image>
+          </to>
+          <container>
+            <jvmFlags>
+              <jvmFlag>-Xmx1g</jvmFlag>
+              <jvmFlag>-Xms1g</jvmFlag>
+              <jvmFlag>-Dcoherence.grpc.server.port=1408</jvmFlag>
+              <jvmFlag>-Dcoherence.wka=127.0.0.1</jvmFlag>
+              <jvmFlag>-Dcoherence.localhost=127.0.0.1</jvmFlag>
+              <jvmFlag>-Dcoherence.ttl=0</jvmFlag>
+              <jvmFlag>-Djava.net.preferIPv4Stack=true</jvmFlag>
+              <jvmFlag>-Dcoherence.management=all</jvmFlag>
+              <jvmFlag>-Dcoherence.management.http=all</jvmFlag>
+            </jvmFlags>
+            <mainClass>com.oracle.coherence.demo.queues.RunCoherence</mainClass>
+            <format>OCI</format>
+          </container>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+</project>
diff --git a/go/queues/java/queues-demo.iml b/go/queues/java/queues-demo.iml
@@ -0,0 +1,59 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module org.jetbrains.idea.maven.project.MavenProjectsManager.isMavenModule="true" type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" LANGUAGE_LEVEL="JDK_17">
+    <output url="file://$MODULE_DIR$/target/classes" />
+    <output-test url="file://$MODULE_DIR$/target/test-classes" />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/resources" type="java-resource" />
+      <excludeFolder url="file://$MODULE_DIR$/target" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="library" name="Maven: com.oracle.coherence.ce:coherence:24.03" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.el:jakarta.el-api:5.0.1" level="project" />
+    <orderEntry type="library" name="Maven: com.oracle.coherence.ce:coherence-json:24.03" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.json.bind:jakarta.json.bind-api:3.0.0" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.json:jakarta.json-api:2.1.3" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.inject:jakarta.inject-api:2.0.1" level="project" />
+    <orderEntry type="library" name="Maven: com.oracle.coherence.ce:coherence-grpc-proxy:24.03" level="project" />
+    <orderEntry type="library" name="Maven: com.oracle.coherence.ce:coherence-grpc-proxy-common:24.03" level="project" />
+    <orderEntry type="library" name="Maven: com.oracle.coherence.ce:coherence-grpc:24.03" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-api:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-stub:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-protobuf:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: com.google.api.grpc:proto-google-common-protos:2.22.0" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-protobuf-lite:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: jakarta.annotation:jakarta.annotation-api:2.1.1" level="project" />
+    <orderEntry type="library" name="Maven: com.google.protobuf:protobuf-java:3.21.12" level="project" />
+    <orderEntry type="library" name="Maven: com.google.protobuf:protobuf-java-util:3.21.12" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-services:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-util:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: com.google.j2objc:j2objc-annotations:2.8" level="project" />
+    <orderEntry type="library" name="Maven: com.google.code.gson:gson:2.10.1" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-inprocess:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-codec-http2:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-common:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-buffer:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-transport:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-resolver:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-codec:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-handler:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-codec-http:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-handler-proxy:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-codec-socks:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.netty:netty-transport-native-unix-common:4.1.100.Final" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-netty:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: io.grpc:grpc-core:1.60.0" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: com.google.android:annotations:4.1.1.4" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: org.codehaus.mojo:animal-sniffer-annotations:1.23" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: io.grpc:grpc-context:1.60.0" level="project" />
+    <orderEntry type="library" name="Maven: com.google.guava:guava:32.0.1-android" level="project" />
+    <orderEntry type="library" name="Maven: com.google.guava:failureaccess:1.0.1" level="project" />
+    <orderEntry type="library" name="Maven: com.google.guava:listenablefuture:9999.0-empty-to-avoid-conflict-with-guava" level="project" />
+    <orderEntry type="library" name="Maven: com.google.code.findbugs:jsr305:3.0.2" level="project" />
+    <orderEntry type="library" name="Maven: org.checkerframework:checker-qual:3.33.0" level="project" />
+    <orderEntry type="library" name="Maven: com.google.errorprone:error_prone_annotations:2.20.0" level="project" />
+    <orderEntry type="library" scope="RUNTIME" name="Maven: io.perfmark:perfmark-api:0.26.0" level="project" />
+  </component>
+</module>
diff --git a/go/queues/java/src/main/java/com/oracle/coherence/demo/queues/Order.java b/go/queues/java/src/main/java/com/oracle/coherence/demo/queues/Order.java
@@ -0,0 +1,110 @@
+package com.oracle.coherence.demo.queues;
+
+import java.io.Serializable;
+import java.util.Objects;
+
+public class Order implements Serializable {
+    private int orderNumber;
+    private String customer;
+    private String orderStatus;
+    private float orderTotal;
+    private long createTime;
+    private long completeTime;
+
+    public Order() {}
+
+    public Order(int orderNumber, String customer, String orderStatus, float orderTotal, long createTime, long completeTime) {
+        this.orderNumber = orderNumber;
+        this.customer = customer;
+        this.orderStatus = orderStatus;
+        this.orderTotal = orderTotal;
+        this.createTime = createTime;
+        this.completeTime = completeTime;
+    }
+
+    public int getOrderNumber() {
+        return orderNumber;
+    }
+
+    public void setOrderNumber(int orderNumber) {
+        this.orderNumber = orderNumber;
+    }
+
+    public String getCustomer() {
+        return customer;
+    }
+
+    public void setCustomer(String customer) {
+        this.customer = customer;
+    }
+
+    public String getOrderStatus() {
+        return orderStatus;
+    }
+
+    public void setOrderStatus(String orderStatus) {
+        this.orderStatus = orderStatus;
+    }
+
+    public float getOrderTotal() {
+        return orderTotal;
+    }
+
+    public void setOrderTotal(float orderTotal) {
+        this.orderTotal = orderTotal;
+    }
+
+    public long getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(long createTime) {
+        this.createTime = createTime;
+    }
+
+    public long getCompleteTime() {
+        return completeTime;
+    }
+
+    public void setCompleteTime(long completeTime) {
+        this.completeTime = completeTime;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+
+        Order order = (Order) o;
+
+        if (orderNumber != order.orderNumber) return false;
+        if (Float.compare(order.orderTotal, orderTotal) != 0) return false;
+        if (createTime != order.createTime) return false;
+        if (completeTime != order.completeTime) return false;
+        if (!Objects.equals(customer, order.customer)) return false;
+        return Objects.equals(orderStatus, order.orderStatus);
+    }
+
+    @Override
+    public int hashCode() {
+        int result = orderNumber;
+        result = 31 * result + (customer != null ? customer.hashCode() : 0);
+        result = 31 * result + (orderStatus != null ? orderStatus.hashCode() : 0);
+        result = 31 * result + (orderTotal != +0.0f ? Float.floatToIntBits(orderTotal) : 0);
+        result = 31 * result + (int) (createTime ^ (createTime >>> 32));
+        result = 31 * result + (int) (completeTime ^ (completeTime >>> 32));
+        return result;
+    }
+
+    @Override
+    public String toString() {
+        return "Order{" +
+               "orderNumber=" + orderNumber +
+               ", customer='" + customer + '\'' +
+               ", orderStatus='" + orderStatus + '\'' +
+               ", orderTotal=" + orderTotal +
+               ", createTime=" + createTime +
+               ", completeTime=" + completeTime +
+               '}';
+    }
+}