SpringBoot/HelloCorda
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #22 from corda/CORE-11842-comment-updates

Browse Source 
CORE-11842 comment updates
This commit is contained in:
Matt Bradbury 2023-03-21 10:57:17 +00:00 committed by GitHub
commit 30a18f8572
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
workflows/src/main/java/com/r3/developers/csdetemplate/flowexample/workflows/MyFirstFlow.java
View File

@ -11,10 +11,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
// MyFirstFlow is an initiating flow, it's corresponding responder flow is called MyFirstFlowResponder (defined below) // MyFirstFlow is an initiating flow, its corresponding responder flow is called MyFirstFlowResponder (defined below)
// to link the two sides of the flow together they need to have the same protocol. // to link the two sides of the flow together they need to have the same protocol.
@InitiatingFlow(protocol = "my-first-flow") @InitiatingFlow(protocol = "my-first-flow")
// MyFirstFlow should inherit from RPCStartableFlow, which tells Corda it can be started via an RPC call // MyFirstFlow should inherit from ClientStartableFlow, which tells Corda it can be started via an REST call
public class MyFirstFlow implements ClientStartableFlow { public class MyFirstFlow implements ClientStartableFlow {
// Log messages from the flows for debugging. // Log messages from the flows for debugging.
@ -78,19 +78,18 @@ public class MyFirstFlow implements ClientStartableFlow {
// Receive a response from the responder flow. // Receive a response from the responder flow.
Message response = session.receive(Message.class); Message response = session.receive(Message.class);
// The return value of a RPCStartableFlow must always be a String. This will be passed // The return value of a ClientStartableFlow must always be a String. This will be passed
// back as the REST RPC response when the status of the flow is queried on Corda, or as the return // back as the REST response when the status of the flow is queried on Corda.
// value from the flow when testing using the simulator.
return response.getMessage(); return response.getMessage();
} }
} }
/* /*
RequestBody for triggering the flow via http-rpc: RequestBody for triggering the flow via REST:
{ {
"clientRequestId": "r1", "clientRequestId": "r1",
"flowClassName": "com.r3.developers.csdetemplate.flowexample.workflows.MyFirstFlow", "flowClassName": "com.r3.developers.csdetemplate.flowexample.workflows.MyFirstFlow",
"requestData": { "requestBody": {
"otherMember":"CN=Bob, OU=Test Dept, O=R3, L=London, C=GB" "otherMember":"CN=Bob, OU=Test Dept, O=R3, L=London, C=GB"
} }
} }

4
workflows/src/main/java/com/r3/developers/csdetemplate/flowexample/workflows/MyFirstFlowResponder.java
View File

@ -29,9 +29,9 @@ public class MyFirstFlowResponder implements ResponderFlow {
// Responder flows are invoked when an initiating flow makes a call via a session set up with the virtual // Responder flows are invoked when an initiating flow makes a call via a session set up with the virtual
// node hosting the responder flow. When a responder flow is invoked its call() method is called. // node hosting the responder flow. When a responder flow is invoked its call() method is called.
// Call() methods must be marked as @Suspendable, this allows Corda to pause mid-execution to wait // 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. // for a response from the other flows and services.
// The Call method has the flow session passed in as a parameter by Corda so the session is available to // The call() method has the flow session passed in as a parameter by Corda so the session is available to
// responder flow code, you don't need to inject the FlowMessaging service. // responder flow code, you don't need to inject the FlowMessaging service.
@Suspendable @Suspendable
@Override @Override

2
workflows/src/main/java/com/r3/developers/csdetemplate/utxoexample/workflows/CreateNewChatFlow.java
View File

@ -120,7 +120,7 @@ public class CreateNewChatFlow implements ClientStartableFlow {
} }
/* /*
RequestBody for triggering the flow via http-rpc: RequestBody for triggering the flow via REST:
{ {
"clientRequestId": "create-1", "clientRequestId": "create-1",
"flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.CreateNewChatFlow", "flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.CreateNewChatFlow",

2
workflows/src/main/java/com/r3/developers/csdetemplate/utxoexample/workflows/GetChatFlow.java
View File

@ -106,7 +106,7 @@ public class GetChatFlow implements ClientStartableFlow {
} }
/* /*
RequestBody for triggering the flow via http-rpc: RequestBody for triggering the flow via REST:
{ {
"clientRequestId": "get-1", "clientRequestId": "get-1",
"flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.GetChatFlow", "flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.GetChatFlow",

2
workflows/src/main/java/com/r3/developers/csdetemplate/utxoexample/workflows/ListChatsFlow.java
View File

@ -49,7 +49,7 @@ public class ListChatsFlow implements ClientStartableFlow {
} }
/* /*
RequestBody for triggering the flow via http-rpc: RequestBody for triggering the flow via REST:
{ {
"clientRequestId": "list-1", "clientRequestId": "list-1",
"flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.ListChatsFlow", "flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.ListChatsFlow",

2
workflows/src/main/java/com/r3/developers/csdetemplate/utxoexample/workflows/UpdateChatFlow.java
View File

@ -108,7 +108,7 @@ public class UpdateChatFlow implements ClientStartableFlow {
} }
/* /*
RequestBody for triggering the flow via http-rpc: RequestBody for triggering the flow via REST:
{ {
"clientRequestId": "update-1", "clientRequestId": "update-1",
"flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.UpdateChatFlow", "flowClassName": "com.r3.developers.csdetemplate.utxoexample.workflows.UpdateChatFlow",