You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
//nested class for access to 'store' methods
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()
However when calling subscriber.startAsync I receive the following error:
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)
Activity
autodidacticon commentedon May 12, 2017
The provided guava dependency was out of date.
deps: update dependency com.google.cloud:google-cloud-bigquery to v2.…
chore(main): release 2.34.2 (#2067)
test: enable proto column tests on emulator (googleapis#2056)
chore(main): release 1.130.0 (#2056)
chore(main): release 1.130.0 (#2056)
chore(deps): update dependency com.google.cloud:libraries-bom to v26.…
deps: update shared dependencies (googleapis#2056)
chore(main): release 2.32.0 (googleapis#2073)