An example of using the CassandraDbObjectStore to distribute the state of an idempotent-message-filter.

cassandra-idempotent-config.xml

    <spring:bean id="cassandraObjectStore" class="com.mulesoft.mule.cassandradb.CassandraDBObjectStore"
                 scope="singleton">
        <spring:property name="host" value="cassandradb.acmesoft.com"/>
        <spring:property name="port" value="9160"/>
        <spring:property name="keyspace" value="MuleState"/>
        <spring:property name="consistencyLevel" value="ALL"/>
        <spring:property name="defaultPartitionName"
                         value="idempotentFlow_#[new java.text.SimpleDateFormat('yyyy_MM_dd').format(new Date())]"/>
    </spring:bean>

    <flow name="idempotentReception">
        <http:inbound-endpoint address="http://0.0.0.0:8080/orders" exchange-patter="one-way"/>
        <idempotent-message-filter idExpression="#[payload]">
            <spring-object-store ref="cassandraObjectStore"/>
        </idempotent-message-filter>
        <vm:outbound-endpoint path="order.process"/>
    </flow>