<int:recipient channel="myChannel"
       selector-expression="(payload.getValueForVariable('thingA') = 'this_value')"
    />

<int-jdbc:outbound-channel-adapter
    channel="myChannel" id="myAdapter"
    data-source='myDataSource' sql-parameter-source-factory="myRequestSource"
    query="INSERT INTO realtime.table1(a_id,  b_id)
                                     VALUES(:a_id, :b_id)">
</int-jdbc:outbound-channel-adapter>

query="DELETE FROM realtime.table2(a_id,  b_id) WHERE a_id = :a_id">