diff --git a/akka-projection-grpc/src/main/scala/akka/projection/grpc/producer/scaladsl/EventProducerPush.scala b/akka-projection-grpc/src/main/scala/akka/projection/grpc/producer/scaladsl/EventProducerPush.scala index bd2a61de1..92cf6c1f3 100644 --- a/akka-projection-grpc/src/main/scala/akka/projection/grpc/producer/scaladsl/EventProducerPush.scala +++ b/akka-projection-grpc/src/main/scala/akka/projection/grpc/producer/scaladsl/EventProducerPush.scala @@ -52,8 +52,6 @@ final class EventProducerPush[Event]( def handler()(implicit system: ActorSystem[_]) : FlowWithContext[EventEnvelope[Event], ProjectionContext, Done, ProjectionContext, NotUsed] = { - // FIXME gprc client config - use stream id to look up block? Use host to lookup port (normal gRPC client config)? Something else? - // users doing it themselves may be fine? val eventConsumerClient = EventConsumerServiceClient(grpcClientSettings) EventPusher(originId, eventConsumerClient, eventProducerSource, connectionMetadata.getOrElse(MetadataBuilder.empty)) }