Commit ffba435d authored by Savorboard's avatar Savorboard

update samples

parent 1bb0c8d5
...@@ -19,7 +19,7 @@ namespace Sample.Kafka.SqlServer.Controllers ...@@ -19,7 +19,7 @@ namespace Sample.Kafka.SqlServer.Controllers
[Route("~/without/transaction")] [Route("~/without/transaction")]
public IActionResult WithoutTransaction() public IActionResult WithoutTransaction()
{ {
_capBus.Publish("sample.rabbitmq.mysql", DateTime.Now); _capBus.Publish("sample.kafka.sqlserver", DateTime.Now);
return Ok(); return Ok();
} }
...@@ -34,7 +34,7 @@ namespace Sample.Kafka.SqlServer.Controllers ...@@ -34,7 +34,7 @@ namespace Sample.Kafka.SqlServer.Controllers
//your business code //your business code
connection.Execute("insert into dbo.test1(tname) values('test');", transaction: transaction); connection.Execute("insert into dbo.test1(tname) values('test');", transaction: transaction);
_capBus.Publish("sample.rabbitmq.mysql", DateTime.Now); _capBus.Publish("sample.kafka.sqlserver", DateTime.Now);
transaction.Commit(); transaction.Commit();
} }
...@@ -44,7 +44,7 @@ namespace Sample.Kafka.SqlServer.Controllers ...@@ -44,7 +44,7 @@ namespace Sample.Kafka.SqlServer.Controllers
} }
[NonAction] [NonAction]
[CapSubscribe("sample.rabbitmq.mysql")] [CapSubscribe("sample.kafka.sqlserver")]
public void Subscriber(DateTime time) public void Subscriber(DateTime time)
{ {
Console.WriteLine($@"{DateTime.Now}, Subscriber invoked, Sent time:{time}"); Console.WriteLine($@"{DateTime.Now}, Subscriber invoked, Sent time:{time}");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment