0
は、私は次のように定義された加入者を持っている:subscriber.startAsync
を呼び出すときGoogleのPubSubの加入者startAsync NosuchmethodError
class PubSubMessageReceiver extends MessageReceiver {
override def receiveMessage(message: PubsubMessage, consumer: AckReplyConsumer): Unit = {
// .. business logic
//acknowledge message
consumer.ack()
}
}
val subscriber = Subscriber.defaultBuilder(subscriptionName, new PubSubMessageReceiver).build()
は、しかし、私は次のエラーが表示されます
java.lang.NoSuchMethodError: com.google.api.core.AbstractApiService$InnerService.startAsync()Lcom/google/common/util/concurrent/Service;
at com.google.api.core.AbstractApiService.startAsync(AbstractApiService.java:121)
at com.google.cloud.pubsub.spi.v1.Subscriber.startAsync(Subscriber.java:218)
サブスクライバをどのような環境で起動していますか? –