Skip to content

Commit 974d9be

Browse files
authored
Merge pull request #1 from ivansorokinf/master
Mongo scheduler uses rabbit host from connection string
2 parents e2ddbf7 + 551bf6d commit 974d9be

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

Source/EasyNetQ.Scheduler.Mongo/SchedulerServiceConfiguration.cs

100644100755
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,11 +10,13 @@ public class SchedulerServiceConfiguration : ConfigurationBase, ISchedulerServic
1010
public TimeSpan PublishInterval { get; set; }
1111
public TimeSpan HandleTimeoutInterval { get; set; }
1212
public int PublishMaxSchedules { get; set; }
13+
public string RabbitHost { get; set; }
1314

1415
public static SchedulerServiceConfiguration FromConfigFile()
1516
{
1617
return new SchedulerServiceConfiguration
1718
{
19+
RabbitHost = ConfigurationManager.ConnectionStrings["rabbit"].ConnectionString,
1820
SubscriptionId = ConfigurationManager.AppSettings["subscriptionId"],
1921
PublishInterval = GetTimeSpanAppSettings("publishInterval"),
2022
PublishMaxSchedules = GetIntAppSetting("publishMaxSchedules"),

Source/EasyNetQ.Scheduler.Mongo/SchedulerServiceFactory.cs

100644100755
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ public static class SchedulerServiceFactory
77
public static ISchedulerService CreateScheduler()
88
{
99
var serviceConfig = SchedulerServiceConfiguration.FromConfigFile();
10-
var bus = RabbitHutch.CreateBus("host=localhost", sr =>
10+
var bus = RabbitHutch.CreateBus(serviceConfig.RabbitHost, sr =>
1111
{
1212
if (serviceConfig.EnableLegacyConventions) sr.EnableLegacyConventions();
1313
});

0 commit comments

Comments
 (0)