Stream Processing Rule Engine for the AllGoTrade Platform