Uploaded image for project: 'Spring Integration'
  1. Spring Integration
  2. INT-2666

JDBCMessageStore error with aggregator

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Complete
    • Affects Version/s: 2.1.1
    • Fix Version/s: 2.2 M4 Sprint 1, 2.2 M4, 2.1.4
    • Component/s: Core, JDBC Support
    • Labels:
      None
    • Environment:
      OS:windows xp
      Database:mysql
      APP server: Tomcat 7

      Description

      After configuring JDBC message Store with aggregator i getting below error:

      2012-07-12 15:44:30,703 ERROR [scheduler-1] [TaskUtils$LoggingErrorHandler] Unexpected error occurred in scheduled task.
      java.lang.NullPointerException
      at java.util.concurrent.LinkedBlockingQueue.offer(Lin kedBlockingQueue.java:368)
      at org.springframework.integration.store.SimpleMessag eGroup.addMessage(SimpleMessageGroup.java:96)
      at org.springframework.integration.store.SimpleMessag eGroup.<init>(SimpleMessageGroup.java:59)
      at org.springframework.integration.jdbc.JdbcMessageSt ore.getMessageGroup(JdbcMessageStore.java:390)
      at org.springframework.integration.jdbc.JdbcMessageSt ore$9.next(JdbcMessageStore.java:504)
      at org.springframework.integration.jdbc.JdbcMessageSt ore$9.next(JdbcMessageStore.java:497)
      at org.springframework.integration.store.AbstractMess ageGroupStore.expireMessageGroups(AbstractMessageG roupStore.java:78)
      at org.springframework.integration.store.MessageGroup StoreReaper.run(MessageGroupStoreReaper.java:110)
      at sun.reflect.NativeMethodAccessorImpl.invoke0(Nativ e Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke(Native MethodAccessorImpl.java:39)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke(De legatingMethodAccessorImpl.java:25)
      at java.lang.reflect.Method.invoke(Method.java:597)
      at org.springframework.scheduling.support.ScheduledMe thodRunnable.run(ScheduledMethodRunnable.java:64)
      at org.springframework.scheduling.support.DelegatingE rrorHandlingRunnable.run(DelegatingErrorHandlingRu nnable.java:53)
      at java.util.concurrent.Executors$RunnableAdapter.cal l(Executors.java:441)
      at java.util.concurrent.FutureTask$Sync.innerRunAndRe set(FutureTask.java:317)
      at java.util.concurrent.FutureTask.runAndReset(Future Task.java:150)
      at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.access$101(ScheduledThreadPoolE xecutor.java:98)
      at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.runPeriodic(ScheduledThreadPool Executor.java:181)
      at java.util.concurrent.ScheduledThreadPoolExecutor$S cheduledFutureTask.run(ScheduledThreadPoolExecutor .java:205)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run Task(ThreadPoolExecutor.java:886)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:908)
      at java.lang.Thread.run(Thread.java:619)

      Configuration:

      <int:aggregator id="catMessageAggregator" auto-startup="true"
      message-store="messageStore" input-channel="aggregate.message"
      output-channel="catalogue.eventMessange"
      send-partial-result-on-expiry="true" correlation-strategy="aggreagatorStartegy"
      correlation-strategy-method="correlationStartegy"
      release-strategy-expression="size()>9"
      expire-groups-upon-completion="false" />
      <jee:jndi-lookup id="messageStoreDB" jndi-name="${jndi.name.messageStore}" />

      <bean id="messageStore" class="org.springframework.integration.jdbc.JdbcMe ssageStore">
      <constructor-arg>
      <ref bean="messageStoreDB" />
      </constructor-arg>
      <property name="timeoutOnIdle" value="true"/>
      </bean>

      <bean id="reaper"
      class="org.springframework.integration.store.Messa geGroupStoreReaper">
      <property name="messageGroupStore" ref="messageStore" />
      <property name="timeout" value="${message.timeouttime}" />
      <property name="autoStartup" value="false"/>
      </bean>

      <task:scheduled-tasks scheduler="scheduler">
      <task:scheduled ref="reaper" method="run"
      fixed-rate="150000" />
      </task:scheduled-tasks>

      <task:scheduler id="scheduler" />

      I have no clue why it is happening
      please help

        Attachments

          Activity

            People

            Assignee:
            oleg.zhurakousky@springsource.com Oleg Zhurakousky
            Reporter:
            rahulk Rahul Kumar
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Dates

              Created:
              Updated:
              Resolved: