dapr
/
java-sdk
mirror of https://github.com/dapr/java-sdk.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix formatting javadoc

This commit is contained in:
Bruno Borges 2019-11-30 02:04:58 -08:00
parent 3d41d54c73
commit 37fa7d9542
1 changed files with 15 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
examples/src/main/java/io/dapr/examples/Example.java
View File

@ -4,46 +4,42 @@ import com.google.protobuf.Any;
import com.google.protobuf.ByteString;
import io.dapr.DaprGrpc;
import io.dapr.DaprGrpc.DaprBlockingStub;
import io.dapr.DaprProtos.DeleteStateEnvelope;
import io.dapr.DaprProtos.GetStateEnvelope;
import io.dapr.DaprProtos.GetStateResponseEnvelope;
import io.dapr.DaprProtos.PublishEventEnvelope;
import io.dapr.DaprProtos.SaveStateEnvelope;
import io.dapr.DaprProtos.StateRequest;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
/**
* Simple example, to run:
* mvn compile
* dapr run --grpc-port 50001 -- mvn exec:java -Dexec.mainClass=io.dapr.examples.Example
*
* <code>
* mvn compile
* dapr run --grpc-port 50001 -- mvn
* exec:java -Dexec.mainClass=io.dapr.examples.Example
* </code>
*/
public class Example {
public static void main(String[] args) {
ManagedChannel channel =
ManagedChannelBuilder.forAddress("localhost", 50001).usePlaintext().build();
DaprBlockingStub client = DaprGrpc.newBlockingStub(channel);
var channel = ManagedChannelBuilder.forAddress("localhost", 50001).usePlaintext().build();
var client = DaprGrpc.newBlockingStub(channel);
Any data = Any.newBuilder().setValue(ByteString.copyFromUtf8("foo")).build();
var data = Any.newBuilder().setValue(ByteString.copyFromUtf8("foo")).build();
client.publishEvent(PublishEventEnvelope.newBuilder().setTopic("foo").setData(data).build());
System.out.println("Published!");
String key = "mykey";
StateRequest req = StateRequest.newBuilder()
.setKey(key)
.setValue(Any.newBuilder().setValue(ByteString.copyFromUtf8("my value")).build())
.build();
SaveStateEnvelope state = SaveStateEnvelope.newBuilder()
.addRequests(req)
.build();
var key = "mykey";
var req = StateRequest.newBuilder().setKey(key)
.setValue(Any.newBuilder().setValue(ByteString.copyFromUtf8("my value")).build()).build();
var state = SaveStateEnvelope.newBuilder().addRequests(req).build();
client.saveState(state);
System.out.println("Saved!");
GetStateResponseEnvelope get = client.getState(GetStateEnvelope.newBuilder().setKey(key).build());
var get = client.getState(GetStateEnvelope.newBuilder().setKey(key).build());
System.out.println("Got: " + get.getData().getValue().toStringUtf8());
client.deleteState(DeleteStateEnvelope.newBuilder().setKey(key).build());
System.out.println("Deleted!");
}
}
}