traceback.log

reactor.core.support.Exceptions$ValueCause: Exception while signaling value: java.util.LinkedHashMap.class : {@SpeciesCode=CO, @SpeciesName=Carbon Monoxide, @Description=Carbon Monoxide is a colourless, odourless poisonous gas produced by incomplete, or inefficient, combustion of fuel including 'cold' or badly tuned engines., @HealthEffect=The gas affects the transport of oxygen around the body by the blood. At very high levels, this can lead to a significant reduction in the supply of oxygen to the heart, particularly in people suffering from heart disease., @Link=http://www.londonair.org.uk/LondonAir/guide/WhatIsCO.aspx}
	at reactor.core.support.Exceptions.addValueAsLastCause(Exceptions.java:127) ~[reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action.onNext(Action.java:206) [reactor-stream-2.0.5.RELEASE.jar:na]
	... 83 common frames omitted
Wrapped by: java.lang.IllegalStateException: Peer already started
	at reactor.io.net.ReactorPeer.start(ReactorPeer.java:71) ~[reactor-net-2.0.5.RELEASE.jar:na]
	at reactor.io.net.impl.netty.http.NettyHttpClient.request(NettyHttpClient.java:183) ~[reactor-net-2.0.5.RELEASE.jar:na]
	at reactor.io.net.http.HttpClient.get(HttpClient.java:72) ~[reactor-net-2.0.5.RELEASE.jar:na]
	at sun.reflect.GeneratedMethodAccessor34.invoke(Unknown Source) ~[na:na]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_60]
	at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_60]
	at org.codehaus.groovy.runtime.callsite.PojoMetaMethodSite$PojoCachedMethodSiteNoUnwrap.invoke(PojoMetaMethodSite.java:213) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.PojoMetaMethodSite.call(PojoMetaMethodSite.java:56) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:125) [groovy-all-2.4.4.jar:2.4.4]
	at com.basho.ingest.LondonAirQualityKafkaSource$_kafkaIngest_closure1$_closure2.doCall(LondonAirQualityKafkaSource.groovy:53) ~[main/:na]
	at sun.reflect.GeneratedMethodAccessor32.invoke(Unknown Source) ~[na:na]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_60]
	at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_60]
	at org.codehaus.groovy.reflection.CachedMethod.invoke(CachedMethod.java:93) [groovy-all-2.4.4.jar:2.4.4]
	at groovy.lang.MetaMethod.doMethodInvoke(MetaMethod.java:325) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.metaclass.ClosureMetaClass.invokeMethod(ClosureMetaClass.java:294) ~[groovy-all-2.4.4.jar:2.4.4]
	at groovy.lang.MetaClassImpl.invokeMethod(MetaClassImpl.java:1019) ~[groovy-all-2.4.4.jar:2.4.4]
	at groovy.lang.Closure.call(Closure.java:426) ~[groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.ConvertedClosure.invokeCustom(ConvertedClosure.java:53) ~[groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.ConversionHandler.invoke(ConversionHandler.java:105) ~[groovy-all-2.4.4.jar:2.4.4]
	at com.sun.proxy.$Proxy59.apply(Unknown Source) ~[na:na]
	at reactor.rx.action.transformation.MapAction.doNext(MapAction.java:37) ~[reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action.onNext(Action.java:202) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.core.reactivestreams.SubscriberWithContext.onNext(SubscriberWithContext.java:82) [reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.rx.stream.IterableStream$1.accept(IterableStream.java:70) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.stream.IterableStream$1.accept(IterableStream.java:65) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.core.reactivestreams.PublisherFactory$ForEachBiConsumer.accept(PublisherFactory.java:411) [reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.core.reactivestreams.PublisherFactory$ForEachBiConsumer.accept(PublisherFactory.java:375) [reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.core.reactivestreams.PublisherFactory$SubscriberProxy.request(PublisherFactory.java:318) [reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.support.WrappedSubscription.onRequest(WrappedSubscription.java:101) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.PushSubscription.request(PushSubscription.java:84) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.support.WrappedSubscription.request(WrappedSubscription.java:47) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action.requestMore(Action.java:619) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action.requestUpstream(Action.java:572) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action$7.onRequest(Action.java:564) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.PushSubscription.request(PushSubscription.java:84) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.combination.DynamicMergeAction.requestMore(DynamicMergeAction.java:70) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.combination.DynamicMergeAction.requestUpstream(DynamicMergeAction.java:108) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.combination.FanInAction.requestUpstream(FanInAction.java:154) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action$7.onRequest(Action.java:564) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.PushSubscription.request(PushSubscription.java:84) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.PushSubscription.accept(PushSubscription.java:68) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.subscription.PushSubscription.accept(PushSubscription.java:35) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.core.dispatch.TailRecurseDispatcher.dispatch(TailRecurseDispatcher.java:102) [reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.terminal.ConsumerAction.requestMore(ConsumerAction.java:70) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.terminal.ConsumerAction.doOnSubscribe(ConsumerAction.java:100) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.action.Action.onSubscribe(Action.java:171) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.core.reactivestreams.PublisherFactory$ReactorPublisher.subscribe(PublisherFactory.java:259) [reactor-core-2.0.5.RELEASE.jar:na]
	at reactor.rx.Streams$1.subscribe(Streams.java:183) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.Stream.consumeOn(Stream.java:449) [reactor-stream-2.0.5.RELEASE.jar:na]
	at reactor.rx.Stream.consume(Stream.java:426) [reactor-stream-2.0.5.RELEASE.jar:na]
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_60]
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_60]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_60]
	at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_60]
	at org.codehaus.groovy.runtime.callsite.PojoMetaMethodSite$PojoCachedMethodSiteNoUnwrap.invoke(PojoMetaMethodSite.java:213) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.PojoMetaMethodSite.call(PojoMetaMethodSite.java:56) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:48) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:113) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:125) [groovy-all-2.4.4.jar:2.4.4]
	at com.basho.ingest.LondonAirQualityKafkaSource.kafkaIngest(LondonAirQualityKafkaSource.groovy:48) [main/:na]
	at com.basho.ingest.LondonAirQualityKafkaSource$$EnhancerBySpringCGLIB$$5fa1322d.CGLIB$kafkaIngest$8(<generated>) [spring-core-4.2.1.RELEASE.jar:na]
	at com.basho.ingest.LondonAirQualityKafkaSource$$EnhancerBySpringCGLIB$$5fa1322d$$FastClassBySpringCGLIB$$4b800a1.invoke(<generated>) [spring-core-4.2.1.RELEASE.jar:na]
	at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228) [spring-core-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:318) [spring-context-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at com.basho.ingest.LondonAirQualityKafkaSource$$EnhancerBySpringCGLIB$$5fa1322d.kafkaIngest(<generated>) [spring-core-4.2.1.RELEASE.jar:na]
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_60]
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_60]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_60]
	at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_60]
	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:162) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:588) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1123) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1018) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:510) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:482) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:305) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:301) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:196) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:772) [spring-beans-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:834) [spring-context-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:537) [spring-context-4.2.1.RELEASE.jar:4.2.1.RELEASE]
	at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:118) [spring-boot-1.3.0.M5.jar:1.3.0.M5]
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:667) [spring-boot-1.3.0.M5.jar:1.3.0.M5]
	at org.springframework.boot.SpringApplication.doRun(SpringApplication.java:342) [spring-boot-1.3.0.M5.jar:1.3.0.M5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:273) [spring-boot-1.3.0.M5.jar:1.3.0.M5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:980) [spring-boot-1.3.0.M5.jar:1.3.0.M5]
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:969) [spring-boot-1.3.0.M5.jar:1.3.0.M5]
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_60]
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_60]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_60]
	at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_60]
	at org.codehaus.groovy.reflection.CachedMethod.invoke(CachedMethod.java:93) [groovy-all-2.4.4.jar:2.4.4]
	at groovy.lang.MetaMethod.doMethodInvoke(MetaMethod.java:325) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.StaticMetaMethodSite.invoke(StaticMetaMethodSite.java:46) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.StaticMetaMethodSite.call(StaticMetaMethodSite.java:91) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:48) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:113) [groovy-all-2.4.4.jar:2.4.4]
	at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:125) [groovy-all-2.4.4.jar:2.4.4]
	at com.basho.ingest.LondonAirQualityKafkaSource.main(LondonAirQualityKafkaSource.groovy:68) [main/:na]
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_60]
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_60]
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_60]
	at java.lang.reflect.Method.invoke(Method.java:497) ~[na:1.8.0_60]
	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140) [idea_rt.jar:na]