increase max message size from default 4MiB to MaxInt

Author: fm3

src/main/scala/com/scalableminds/fossildb/FossilDBServer.scala

@@ -6,7 +6,8 @@ package com.scalableminds.fossildb
 import com.scalableminds.fossildb.db.StoreManager
 import com.scalableminds.fossildb.proto.fossildbapi.FossilDBGrpc
 import com.typesafe.scalalogging.LazyLogging
-import io.grpc.{Server, ServerBuilder}
+import io.grpc.Server
+import io.grpc.netty.NettyServerBuilder
 
 import scala.concurrent.ExecutionContext
 
@@ -15,7 +16,7 @@ class FossilDBServer(storeManager: StoreManager, port: Int, executionContext: Ex
   private[this] var server: Server = null
 
   def start(): Unit = {
-    server = ServerBuilder.forPort(port).addService(FossilDBGrpc.bindService(new FossilDBGrpcImpl(storeManager), executionContext)).build.start
+    server = NettyServerBuilder.forPort(port).maxMessageSize(Int.MaxValue).addService(FossilDBGrpc.bindService(new FossilDBGrpcImpl(storeManager), executionContext)).build.start
     logger.info("Server started, listening on " + port)
     sys.addShutdownHook {
       logger.info("Shutting down gRPC server since JVM is shutting down")

src/test/scala/com/scalableminds/fossildb/FossilDBSuite.scala

@@ -9,7 +9,7 @@ import java.nio.file.Paths
 import com.google.protobuf.ByteString
 import com.scalableminds.fossildb.db.StoreManager
 import com.scalableminds.fossildb.proto.fossildbapi._
-import io.grpc.ManagedChannelBuilder
+import io.grpc.netty.NettyChannelBuilder
 import org.scalatest.{BeforeAndAfterEach, FlatSpec}
 
 import scala.concurrent.ExecutionContext
@@ -21,7 +21,7 @@ class FossilDBSuite extends FlatSpec with BeforeAndAfterEach {
 
   val port = 21505
   var serverOpt: Option[FossilDBServer] = None
-  val client = FossilDBGrpc.blockingStub(ManagedChannelBuilder.forAddress("127.0.0.1", port).usePlaintext(true).build)
+  val client = FossilDBGrpc.blockingStub(NettyChannelBuilder.forAddress("127.0.0.1", port).maxInboundMessageSize(Int.MaxValue).usePlaintext(true).build)
 
   val collectionA = "collectionA"
   val collectionB = "collectionB"