@@ -10,8 +10,8 @@ namespace Sample.RabbitMQ.SqlServer | |||||
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) | protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder) | ||||
{ | { | ||||
optionsBuilder.UseSqlServer("Server=192.168.2.206;Initial Catalog=TestCap;User Id=cmswuliu;Password=h7xY81agBn*Veiu3;MultipleActiveResultSets=True"); | |||||
//optionsBuilder.UseSqlServer("Server=DESKTOP-M9R8T31;Initial Catalog=Sample.Kafka.SqlServer;User Id=sa;Password=P@ssw0rd;MultipleActiveResultSets=True"); | |||||
//optionsBuilder.UseSqlServer("Server=192.168.2.206;Initial Catalog=TestCap;User Id=cmswuliu;Password=h7xY81agBn*Veiu3;MultipleActiveResultSets=True"); | |||||
optionsBuilder.UseSqlServer("Server=DESKTOP-M9R8T31;Initial Catalog=Sample.Kafka.SqlServer;User Id=sa;Password=P@ssw0rd;MultipleActiveResultSets=True"); | |||||
} | } | ||||
} | } | ||||
} | } |
@@ -19,12 +19,7 @@ namespace Sample.RabbitMQ.SqlServer | |||||
services.AddCap(x => | services.AddCap(x => | ||||
{ | { | ||||
x.UseEntityFramework<AppDbContext>(); | x.UseEntityFramework<AppDbContext>(); | ||||
x.UseRabbitMQ(xx => | |||||
{ | |||||
xx.HostName = "192.168.2.206"; | |||||
xx.UserName = "admin"; | |||||
xx.Password = "123123"; | |||||
}); | |||||
x.UseRabbitMQ("localhost"); | |||||
x.UseDashboard(); | x.UseDashboard(); | ||||
}); | }); | ||||
@@ -23,7 +23,7 @@ namespace DotNetCore.CAP | |||||
/// <summary> | /// <summary> | ||||
/// Default succeeded message expriation timespan, in seconds. | /// Default succeeded message expriation timespan, in seconds. | ||||
/// </summary> | /// </summary> | ||||
public const int DefaultSucceedMessageExpirationAfter = 3600; | |||||
public const int DefaultSucceedMessageExpirationAfter = 24 * 3600; | |||||
/// <summary> | /// <summary> | ||||
/// Failed message retry waiting interval. | /// Failed message retry waiting interval. | ||||
@@ -53,7 +53,7 @@ namespace DotNetCore.CAP | |||||
/// <summary> | /// <summary> | ||||
/// Sent or received succeed message after timespan of due, then the message will be deleted at due time. | /// Sent or received succeed message after timespan of due, then the message will be deleted at due time. | ||||
/// Dafault is 3600 seconds. | |||||
/// Dafault is 24*3600 seconds. | |||||
/// </summary> | /// </summary> | ||||
public int SucceedMessageExpiredAfter { get; set; } | public int SucceedMessageExpiredAfter { get; set; } | ||||