msg bucketing based on time beats