Example cordapp works on a corda cluster. Added getter methods for Data transfer objects, added default constructors.

build.gradle

@@ -45,6 +45,7 @@ cordapp {
     }
 }
 
+/*
 // Declare the set of Kotlin compiler options we need to build a CorDapp.
 tasks.withType(org.jetbrains.kotlin.gradle.tasks.KotlinCompile).configureEach {
     kotlinOptions {
@@ -72,6 +73,19 @@ tasks.withType(org.jetbrains.kotlin.gradle.tasks.KotlinCompile).configureEach {
     }
 }
 
+ */
+
+// Declare the set of Kotlin compiler options we need to build a CorDapp.
+tasks.withType(JavaCompile) {
+
+    // -parameters - Needed for reflection and serialization to work correctly.
+    options.compilerArgs += [
+            "-parameters"
+    ]
+}
+
+
+
 repositories {
     // All dependencies are held in Maven Central
     mavenCentral()
@@ -134,7 +148,7 @@ test {
 publishing {
     publications {
             maven(MavenPublication) {
-                artifactId "corda-CSDE-kotlin-sample"
+                artifactId "corda-CSDE-java-sample"
                 groupId project.group
                 artifact jar
             }

buildSrc/src/main/groovy/csde.gradle

@@ -2,7 +2,6 @@ import com.r3.csde.CsdeRpcInterface
 
 plugins {
     id 'java-library'
-    id 'checkstyle'
     id 'groovy'
     id 'java'
 }
@@ -37,7 +36,7 @@ def cordaJDBCDir = cordaBinDir + "/jdbcDrivers"
 def signingCertAlias="gradle-plugin-default-key"
 // Get error if this is not a autotyped object
 // def signingCertFName = "$rootDir/config/gradle-plugin-default-key.pem"
-def signingCertFName = rootDir.toString() + "/csde-config/gradle-plugin-default-key.pem"
+def signingCertFName = rootDir.toString() + "/config/gradle-plugin-default-key.pem"
 def keystoreAlias = "my-signing-key"
 def keystoreFName = devEnvWorkspace + "/signingkeys.pfx"
 def keystoreCertFName = devEnvWorkspace + "/signingkey1.pem"
@@ -82,7 +81,7 @@ tasks.register("createGroupPolicy") {
     doLast {
 
             def groupPolicyFName = new String("${devEnvWorkspace}/GroupPolicy.json")
-            def devnetFName = new String("$rootDir/csde-config/dev-net.json")
+            def devnetFName = new String("$rootDir/config/dev-net.json")
             File groupPolicyFile = new File(groupPolicyFName)
             File devnetFile = new File(devnetFName)
             if (!groupPolicyFile.exists() || groupPolicyFile.lastModified() < devnetFile.lastModified()) {
@@ -128,7 +127,7 @@ tasks.register('createKeystore') {
         if(!keystoreFile.exists()) {
             println('createKeystore: Create a keystore')
             exec {
-                commandLine "keytool", "-genkeypair",
+                commandLine "${System.getProperty("java.home")}/bin/keytool", "-genkeypair",
                         "-alias", keystoreAlias,
                         "-keystore", keystoreFName,
                         "-storepass", "keystore password",
@@ -139,7 +138,7 @@ tasks.register('createKeystore') {
             }
             // Need to add the default signing key to the keystore
             exec {
-                commandLine "keytool", "-importcert",
+                commandLine "${System.getProperty("java.home")}/bin/keytool", "-importcert",
                         "-keystore", keystoreFName,
                         "-storepass", "keystore password",
                         "-noprompt",
@@ -148,7 +147,7 @@ tasks.register('createKeystore') {
             }
             // keytool -exportcert -rfc -alias "signing key 1" -keystore signingkeys.pfx -storepass "keystore password" -file signingkey1.pem
             exec {
-                commandLine "keytool",
+                commandLine "${System.getProperty("java.home")}/bin/keytool",
                         "-exportcert", "-rfc", "-alias", keystoreAlias,
                         "-keystore", keystoreFName,
                         "-storepass", "keystore password",

src/main/java/com/r3/developers/csdetemplate/Message.java

@@ -7,10 +7,19 @@ import net.corda.v5.base.types.MemberX500Name;
 //// to be able to send from one virtual node to another.
 @CordaSerializable
 public class Message {
-    Message(MemberX500Name _sender, String _message) {
+    // public Message() {}
-        sender = _sender;
+    public Message(MemberX500Name sender, String message) {
-        message = _message;
+        this.sender = sender;
+        this.message = message;
     }
+    public MemberX500Name getSender() {
+        return sender;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
     public MemberX500Name sender;
     public String message;
 }

src/main/java/com/r3/developers/csdetemplate/MyFirstFlow.java

@@ -16,7 +16,7 @@ import org.slf4j.LoggerFactory;
 // to link the two sides of the flow together they need to have the same protocol.
 @InitiatingFlow(protocol = "another-flow")
 // MyFirstFlow should inherit from RPCStartableFlow, which tells Corda it can be started via an RPC call
-class MyFirstFlow implements RPCStartableFlow {
+public class MyFirstFlow implements RPCStartableFlow {
 
     // It is useful to be able to log messages from the flows for debugging.
     private final Logger log = LoggerFactory.getLogger(MyFirstFlow.class);
@@ -43,6 +43,7 @@ class MyFirstFlow implements RPCStartableFlow {
     // When a flow is invoked it's call() method is called.
     // call() methods must be marked as @Suspendable, this allows Corda to pause mid-execution to wait
     // for a response from the other flows and services
+    @NotNull
     @Suspendable
     @Override
     public String call(@NotNull RPCRequestData requestBody) {
@@ -57,7 +58,7 @@ class MyFirstFlow implements RPCStartableFlow {
         MyFirstFlowStartArgs flowArgs = requestBody.getRequestBodyAs(jsonMarshallingService, MyFirstFlowStartArgs.class);
 
         // Obtain the MemberX500Name of counterparty
-        MemberX500Name otherMember = flowArgs.othermember;
+        MemberX500Name otherMember = flowArgs.otherMember;
 
         // Get our identity from the MemberLookup service.
         MemberX500Name ourIdentity = memberLookup.myInfo().getName();

src/main/java/com/r3/developers/csdetemplate/MyFirstFlowResponder.java

@@ -15,7 +15,7 @@ import org.slf4j.LoggerFactory;
 // to link the two sides of the flow together they need to have the same protocol.
 @InitiatedBy(protocol = "another-flow")
 // Responder flows must inherit from ResponderFlow
-class MyFirstFlowResponder implements ResponderFlow {
+public class MyFirstFlowResponder implements ResponderFlow {
 
     // It is useful to be able to log messages from the flows for debugging.
     private final Logger log = LoggerFactory.getLogger(MyFirstFlowResponder.class);

src/main/java/com/r3/developers/csdetemplate/MyFirstFlowStartArgs.java

@@ -5,9 +5,17 @@ import net.corda.v5.base.types.MemberX500Name;
 // // A class to hold the arguments required to start the flow
 //class MyFirstFlowStartArgs(val otherMember: MemberX500Name)
 public class MyFirstFlowStartArgs {
-    public MemberX500Name othermember;
+    public MemberX500Name otherMember;
 
-    public MyFirstFlowStartArgs(MemberX500Name othermember) {
+    public MemberX500Name getOtherMember() {
-        this.othermember = othermember;
+        return otherMember;
     }
+
+    public MyFirstFlowStartArgs(MemberX500Name otherMember) {
+        this.otherMember = otherMember;
+    }
+
+    // Without the following we get
+    // "Cannot construct instance of `com.r3.developers.csdetemplate.MyFirstFlowStartArgs` (no Creators, like default constructor, exist): cannot deserialize from Object value (no delegate- or property-based Creator)\n at [Source: (String)\"{\"otherMember\":\"CN=Bob, OU=Test Dept, O=R3, L=London, C=GB\"}\"; line: 1, column: 2]"
+    public MyFirstFlowStartArgs() {}
 }

src/test/java/com/r3/developers/csdetemplate/MyFirstFlowTest.java

@@ -1,5 +1,6 @@
 package com.r3.developers.csdetemplate;
 
+
 import net.corda.simulator.HoldingIdentity;
 import net.corda.simulator.RequestData;
 import net.corda.simulator.SimulatedVirtualNode;
@@ -7,6 +8,7 @@ import net.corda.simulator.Simulator;
 import net.corda.v5.base.types.MemberX500Name;
 import org.junit.jupiter.api.Test;
 
+
 class MyFirstFlowTest {
 
     // Names picked to match the corda network in config/dev-net.json
@@ -45,3 +47,4 @@ class MyFirstFlowTest {
         assert(flowResponse.equals("Hello Alice, best wishes from Bob"));
     }
 }
+