From 37fa7d9542921cc9f7a227a42e24cc6c02d85c5f Mon Sep 17 00:00:00 2001 From: Bruno Borges Date: Sat, 30 Nov 2019 02:04:58 -0800 Subject: [PATCH] fix formatting javadoc --- .../main/java/io/dapr/examples/Example.java | 34 ++++++++----------- 1 file changed, 15 insertions(+), 19 deletions(-) diff --git a/examples/src/main/java/io/dapr/examples/Example.java b/examples/src/main/java/io/dapr/examples/Example.java index 7f68533ef..dde4dc2c7 100644 --- a/examples/src/main/java/io/dapr/examples/Example.java +++ b/examples/src/main/java/io/dapr/examples/Example.java @@ -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 + * + * + * mvn compile + * dapr run --grpc-port 50001 -- mvn + * exec:java -Dexec.mainClass=io.dapr.examples.Example + * */ 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!"); } -} \ No newline at end of file +}