* added test case to demonstrate query-based subscription recovery policy in action. * minor refactor to the SubscriptionRecoveryPolicy API to make it easy to generate messages from inside the recovery policy