CDI Camel MQ QuickStart from Web GUI not working

[stevef1uk]

I am trying to find a good messaging example.

I run the Messaging application form console Runtime -> Run this started up the components I expected. The Message Broker Pod didn't start until I ran the 'gofabric8 volumes' command to create the missing volume.

Then I ran the example-message-producer and example-message-consumer to check all was ok, which it was. I could see messages arriving at the consumer ok.

Then I tried to create an application that also used messaging from the Console using Quickstart -> Camel cdi-camel- amq v. 2.2.179.

The Pod created is logging errors:

Error syncing pod, skipping: failed to "StartContainer" for "java-exec" with CrashLoopBackOff: "Back-off 10s restarting failed container=java-exec pod=myqs1-2956951779-2d7s5_default-testing(cf19c9d2-990a-11e6-a967-4219d5efc92e)"

The Pod's logs are:

xec java -javaagent:/opt/agent-bond/agent-bond.jar=jolokia{{host=0.0.0.0}},jmx_exporter{{9779:/opt/agent-bond/jmx_exporter_config.yml}} -cp .:/deployments/* org.apache.camel.cdi.Main
I> No access restrictor found, access to any MBean is allowed
Jolokia: Agent started with URL http://172.17.0.17:8778/jolokia/
2016-10-23 10:40:20.431:INFO:ifasjipjsoejs.Server:jetty-8.y.z-SNAPSHOT
2016-10-23 10:40:20.474:INFO:ifasjipjsoejs.AbstractConnector:Started [email protected]:9779
2016-10-23 10:40:20 INFO Version:153 - WELD-000900: 2.3.3 (Final)
Oct 23, 2016 10:40:20 AM org.apache.deltaspike.core.util.ProjectStageProducer initProjectStage
INFO: Computed the following DeltaSpike ProjectStage: Production
2016-10-23 10:40:20 INFO Bootstrap:209 - WELD-000101: Transactional services not available. Injection of @Inject UserTransaction not available. Transactional observers will be invoked synchronously.
2016-10-23 10:40:20 INFO Event:87 - WELD-000411: Observer method [BackedAnnotatedMethod] private org.apache.camel.cdi.CdiCamelExtension.processAnnotatedType(@observes ProcessAnnotatedType) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
2016-10-23 10:40:20 INFO Event:87 - WELD-000411: Observer method [BackedAnnotatedMethod] public io.fabric8.cdi.Fabric8Extension.processAnnotatedType(@observes ProcessAnnotatedType, BeanManager) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
2016-10-23 10:40:20 INFO Event:87 - WELD-000411: Observer method [BackedAnnotatedMethod] protected org.apache.deltaspike.core.impl.exclude.extension.ExcludeExtension.vetoBeans(@observes ProcessAnnotatedType, BeanManager) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
2016-10-23 10:40:20 INFO Event:87 - WELD-000411: Observer method [BackedAnnotatedMethod] protected org.apache.deltaspike.core.impl.interceptor.GlobalInterceptorExtension.promoteInterceptors(@observes ProcessAnnotatedType, BeanManager) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
2016-10-23 10:40:20 INFO Event:87 - WELD-000411: Observer method [BackedAnnotatedMethod] protected org.apache.deltaspike.core.impl.message.MessageBundleExtension.detectInterfaces(@observes ProcessAnnotatedType) receives events for all annotated types. Consider restricting events using @WithAnnotations or a generic type with bounds.
2016-10-23 10:40:22 INFO Systems:147 - Connecting to service amqbroker on : from $AMQBROKER_SERVICE_HOST and $AMQBROKER_SERVICE_PORT
Exception in thread "main" org.jboss.weld.exceptions.DeploymentException: Exception List with 1 exceptions:
Exception 0 :
javax.enterprise.inject.InjectionException: Error adding routes of type [org.example.MyRoutes] to Camel context [myCdiCamelContext]
at org.apache.camel.cdi.CdiCamelExtension.addRouteToContext(CdiCamelExtension.java:452)
at org.apache.camel.cdi.CdiCamelExtension.afterDeploymentValidation(CdiCamelExtension.java:398)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.jboss.weld.injection.StaticMethodInjectionPoint.invoke(StaticMethodInjectionPoint.java:88)
at org.jboss.weld.injection.MethodInvocationStrategy$SpecialParamPlusBeanManagerStrategy.invoke(MethodInvocationStrategy.java:144)
at org.jboss.weld.event.ObserverMethodImpl.sendEvent(ObserverMethodImpl.java:309)
at org.jboss.weld.event.ExtensionObserverMethodImpl.sendEvent(ExtensionObserverMethodImpl.java:124)
at org.jboss.weld.event.ObserverMethodImpl.sendEvent(ObserverMethodImpl.java:287)
at org.jboss.weld.event.ObserverMethodImpl.notify(ObserverMethodImpl.java:265)
at org.jboss.weld.event.ObserverNotifier.notifySyncObservers(ObserverNotifier.java:271)
at org.jboss.weld.event.ObserverNotifier.notify(ObserverNotifier.java:260)
at org.jboss.weld.event.ObserverNotifier.fireEvent(ObserverNotifier.java:154)
at org.jboss.weld.event.ObserverNotifier.fireEvent(ObserverNotifier.java:148)
at org.jboss.weld.bootstrap.events.AbstractContainerEvent.fire(AbstractContainerEvent.java:53)
at org.jboss.weld.bootstrap.events.AbstractDeploymentContainerEvent.fire(AbstractDeploymentContainerEvent.java:35)
at org.jboss.weld.bootstrap.events.AfterDeploymentValidationImpl.fire(AfterDeploymentValidationImpl.java:28)
at org.jboss.weld.bootstrap.WeldStartup.validateBeans(WeldStartup.java:449)
at org.jboss.weld.bootstrap.WeldBootstrap.validateBeans(WeldBootstrap.java:90)
at org.jboss.weld.environment.se.Weld.initialize(Weld.java:558)
at org.apache.deltaspike.cdise.weld.WeldContainerControl.boot(WeldContainerControl.java:68)
at org.apache.camel.cdi.Main.doStart(Main.java:97)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:138)
at org.apache.camel.main.MainSupport.run(MainSupport.java:390)
at org.apache.camel.cdi.Main.main(Main.java:64)
Caused by: java.lang.RuntimeException: Failed to process @factory annotated method: create on bean: org.example.ActiveMQComponentFactory. Failed to lookup bean of type: class org.apache.activemq.ActiveMQConnectionFactory for service: amqbroker.
at io.fabric8.cdi.producers.FactoryMethodProducer.produce(FactoryMethodProducer.java:145)
at io.fabric8.cdi.bean.ProducerBean.create(ProducerBean.java:43)
at org.jboss.weld.context.unbound.DependentContextImpl.get(DependentContextImpl.java:70)
at org.jboss.weld.bean.ContextualInstanceStrategy$DefaultContextualInstanceStrategy.get(ContextualInstanceStrategy.java:101)
at org.jboss.weld.bean.ContextualInstance.get(ContextualInstance.java:50)
at org.jboss.weld.manager.BeanManagerImpl.getReference(BeanManagerImpl.java:742)
at org.jboss.weld.manager.BeanManagerImpl.getInjectableReference(BeanManagerImpl.java:842)
at org.jboss.weld.injection.FieldInjectionPoint.inject(FieldInjectionPoint.java:92)
at org.jboss.weld.util.Beans.injectBoundFields(Beans.java:363)
at org.jboss.weld.util.Beans.injectFieldsAndInitializers(Beans.java:374)
at org.jboss.weld.injection.producer.ResourceInjector$1.proceed(ResourceInjector.java:70)
at org.jboss.weld.injection.InjectionContextImpl.run(InjectionContextImpl.java:48)
at org.jboss.weld.injection.producer.ResourceInjector.inject(ResourceInjector.java:72)
at org.jboss.weld.injection.producer.BasicInjectionTarget.inject(BasicInjectionTarget.java:121)
at org.jboss.weld.bean.ManagedBean.create(ManagedBean.java:159)
at org.jboss.weld.context.unbound.DependentContextImpl.get(DependentContextImpl.java:70)
at org.jboss.weld.bean.ContextualInstanceStrategy$DefaultContextualInstanceStrategy.get(ContextualInstanceStrategy.java:101)
at org.jboss.weld.bean.ContextualInstance.get(ContextualInstance.java:50)
at org.jboss.weld.manager.BeanManagerImpl.getReference(BeanManagerImpl.java:742)
at org.jboss.weld.manager.BeanManagerImpl.getReference(BeanManagerImpl.java:765)
at org.jboss.weld.util.ForwardingBeanManager.getReference(ForwardingBeanManager.java:61)
at org.jboss.weld.bean.builtin.BeanManagerProxy.getReference(BeanManagerProxy.java:85)
at org.apache.camel.cdi.BeanManagerHelper.getReference(BeanManagerHelper.java:53)
at org.apache.camel.cdi.CdiCamelExtension.addRouteToContext(CdiCamelExtension.java:437)
... 27 more
Caused by: java.lang.RuntimeException: Failed to process @factory annotated method: create on bean: org.example.mq.ActiveMQConfigurer. Failed to lookup service amqbroker.
at io.fabric8.cdi.producers.FactoryMethodProducer.produce(FactoryMethodProducer.java:108)
at io.fabric8.cdi.bean.ProducerBean.create(ProducerBean.java:43)
at org.jboss.weld.context.unbound.DependentContextImpl.get(DependentContextImpl.java:70)
at org.jboss.weld.bean.ContextualInstanceStrategy$DefaultContextualInstanceStrategy.get(ContextualInstanceStrategy.java:101)
at org.jboss.weld.bean.ContextualInstance.get(ContextualInstance.java:50)
at org.jboss.weld.manager.BeanManagerImpl.getReference(BeanManagerImpl.java:742)
at org.jboss.weld.manager.BeanManagerImpl.getReference(BeanManagerImpl.java:765)
at org.jboss.weld.util.ForwardingBeanManager.getReference(ForwardingBeanManager.java:61)
at org.jboss.weld.bean.builtin.BeanManagerProxy.getReference(BeanManagerProxy.java:85)
at org.apache.deltaspike.core.api.provider.BeanProvider.getContextualReference(BeanProvider.java:497)
at org.apache.deltaspike.core.api.provider.BeanProvider.getContextualReference(BeanProvider.java:157)
at org.apache.deltaspike.core.api.provider.BeanProvider.getContextualReference(BeanProvider.java:121)
at org.apache.deltaspike.core.api.provider.BeanProvider.getContextualReference(BeanProvider.java:100)
at io.fabric8.cdi.producers.FactoryMethodProducer.getServiceBean(FactoryMethodProducer.java:251)
at io.fabric8.cdi.producers.FactoryMethodProducer.produce(FactoryMethodProducer.java:142)
... 50 more
Caused by: java.lang.IllegalArgumentException: No kubernetes service could be found for name: amqbroker in namespace: default-testing
at io.fabric8.kubernetes.api.KubernetesHelper.getServiceURL(KubernetesHelper.java:1347)
at io.fabric8.cdi.Services.toServiceUrl(Services.java:38)
at io.fabric8.cdi.producers.ServiceUrlProducer.produce(ServiceUrlProducer.java:47)
at io.fabric8.cdi.producers.ServiceUrlProducer.produce(ServiceUrlProducer.java:26)
at io.fabric8.cdi.producers.FactoryMethodProducer.getServiceUrl(FactoryMethodProducer.java:211)
at io.fabric8.cdi.producers.FactoryMethodProducer.produce(FactoryMethodProducer.java:105)
... 64 more
at org.jboss.weld.bootstrap.events.AbstractDeploymentContainerEvent.fire(AbstractDeploymentContainerEvent.java:37)
at org.jboss.weld.bootstrap.events.AfterDeploymentValidationImpl.fire(AfterDeploymentValidationImpl.java:28)
at org.jboss.weld.bootstrap.WeldStartup.validateBeans(WeldStartup.java:449)
at org.jboss.weld.bootstrap.WeldBootstrap.validateBeans(WeldBootstrap.java:90)
at org.jboss.weld.environment.se.Weld.initialize(Weld.java:558)
at org.apache.deltaspike.cdise.weld.WeldContainerControl.boot(WeldContainerControl.java:68)
at org.apache.camel.cdi.Main.doStart(Main.java:97)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:138)
at org.apache.camel.main.MainSupport.run(MainSupport.java:390)
at org.apache.camel.cdi.Main.main(Main.java:64)
2016-10-23 10:40:22 INFO MainSupport$HangupInterceptor:80 - Received hang up - stopping the main instance.

Using kubectl I can see that there is a service called activemq available, but perhaps not in the defaukt-testing namespace? I will see if I can change the source and see what happens to use amqbroker.

[ChadCorsentino]

Has this issue been resolved yet? I can't even find the consumer and producer examples... And none of the messaging quickstarts are even running pods. They seem to start up a pod, install karaf features, then exit and shutdown.