Announcement Announcement Module
Collapse
No announcement yet.
JdbcChannelMessageStore.completeGroup() Not implemented Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • JdbcChannelMessageStore.completeGroup() Not implemented

    I am trying to use the new JdbcChannelMessageStore functionality, but I am getting the following exception:

    Code:
    Caused by: java.lang.UnsupportedOperationException: Not implemented
            at org.springframework.integration.jdbc.store.JdbcChannelMessageStore.completeGroup(JdbcChannelMessageStore.java:426)
            at org.springframework.integration.aggregator.AggregatingMessageHandler.afterRelease(AggregatingMessageHandler.java:67)
    Looking at the javadocs for JdbcChannelMessageStore I do see that it says "Method not implemented". Since this is being called but the UnsupportedOperationException is being thrown is this functionality not really ready yet? Or am I missing something in the configuration?

    Code:
        <int:aggregator input-channel="notification.event.route.channel" message-store="notificationMessageStore"                    ref="notificationEventAggregator" method="aggregate"
                        release-strategy="notificationEventAggregator" release-strategy-method="canRelease"
                        correlation-strategy="notificationEventAggregator" correlation-strategy-method="correlateBy"
                        output-channel="notification.event.aggregated.channel" send-partial-result-on-expiry="true"/>
    
    
        <bean id="notificationMessageStore" class="org.springframework.integration.jdbc.store.JdbcChannelMessageStore">
            <property name="dataSource" ref="dataSource"/>
            <property name="channelMessageStoreQueryProvider" ref="messageStoreQueryProvider"/>
        </bean>
    
    
        <bean id="messageStoreQueryProvider"
              class="org.springframework.integration.jdbc.store.channel.PostgresChannelMessageStoreQueryProvider"/>
    
    
        <jdbc:initialize-database data-source="dataSource" ignore-failures="DROPS" enabled="true">
            <jdbc:script location="classpath:org/springframework/integration/jdbc/store/channel/schema-postgresql.sql"/>
        </jdbc:initialize-database>
    I am assuming because it is in a release 2.2.1 jar it would be usable now, but for misconfiguration on my part.

  • #2
    The 'JdbcChannelMessageStore' is for JMS-backed channels only; it is not intended for use in other elements, such as aggregators. From the javadocs...

    Code:
    This message store shall be used for message channels only.
    For an aggregator, use the 'JdbcMessageStore' instead.

    Comment

    Working...
    X