ChadCorsentino
commented
7 years ago 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.
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 SelectChannelConnector@0.0.0.0: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.