Skip to content

Commit 01a7b65

Browse files
committed
fixed spring boot upgraded repository
1 parent 76de53e commit 01a7b65

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

jpa-example/guestbook-server/src/main/java/com/example/grpc/springboot/GuestbookServiceGrpcImpl.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@
2020
import io.grpc.stub.StreamObserver;
2121
import org.springframework.boot.autoconfigure.grpc.server.GrpcService;
2222

23+
import java.util.Optional;
24+
2325
/**
2426
* Created by rayt on 6/20/17.
2527
*/
@@ -41,16 +43,15 @@ public void all(AllRequest request, StreamObserver<GuestbookEntry> responseObser
4143

4244
@Override
4345
public void findOne(FindOneRequest request, StreamObserver<GuestbookEntry> responseObserver) {
44-
GuestbookEntryDomain entry = repository.findOne(request.getId());
45-
if (entry != null) {
46-
responseObserver.onNext(entry.toProto());
47-
}
46+
Optional<GuestbookEntryDomain> entry = repository.findById(request.getId());
47+
entry.map(e -> e.toProto())
48+
.ifPresent(responseObserver::onNext);
4849
responseObserver.onCompleted();
4950
}
5051

5152
@Override
5253
public void delete(DeleteRequest request, StreamObserver<DeleteResponse> responseObserver) {
53-
repository.delete(request.getId());
54+
repository.deleteById(request.getId());
5455
responseObserver.onNext(DeleteResponse.getDefaultInstance());
5556
responseObserver.onCompleted();
5657
}

0 commit comments

Comments
 (0)