Невозможно использовать сообщения с Camel 3.3 и Google Pubsub - PullRequest
Новая
       27

Невозможно использовать сообщения с Camel 3.3 и Google Pubsub

0 голосов
/ 28 мая 2020

У меня есть небольшой сценарий groovy с верблюдом Apache, который пытается получить сообщения из Google Pubsub. Это хорошо работает на Camel 2.25.1, но на camel 3.3.0 - нет. Вот сценарий. Я также просмотрел руководство по миграции Camel 2.x на 3.0 , но я не могу найти ничего, имеющего отношение к этой проблеме, но, возможно, я ошибаюсь и мне понадобится помощь.

Моя groovy версия - 3.0.4, и я использую JDK 11.0.6 

@Grapes([
    @Grab(group='org.apache.camel', module='camel-core', version='3.3.0'),
    @Grab(group='org.apache.camel', module='camel-google-pubsub', version='3.3.0'),
    @Grab(group='org.slf4j', module='slf4j-api', version='1.7.30'),
    @Grab(group='ch.qos.logback', module='logback-classic', version='1.2.3'),
])

import org.apache.camel.CamelContext
import org.apache.camel.impl.DefaultCamelContext
import org.apache.camel.builder.RouteBuilder

main()

def main() {
    println "downloaded camel dependencies"
    CamelContext context = new DefaultCamelContext()

    context.addRoutes(new ReadFromQueueWithPubsub())
    context.start()
    addShutdownHook { context.stop() }
    synchronized(this){ this.wait() }
}


class ReadFromQueueWithPubsub extends RouteBuilder {

    @Override
    void configure() {
        from("google-pubsub://my_gcp_project:transaction-test-subscriber")
        .to("log:input?showAll=true")

    }
}

Вот фрагмент журналов в режиме отладки. Я не вижу здесь ничего подходящего, но могу ошибаться. 

2020-05-28 07:14:51 INFO  [o.a.c.i.e.AbstractCamelContext          ] - Apache Camel 3.3.0 (CamelContext: camel-1) is starting
2020-05-28 07:14:51 DEBUG [o.a.c.i.e.AbstractCamelContext          ] - Using ClassResolver=org.apache.camel.impl.engine.DefaultClassResolver@25478603, PackageScanClassResolver=org.apache.camel.impl.engine.DefaultPackageScanClassResolver@3c7dbf1f, ApplicationContextClassLoader=null, RouteController=org.apache.camel.impl.engine.DefaultRouteController@2efbe938
2020-05-28 07:14:51 INFO  [o.a.c.i.e.AbstractCamelContext          ] - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
2020-05-28 07:14:51 DEBUG [o.a.c.i.e.AbstractCamelContext          ] - Using HeadersMapFactory: org.apache.camel.impl.engine.DefaultHeadersMapFactory@12459991
2020-05-28 07:14:51 DEBUG [o.a.c.i.e.AbstractCamelContext          ] - Using ReactiveExecutor: org.apache.camel.impl.engine.DefaultReactiveExecutor@43114981
2020-05-28 07:14:51 DEBUG [o.a.c.i.e.AbstractCamelContext          ] - Warming up route id: route1 having autoStartup=true
2020-05-28 07:14:51 DEBUG [o.a.c.s.DefaultProducer                 ] - Starting producer: Producer[log://input?showAll=true]
2020-05-28 07:14:52 DEBUG [o.a.c.i.e.AbstractCamelContext          ] - Route: route1 >>> Route[google-pubsub://my_gcp_project:transaction-test-subscriber -> null]
2020-05-28 07:14:52 DEBUG [o.a.c.i.e.AbstractCamelContext          ] - Starting consumer (order: 1000) on route: route1
2020-05-28 07:14:52 DEBUG [o.a.c.s.DefaultConsumer                 ] - Init consumer: Consumer[google-pubsub://my_gcp_project:transaction-test-subscriber]
2020-05-28 07:14:52 DEBUG [o.a.c.s.DefaultConsumer                 ] - Starting consumer: Consumer[google-pubsub://my_gcp_project:transaction-test-subscriber]
2020-05-28 07:14:52 INFO  [o.a.c.c.g.p.GooglePubsubConsumer        ] - Starting Google PubSub consumer for my_gcp_project/transaction-test-subscriber
2020-05-28 07:14:52 DEBUG [o.a.c.i.e.BaseExecutorServiceManager    ] - Created new ThreadPool for source: google-pubsub://my_gcp_project:transaction-test-subscriber with name: GooglePubsubConsumer[transaction-test-subscriber]. -> org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@7d726fa1[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0][GooglePubsubConsumer[transaction-test-subscriber]]
2020-05-28 07:14:52 INFO  [o.a.c.i.e.AbstractCamelContext          ] - Route: route1 started and consuming from: google-pubsub://my_gcp_project:transaction-test-subscriber
2020-05-28 07:14:52 INFO  [o.a.c.i.e.AbstractCamelContext          ] - Total 1 routes, of which 1 are started
2020-05-28 07:14:52 INFO  [o.a.c.i.e.AbstractCamelContext          ] - Apache Camel 3.3.0 (CamelContext: camel-1) started in 0.078 seconds
2020-05-28 07:14:52 DEBUG [o.a.c.c.g.p.GooglePubsubConsumer        ] - Subscribing to projects/my_gcp_project/subscriptions/transaction-test-subscriber

1 Ответ

0 голосов
/ 02 июня 2020

Закрытие: похоже, что в JIRA есть ошибка для этого CAMEL-15064 , которая влияет на версии> = 3.2

...