{"action":"created","issue":{"url":"https://api.github.com/repos/MassTransit/MassTransit/issues/647","repository_url":"https://api.github.com/repos/MassTransit/MassTransit","labels_url":"https://api.github.com/repos/MassTransit/MassTransit/issues/647/labels{/name}","comments_url":"https://api.github.com/repos/MassTransit/MassTransit/issues/647/comments","events_url":"https://api.github.com/repos/MassTransit/MassTransit/issues/647/events","html_url":"https://github.com/MassTransit/MassTransit/issues/647","id":176302486,"number":647,"title":"Is bus.ScheduleRecurringMessage() broken?","user":{"login":"brase","id":170088,"avatar_url":"https://avatars.githubusercontent.com/u/170088?v=3","gravatar_id":"","url":"https://api.github.com/users/brase","html_url":"https://github.com/brase","followers_url":"https://api.github.com/users/brase/followers","following_url":"https://api.github.com/users/brase/following{/other_user}","gists_url":"https://api.github.com/users/brase/gists{/gist_id}","starred_url":"https://api.github.com/users/brase/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/brase/subscriptions","organizations_url":"https://api.github.com/users/brase/orgs","repos_url":"https://api.github.com/users/brase/repos","events_url":"https://api.github.com/users/brase/events{/privacy}","received_events_url":"https://api.github.com/users/brase/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":14,"created_at":"2016-09-12T06:24:40Z","updated_at":"2016-09-28T14:23:42Z","closed_at":null,"body":"I am trying to send recurring messages to the bus but they go in the skipped queue instead of the wanted destination. \r\n\r\nAm I wrong in doing it this way:\r\n\r\n    public class MyMessage2\r\n    {\r\n        public string Value { get; set; }\r\n    }\r\n\r\n    public class MyMessageConsumer : IConsumer<MyMessage2>\r\n    {\r\n        public Task Consume(ConsumeContext<MyMessage2> context)\r\n        {\r\n            return Console.Out.WriteLineAsync($\"Received: {context.Message.Value}\");\r\n        }\r\n    }\r\n    public class SendNotificationSchedule : DefaultRecurringSchedule\r\n    {\r\n        public SendNotificationSchedule()\r\n        {\r\n            CronExpression = \"0/5 * * * * ?\";\r\n            Description = \"vla\";\r\n            StartTime = DateTimeOffset.Now;\r\n            EndTime = null;\r\n            MisfirePolicy = MissedEventPolicy.Default;\r\n        }\r\n    }\r\n\r\n\r\n    class Program\r\n    {\r\n        static void Main(string[] args)\r\n        {\r\n            // Code Snippet for Console Application\r\n            var bus = Bus.Factory.CreateUsingRabbitMq(config =>\r\n            {\r\n                var host = config.Host(new Uri(\"rabbitmq://localhost/\"), h =>\r\n                {\r\n                    h.Username(\"bla\");\r\n                    h.Password(\"bla\");\r\n                });\r\n\r\n                config.ReceiveEndpoint(host, \"my_queue2\", endpoint =>\r\n                {\r\n                    endpoint.Consumer<MyMessageConsumer>();\r\n                });\r\n\r\n                config.UseInMemoryScheduler();\r\n            });\r\n\r\n            using (bus.Start())\r\n            {\r\n                //sends messages but they go into skipped\r\n                bus.ScheduleRecurringMessage(new SendNotificationSchedule(), new MyMessage2 {Value = \"Bla\"});\r\n\r\n                Console.ReadLine();\r\n            }\r\n        }\r\n    }"},"comment":{"url":"https://api.github.com/repos/MassTransit/MassTransit/issues/comments/250181419","html_url":"https://github.com/MassTransit/MassTransit/issues/647#issuecomment-250181419","issue_url":"https://api.github.com/repos/MassTransit/MassTransit/issues/647","id":250181419,"user":{"login":"alexeyzimarev","id":2821205,"avatar_url":"https://avatars.githubusercontent.com/u/2821205?v=3","gravatar_id":"","url":"https://api.github.com/users/alexeyzimarev","html_url":"https://github.com/alexeyzimarev","followers_url":"https://api.github.com/users/alexeyzimarev/followers","following_url":"https://api.github.com/users/alexeyzimarev/following{/other_user}","gists_url":"https://api.github.com/users/alexeyzimarev/gists{/gist_id}","starred_url":"https://api.github.com/users/alexeyzimarev/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/alexeyzimarev/subscriptions","organizations_url":"https://api.github.com/users/alexeyzimarev/orgs","repos_url":"https://api.github.com/users/alexeyzimarev/repos","events_url":"https://api.github.com/users/alexeyzimarev/events{/privacy}","received_events_url":"https://api.github.com/users/alexeyzimarev/received_events","type":"User","site_admin":false},"created_at":"2016-09-28T14:23:42Z","updated_at":"2016-09-28T14:23:42Z","body":"But again, to cancel the recurring schedule, I have to use the \"obsolete\" `IBus.CancelScheduledRecurringMessage`, right? At least it is used in tests."}}
{"actor":{"display_login":"alexeyzimarev"}}