{"action":"created","issue":{"url":"https://api.github.com/repos/dotnet/orleans/issues/990","labels_url":"https://api.github.com/repos/dotnet/orleans/issues/990/labels{/name}","comments_url":"https://api.github.com/repos/dotnet/orleans/issues/990/comments","events_url":"https://api.github.com/repos/dotnet/orleans/issues/990/events","html_url":"https://github.com/dotnet/orleans/issues/990","id":115039615,"number":990,"title":"Need to replay the historic messages","user":{"login":"angshuman-agarwal","id":1796126,"avatar_url":"https://avatars.githubusercontent.com/u/1796126?v=3","gravatar_id":"","url":"https://api.github.com/users/angshuman-agarwal","html_url":"https://github.com/angshuman-agarwal","followers_url":"https://api.github.com/users/angshuman-agarwal/followers","following_url":"https://api.github.com/users/angshuman-agarwal/following{/other_user}","gists_url":"https://api.github.com/users/angshuman-agarwal/gists{/gist_id}","starred_url":"https://api.github.com/users/angshuman-agarwal/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/angshuman-agarwal/subscriptions","organizations_url":"https://api.github.com/users/angshuman-agarwal/orgs","repos_url":"https://api.github.com/users/angshuman-agarwal/repos","events_url":"https://api.github.com/users/angshuman-agarwal/events{/privacy}","received_events_url":"https://api.github.com/users/angshuman-agarwal/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/dotnet/orleans/labels/question","name":"question","color":"cc317c"}],"state":"open","locked":false,"assignee":{"login":"jason-bragg","id":10675494,"avatar_url":"https://avatars.githubusercontent.com/u/10675494?v=3","gravatar_id":"","url":"https://api.github.com/users/jason-bragg","html_url":"https://github.com/jason-bragg","followers_url":"https://api.github.com/users/jason-bragg/followers","following_url":"https://api.github.com/users/jason-bragg/following{/other_user}","gists_url":"https://api.github.com/users/jason-bragg/gists{/gist_id}","starred_url":"https://api.github.com/users/jason-bragg/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/jason-bragg/subscriptions","organizations_url":"https://api.github.com/users/jason-bragg/orgs","repos_url":"https://api.github.com/users/jason-bragg/repos","events_url":"https://api.github.com/users/jason-bragg/events{/privacy}","received_events_url":"https://api.github.com/users/jason-bragg/received_events","type":"User","site_admin":false},"milestone":null,"comments":17,"created_at":"2015-11-04T12:11:07Z","updated_at":"2015-11-10T20:47:56Z","closed_at":null,"body":"Hi,\r\n[Documentation](http://dotnet.github.io/orleans/Orleans-Streams/Streams-Implementation) on PullingProtocol says - _once the consumer has subscribed to the stream it will see all events that were generated after it has subscribed (in addition, using StreamSequenceToken allows to subscribe in the past)._\r\n\r\nCan someone point out on how to use this in the persistent provider with own queue adapter ? I would like to replay the historic data (_snapshot data_) first for every new client subscribing to an existing stream and then send the ticking data (_latest data_). Something on these lines - http://goo.gl/KPdZvy. I do not think I need to go via path of writing a completely new [StreamProvider](http://dotnet.github.io/orleans/Orleans-Streams/Streams-Extensibility) (last option in this link). \r\n \r\nThanks a lot for any suggestions.\r\n\r\nregards\r\nAngshuman"},"comment":{"url":"https://api.github.com/repos/dotnet/orleans/issues/comments/155561048","html_url":"https://github.com/dotnet/orleans/issues/990#issuecomment-155561048","issue_url":"https://api.github.com/repos/dotnet/orleans/issues/990","id":155561048,"user":{"login":"amamh","id":2524201,"avatar_url":"https://avatars.githubusercontent.com/u/2524201?v=3","gravatar_id":"","url":"https://api.github.com/users/amamh","html_url":"https://github.com/amamh","followers_url":"https://api.github.com/users/amamh/followers","following_url":"https://api.github.com/users/amamh/following{/other_user}","gists_url":"https://api.github.com/users/amamh/gists{/gist_id}","starred_url":"https://api.github.com/users/amamh/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/amamh/subscriptions","organizations_url":"https://api.github.com/users/amamh/orgs","repos_url":"https://api.github.com/users/amamh/repos","events_url":"https://api.github.com/users/amamh/events{/privacy}","received_events_url":"https://api.github.com/users/amamh/received_events","type":"User","site_admin":false},"created_at":"2015-11-10T20:47:56Z","updated_at":"2015-11-10T20:47:56Z","body":"@jason-bragg \r\n\r\n> along with a persistent backend queue (EventHub, Kafka, ..) \r\n\r\nWhat is the point of doing that if the stream's \"Rewindable\" feature doesn't work?"}}