Drools Grid-Node issue

<beans xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance' xmlns='http://www.springframework.org/schema/beans' xmlns:drools='http://drools.org/schema/drools-spring' xmlns:aop='http://www.springframework.org/schema/aop' xmlns:util='http://www.springframework.org/schema/util' xmlns:jms='http://www.springframework.org/schema/jms' xmlns:tx='http://www.springframework.org/schema/tx' xmlns:camel='http://camel.apache.org/schema/spring' xmlns:jee='http://www.springframework.org/schema/jee' xmlns:context='http://www.springframework.org/schema/context' xmlns:tool='http://www.springframework.org/schema/tool' xmlns:cxf='http://camel.apache.org/schema/cxf' xmlns:jaxrs='http://cxf.apache.org/jaxrs' xsi:schemaLocation='http://www.springframework.org/schema/beans file:///opt/schemas/spring-beans-3.0.xsd http://drools.org/schema/drools-spring file:///opt/schemas/drools5/drools-spring-1.5.0.xsd http://www.springframework.org/schema/aop file:///opt/schemas/spring-aop-3.0.xsd http://www.springframework.org/schema/util file:///opt/schemas/spring-util-3.0.xsd http://www.springframework.org/schema/jms file:///opt/schemas/spring-jms-3.0.xsd http://www.springframework.org/schema/tx file:///opt/schemas/spring-tx-3.0.xsd http://www.springframework.org/schema/jee file:///opt/schemas/spring-jee-3.0.xsd http://www.springframework.org/schema/context file:///opt/schemas/spring-context-3.0.xsd http://www.springframework.org/schema/tool file:///opt/schemas/spring-tool-3.0.xsd http://camel.apache.org/schema/cxf file:///opt/schemas/cxfEndpoint.xsd http://cxf.apache.org/jaxrs file:///opt/schemas/jaxrs.xsd http://camel.apache.org/schema/spring file:///opt/schemas/camel-spring.xsd '> <context:component-scan base-package="com.inspired"/> <context:annotation-config/> <aop:aspectj-autoproxy proxy-target-class="true"> <aop:include name="fuelVolumeMeasurementUtils"/> </aop:aspectj-autoproxy> <import resource="classpath*:CxfRsSpring.xml"/> <import resource="classpath:META-INF/cxf/cxf.xml"/> <drools:kstore id="kstore" /> <bean id="droolsPolicy" class="org.drools.camel.component.DroolsPolicy" /> <drools:resource-change-scanner id="agentsResourceChangeConfig" interval="90" /> <bean id="logInbound" class="org.apache.cxf.interceptor.LoggingInInterceptor"/> <bean id="logOutbound" class="org.apache.cxf.interceptor.LoggingOutInterceptor"/> <!-- <jaxrs:server id="restService" address="http://localhost:9903/kservice" staticSubresourceResolution="true" bus="cxf" serviceClass="org.drools.jax.rs.CommandExecutorImpl" serviceName="rest"> <jaxrs:providers> <ref bean="providers"/> </jaxrs:providers> </jaxrs:server>--> <cxf:rsServer id="rsServer" address="/kservice/rest" staticSubresourceResolution="true" serviceClass="org.drools.jax.rs.CommandExecutorImpl" > <cxf:providers> <bean class="org.drools.jax.rs.CommandMessageBodyReader"/> </cxf:providers> </cxf:rsServer> <cxf:rsClient id="rsClient" address="http://localhost:9903/kservice/rest" serviceClass="org.drools.jax.rs.CommandExecutorImpl"/> <bean id="camelTransportFactory" class="org.apache.camel.component.cxf.transport.CamelTransportFactory" lazy-init="true" depends-on="executionContext"> <property name="bus" ref="cxf" /> <property name="camelContext" ref="executionContext" /> <property name="transportIds"> <list> <value> http://cxf.apache.org/transports/camel </value> </list> </property> </bean> <bean id="commandExecutor" class="org.drools.jax.rs.CommandExecutorImpl" /> <bean id="jsonProvider" class="org.apache.cxf.jaxrs.provider.JSONProvider"/> <bean id="persistenceAnnotationBean" class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor"/> <bean id="rulesEngineEmf" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"> <property name="dataSource" ref="rulesDataSource" /> <property name="persistenceXmlLocation" value="config/persistenceUnit.xml"/> <property name="jpaVendorAdapter"> <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"> <property name="showSql" value="true"/> <property name="generateDdl" value="true"/> <property name="databasePlatform" value="org.hibernate.dialect.MySQLInnoDBDialect"/> </bean> </property> <property name="persistenceUnitName" value="org.drools.persistence.jpa.local" /> <property name="loadTimeWeaver"> <bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver"/> </property> </bean> <bean id="txManager" class="org.springframework.orm.jpa.JpaTransactionManager"> <property name="entityManagerFactory" ref="rulesEngineEmf" /> </bean> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="rulesDataSource" /> </bean> <tx:annotation-driven transaction-manager="txManager" proxy-target-class="true"/> <!-- <tx:advice id="txAdvice" transaction-manager="txManager"> <tx:attributes> <tx:method name="get*" read-only="true" no-rollback-for="java.lang.RuntimeException, java.lang.NullPointerException" /> <tx:method name="*" no-rollback-for="java.lang.RuntimeException, java.lang.NullPointerException"/> </tx:attributes> </tx:advice> <tx:advice id="noTxAdvice" transaction-manager="txManager"> <tx:attributes> <tx:method name="*" propagation="NOT_SUPPORTED"/> </tx:attributes> </tx:advice> --> <bean id="shared-map" class="java.util.HashMap" /> <bean id="localWhitePages" class="org.drools.grid.service.directory.impl.WhitePagesImpl" /> <bean id="timeOfDayProcessor" class="com.inspired.time.utils.TimeOfDayProcessor"/> <drools:grid id="gridOne"> <drools:core-services ref="shared-map" /> <drools:whitepages ref="localWhitePages" > <drools:jpa-persistence> <drools:entity-manager-factory ref="rulesEngineEmf" /> </drools:jpa-persistence> </drools:whitepages> <drools:socket-service acceptor="mina" ip="127.0.0.1" > <drools:service name="org.drools.grid.service.directory.WhitePages" port="8003" /> </drools:socket-service> </drools:grid> <drools:grid-node id="node1" grid="gridOne"/> <bean id="fuelConsumptionEventInitFact" class="com.inspired.instruments.dto.FuelConsumptionEvent"> <property name="location" value="${node.code}"/> </bean> <drools:kbase id="knowledge-base1" node="node1"> <drools:configuration> <drools:advanced-process-rule-integration enabled="true" /> <!-- <drools:multithread enabled="true" max-threads="15"/>--> <drools:event-processing-mode mode="STREAM"/> <drools:mbeans enabled="true"/> <drools:accumulate-functions> <drools:accumulate-function name="bigDecimalRateOfConsumption" ref="fuelRateOfConsumptionAccAccumulateProxy"/> <drools:accumulate-function name="bigDecimalAverage" ref="bigDecimalAverageAccumulateProxy" /> <drools:accumulate-function name="bigDecRegressionFunction" ref="bigDecimalRegressionAccumulateProxy"/> <drools:accumulate-function name="bigDecimalMin" ref="bigDecimalMinAccumulateFunctionProxy"/> <drools:accumulate-function name="bigDecimalMax" ref="bigDecimalMaxAccumulateFunctionProxy"/> <drools:accumulate-function name="objectFuelConsumptionRateInfo" ref="objectConsumptionRateAccFunctionProxy"/> <drools:accumulate-function name="rateOfChange" ref="rateOfChangeAccumulateFunctionProxy"/> </drools:accumulate-functions> <!-- <drools:evaluators> <drools:evaluator name="" ref=""/> </drools:evaluators>--> </drools:configuration> <drools:resources> <drools:resource source="file:/opt/ifrost/rules/logistics/logistics-rules-change-sets.xml" type="CHANGE_SET" /> </drools:resources> </drools:kbase> <drools:kagent id="kbase-kAgent" kbase="knowledge-base1" new-instance="false" use-kbase-classloader="true" /> <drools:eventListeners id="debugListeners" > <drools:agendaEventListener /> <drools:processEventListener/> <drools:workingMemoryEventListener /> </drools:eventListeners> <drools:ksession id="trnsx-stateless-ksession" type="stateless" name="trnsx-stateless-ksession" kbase="knowledge-base1" listeners="debugListeners" node="node1"> <drools:batch> <drools:set-global identifier="list"> <bean id="justAnArrayList" class="java.util.ArrayList" /> </drools:set-global> <drools:set-global identifier="mapStateless"> <bean id="justAnObjectsMap.stateful" class="java.util.TreeMap" /> </drools:set-global> <drools:set-global identifier="muleMessageMap"> <bean id="muleMessageInvokeMap" class="java.util.HashMap" /> </drools:set-global> <drools:set-global identifier="fuel-device" ref="fuelSensor"/> <drools:set-global identifier="nodeTransactionSpace" ref="nodeGigaSpace"/> <!-- <drools:set-global identifier="fuel-tank-diameter" ref="tankDiameter"/> <drools:set-global identifier="fuel-tank-height" ref="tankHeightStanding"/> <drools:set-global identifier="fuel-tank-dimensions" ref="tankDimensions"/>--> <drools:set-global identifier="tankDetails" ref="tankDetails"/> <drools:set-global identifier="timeOfDayProcessor" ref="timeOfDayProcessor"/> <drools:set-global identifier="vehicleFuelTankData" ref="vehicleFuelTankData"/> <drools:set-global identifier="vehicleMaintenanceProfile" ref="vehicleMaintenanceProfileMap"/> <drools:set-global identifier="vehicleTravelZoningMapping" ref="vehicleTravelRangeZones"/> <drools:set-global identifier="etaCalculator" ref="etaCalculatorProxy"/> <drools:set-global identifier="googleDistanceComputingEngine" ref="googleDistanceProcessorBeanProxy"/> <drools:set-global identifier="vehicleRepository" ref="logisticsVehicleRepositoryRemProxy"/> <drools:set-global identifier="driversRepository" ref="logisticsDriversRepositoryRemProxy"/> <drools:set-global identifier="mongoTemplate" ref="mongoTemplate"/> <drools:set-global identifier="droolsToMuleChannel" ref="droolsToMuleChannelRemProxy"/> <drools:set-global identifier="vehicleGridSearchService" ref="vehicleGridSearch"/> <drools:set-global identifier="plantSensorsConnector" ref="remotePlantParamsConnector"/> <drools:set-global identifier="vehicleOpsMonitoringService" ref="vehicleOpsParamsMonitorBean"/> <drools:set-global identifier="vehicleOpsParamsMap" ref="mobiVehicleOparatingParamsMap"/> </drools:batch> </drools:ksession> <drools:ksession id="trnsx-stateful-ksession" type="stateful" node="node1" kbase="knowledge-base1" name="trnsx-stateful-ksession" listeners="debugListeners"> <drools:workingMemoryEventListener ref="working-mem-drools-mule-conn-listenerProxy"/> <drools:workingMemoryEventListener ref="working-mem-drools-activiti-conn-listenerProxy"/> <drools:configuration> <drools:keep-reference enabled="true"/> <drools:clock-type type="REALTIME"/> <drools:jpa-persistence > <drools:transaction-manager ref="txManager"/> <drools:entity-manager-factory ref="rulesEngineEmf"/> </drools:jpa-persistence> </drools:configuration> </drools:ksession> <bean id="activemq" class="org.apache.camel.component.jms.JmsComponent" > <property name="connectionFactory" > <bean class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://localhost:61616"/> <property name="userName" value="root"/> <property name="password" value="inspired"/> </bean> </property> </bean> <bean id="providers" class="org.drools.jax.rs.CommandMessageBodyReader"/>