- ft = record_filters filter.filters, Log.table_name
- cond_out += ft[:cond_out]
- param_out += ft[:param_out]
+ ft = record_filters filter.filters, Log
+ if ft[:cond_out].any?
+ # Join the clauses within a single subscription filter with AND
+ # so it is consistent with regular queries
+ cond_out << "(#{ft[:cond_out].join ') AND ('})"
+ param_out += ft[:param_out]
+ end