[
https://issues.apache.org/jira/browse/CAMEL-15064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17161157#comment-17161157
]
Ramesh Venkitaswaran commented on CAMEL-15064:
----------------------------------------------
Camel 3.4
{code:java}
06:03:59.267 [Camel Thread #0 - LRUCacheFactory] DEBUG
org.apache.camel.component.caffeine.lrucache.CaffeineLRUCacheFactory - Warming
up LRUCache ...
06:03:59.267 [main] INFO org.apache.camel.support.LRUCacheFactory - Detected
and using LRUCacheFactory: camel-caffeine-lrucache
06:03:59.456 [Camel Thread #0 - LRUCacheFactory] DEBUG
org.apache.camel.component.caffeine.lrucache.CaffeineLRUCacheFactory - Warming
up LRUCache complete in 194 millis
06:03:59.463 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Setting up management with factory:
org.apache.camel.impl.engine.DefaultManagementStrategyFactory@62d59d60
06:03:59.486 [main] DEBUG org.apache.camel.impl.engine.BaseServiceResolver -
Found HealthCheckRegistry:
org.apache.camel.impl.health.DefaultHealthCheckRegistry via:
META-INF/services/org/apache/camel/health-check-registry
06:03:59.496 [main] DEBUG org.apache.camel.impl.engine.BaseServiceResolver -
Detected and using HealthCheckRegistry:
org.apache.camel.impl.health.DefaultHealthCheckRegistry@6d2d04ef
06:03:59.546 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Loading file
META-INF/services/org/apache/camel/TypeConverterLoader to retrieve list of type
converters, from url:
jar:file:/Users/ramesh/.groovy/grapes/org.apache.camel/camel-support/jars/camel-support-3.4.0.jar!/META-INF/services/org/apache/camel/TypeConverterLoader
06:03:59.552 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Loading file
META-INF/services/org/apache/camel/TypeConverterLoader to retrieve list of type
converters, from url:
jar:file:/Users/ramesh/.groovy/grapes/org.apache.camel/camel-base/jars/camel-base-3.4.0.jar!/META-INF/services/org/apache/camel/TypeConverterLoader
06:03:59.555 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Loading file
META-INF/services/org/apache/camel/TypeConverterLoader to retrieve list of type
converters, from url:
jar:file:/Users/ramesh/.groovy/grapes/org.apache.camel/camel-file/jars/camel-file-3.4.0.jar!/META-INF/services/org/apache/camel/TypeConverterLoader
06:03:59.559 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Loading file
META-INF/services/org/apache/camel/TypeConverterLoader to retrieve list of type
converters, from url:
jar:file:/Users/ramesh/.groovy/grapes/org.apache.camel/camel-xml-jaxp/jars/camel-xml-jaxp-3.4.0.jar!/META-INF/services/org/apache/camel/TypeConverterLoader
06:03:59.563 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader:
org.apache.camel.converter.stream.StreamCacheConverterLoader
06:03:59.567 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader:
org.apache.camel.converter.stream.StreamCacheConverterLoader loading converters
06:03:59.576 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.CamelConverterLoader
06:03:59.579 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.CamelConverterLoader loading
converters
06:03:59.581 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.CollectionConverterLoader
06:03:59.584 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.CollectionConverterLoader
loading converters
06:03:59.589 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.DateTimeConverterLoader
06:03:59.591 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.DateTimeConverterLoader loading
converters
06:03:59.596 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.DurationConverterLoader
06:03:59.599 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.DurationConverterLoader loading
converters
06:03:59.601 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.IOConverterLoader
06:03:59.605 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.IOConverterLoader loading
converters
06:03:59.623 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.NIOConverterLoader
06:03:59.626 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.NIOConverterLoader loading
converters
06:03:59.631 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.ObjectConverterLoader
06:03:59.633 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.ObjectConverterLoader loading
converters
06:03:59.645 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.SQLConverterLoader
06:03:59.646 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.SQLConverterLoader loading
converters
06:03:59.647 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.impl.converter.UriTypeConverterLoader
06:03:59.648 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.impl.converter.UriTypeConverterLoader
loading converters
06:03:59.649 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.component.file.GenericFileConverterLoader
06:03:59.653 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.component.file.GenericFileConverterLoader
loading converters
06:03:59.662 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.jaxp.DomConverterLoader
06:03:59.666 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.jaxp.DomConverterLoader loading
converters
06:03:59.668 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.jaxp.StaxConverterLoader
06:03:59.672 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.jaxp.StaxConverterLoader
loading converters
06:03:59.678 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.jaxp.StreamSourceConverterLoader
06:03:59.679 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader:
org.apache.camel.converter.jaxp.StreamSourceConverterLoader loading converters
06:03:59.680 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.converter.jaxp.XmlConverterLoader
06:03:59.685 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.converter.jaxp.XmlConverterLoader loading
converters
06:03:59.713 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry - Resolving
TypeConverterLoader: org.apache.camel.util.xml.StreamSourceConverterLoader
06:03:59.715 [main] DEBUG
org.apache.camel.impl.converter.BaseTypeConverterRegistry -
TypeConverterLoader: org.apache.camel.util.xml.StreamSourceConverterLoader
loading converters
06:03:59.724 [main] DEBUG org.apache.camel.impl.converter.DefaultTypeConverter
- Loaded 197 type converters in 0.178 seconds
06:04:00.330 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Adding routes from builder: Routes: []
06:04:00.489 [main] DEBUG org.apache.camel.impl.engine.BaseServiceResolver -
Found RestRegistryFactory:
org.apache.camel.component.rest.DefaultRestRegistryFactory via:
META-INF/services/org/apache/camel/rest-registry-factory
06:04:00.489 [main] DEBUG org.apache.camel.impl.engine.BaseServiceResolver -
Detected and using RestRegistryFactory:
org.apache.camel.component.rest.DefaultRestRegistryFactory@2121d0ed
06:04:00.507 [main] DEBUG org.apache.camel.impl.engine.BaseServiceResolver -
Found PropertiesComponent:
org.apache.camel.component.properties.PropertiesComponent via:
META-INF/services/org/apache/camel/properties-component-factory
06:04:00.524 [main] DEBUG org.apache.camel.impl.engine.BaseServiceResolver -
Detected and using PropertiesComponent:
org.apache.camel.component.properties.PropertiesComponent@1ee1c0cc
06:04:00.532 [main] DEBUG org.apache.camel.support.ResolverHelper - Lookup
Language with name simple in registry. Found: null
06:04:00.533 [main] DEBUG org.apache.camel.support.ResolverHelper - Lookup
Language with name simple-language in registry. Found: null
06:04:00.670 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Using ComponentResolver:
org.apache.camel.impl.engine.DefaultComponentResolver@705a793a to resolve
component with name: google-pubsub
06:04:00.670 [main] DEBUG org.apache.camel.support.ResolverHelper - Lookup
Component with name google-pubsub in registry. Found: null
06:04:00.670 [main] DEBUG org.apache.camel.support.ResolverHelper - Lookup
Component with name google-pubsub-component in registry. Found: null
06:04:00.681 [main] DEBUG org.apache.camel.impl.engine.DefaultComponentResolver
- Found component: google-pubsub via type:
org.apache.camel.component.google.pubsub.GooglePubsubComponent via:
META-INF/services/org/apache/camel/component/google-pubsub
06:04:00.837 [main] DEBUG
org.apache.camel.impl.engine.DefaultConfigurerResolver - Found configurer:
google-pubsub-component via type:
org.apache.camel.component.google.pubsub.GooglePubsubComponentConfigurer via:
META-INF/services/org/apache/camel/configurer/google-pubsub-component
06:04:00.841 [main] DEBUG
org.apache.camel.impl.engine.DefaultConfigurerResolver - Found configurer:
google-pubsub-endpoint via type:
org.apache.camel.component.google.pubsub.GooglePubsubEndpointConfigurer via:
META-INF/services/org/apache/camel/configurer/google-pubsub-endpoint
06:04:00.846 [main] DEBUG org.apache.camel.support.DefaultComponent - Creating
endpoint
uri=[google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO],
path=[GCP-PROJECT-NAME:transaction-test-subscriber]
06:04:00.872 [main] DEBUG
org.apache.camel.impl.converter.CoreTypeConverterRegistry - Promoting fallback
type converter as a known type converter to convert from:
org.apache.camel.component.google.pubsub.GooglePubsubConstants.AckMode to:
java.lang.String for the fallback converter:
org.apache.camel.impl.converter.EnumTypeConverter@63e148cb
06:04:00.882 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO
converted to endpoint:
google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO by
component:
org.apache.camel.component.google.pubsub.GooglePubsubComponent@1bc4ec31
06:04:00.898 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Using ComponentResolver:
org.apache.camel.impl.engine.DefaultComponentResolver@705a793a to resolve
component with name: log
06:04:00.898 [main] DEBUG org.apache.camel.support.ResolverHelper - Lookup
Component with name log in registry. Found: null
06:04:00.898 [main] DEBUG org.apache.camel.support.ResolverHelper - Lookup
Component with name log-component in registry. Found: null
06:04:00.902 [main] DEBUG org.apache.camel.impl.engine.DefaultComponentResolver
- Found component: log via type: org.apache.camel.component.log.LogComponent
via: META-INF/services/org/apache/camel/component/log
06:04:00.906 [main] DEBUG
org.apache.camel.impl.engine.DefaultConfigurerResolver - Found configurer:
log-component via type: org.apache.camel.component.log.LogComponentConfigurer
via: META-INF/services/org/apache/camel/configurer/log-component
06:04:00.910 [main] DEBUG
org.apache.camel.impl.engine.DefaultConfigurerResolver - Found configurer:
log-endpoint via type: org.apache.camel.component.log.LogEndpointConfigurer
via: META-INF/services/org/apache/camel/configurer/log-endpoint
06:04:00.910 [main] DEBUG org.apache.camel.support.DefaultComponent - Creating
endpoint uri=[log://input?showAll=true], path=[input]
06:04:00.926 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
log://input?showAll=true converted to endpoint: log://input?showAll=true by
component: org.apache.camel.component.log.LogComponent@69e0f16
06:04:01.026 [main] DEBUG org.apache.camel.reifier.LogReifier - LogName is not
configured, using route id as logName: route1
06:04:01.047 [main] INFO org.apache.camel.impl.engine.AbstractCamelContext -
Apache Camel 3.4.0 (camel-1) is starting
06:04:01.047 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Using ClassResolver=org.apache.camel.impl.engine.DefaultClassResolver@6a6b4536,
PackageScanClassResolver=org.apache.camel.impl.engine.DefaultPackageScanClassResolver@5582249c,
ApplicationContextClassLoader=null,
RouteController=org.apache.camel.impl.engine.DefaultRouteController@19801b8d
06:04:01.049 [main] INFO org.apache.camel.impl.engine.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
06:04:01.049 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Using HeadersMapFactory:
org.apache.camel.impl.engine.DefaultHeadersMapFactory@f6776e2
06:04:01.049 [main] DEBUG org.apache.camel.impl.engine.AbstractCamelContext -
Using ReactiveExecutor:
org.apache.camel.impl.engine.DefaultReactiveExecutor@79e1f733
06:04:01.049 [main] INFO org.apache.camel.impl.engine.AbstractCamelContext -
Using HealthCheck: camel-health
06:04:01.052 [main] DEBUG
org.apache.camel.impl.engine.InternalRouteStartupManager - Warming up route id:
route1 having autoStartup=true
06:04:01.071 [main] DEBUG org.apache.camel.support.DefaultProducer - Starting
producer: Producer[log://input?showAll=true]
06:04:01.072 [main] DEBUG
org.apache.camel.impl.engine.InternalRouteStartupManager - Route: route1 >>>
Route[google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO
-> null]
06:04:01.072 [main] DEBUG
org.apache.camel.impl.engine.InternalRouteStartupManager - Starting consumer
(order: 1000) on route: route1
06:04:01.073 [main] DEBUG org.apache.camel.support.DefaultConsumer - Init
consumer:
Consumer[google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO]
06:04:01.073 [main] DEBUG org.apache.camel.support.DefaultConsumer - Starting
consumer:
Consumer[google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO]
06:04:01.073 [main] INFO
org.apache.camel.component.google.pubsub.GooglePubsubConsumer - Starting Google
PubSub consumer for GCP-PROJECT-NAME/transaction-test-subscriber
06:04:01.078 [main] DEBUG
org.apache.camel.impl.engine.BaseExecutorServiceManager - Created new
ThreadPool for source:
google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber?ackMode=AUTO with
name: GooglePubsubConsumer[transaction-test-subscriber]. ->
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@11306ed7[Running,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks =
0][GooglePubsubConsumer[transaction-test-subscriber]]
06:04:01.295 [Camel (camel-1) thread #1 -
GooglePubsubConsumer[transaction-test-subscriber]] DEBUG
org.apache.camel.component.google.pubsub.GooglePubsubConsumer - Subscribing to
projects/GCP-PROJECT-NAME/subscriptions/transaction-test-subscriber
06:04:01.299 [main] INFO
org.apache.camel.impl.engine.InternalRouteStartupManager - Route: route1
started and consuming from:
google-pubsub://GCP-PROJECT-NAME:transaction-test-subscriber
06:04:01.316 [main] INFO org.apache.camel.impl.engine.AbstractCamelContext -
Total 1 routes, of which 1 are started
06:04:01.317 [main] INFO org.apache.camel.impl.engine.AbstractCamelContext -
Apache Camel 3.4.0 (camel-1) started in 0.270 seconds{code}
> Messages no more received from Google Pubsub
> --------------------------------------------
>
> Key: CAMEL-15064
> URL: https://issues.apache.org/jira/browse/CAMEL-15064
> Project: Camel
> Issue Type: Bug
> Components: camel-google-pubsub
> Affects Versions: 3.2.0
> Environment: * macOS 10.15.4
> * OpenJDK 11.0.6 2020-01-14
> * I've been able to reproduce the issue on Ubuntu 16, same JDK
> Reporter: Jean-Pierre Matsumoto
> Assignee: Omar Al-Safi
> Priority: Major
> Fix For: 3.4.0
>
>
> With Camel 3.2.0, my route does not receive the messages from Google Pubsub.
> The exact same route works well if I downgrade to 3.1.0.
> I've created following test case to reproduce easily the issue:
> {code:java}
> @Component
> public class SimplePubsubRouteBuilder extends RouteBuilder {
> @Override
> public void configure() throws Exception {
> from("google-pubsub://project-id:subs-name")
> .to("log:myLog?showHeaders=true");
> }
> }{code}
> Result with *Camel 3.2.0*: nothing happens, no errors even with DEBUG log
> level.
> Result with *Camel 3.1.0*: error 404 as expected since Pubsub subscription
> path is invalid.
> I've tried to fix the issue myself with no success. But by tracing with
> debugger, I think the issue is because of bad version of Guava library.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
