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.
