update readme

README.md

@@ -94,7 +94,7 @@ public void Configure(IApplicationBuilder app)
 
 Inject `ICapPublisher` in your Controller, then use the `ICapPublisher` to send message
 
-```cs
+```c#
 public class PublishController : Controller
 {
 	private readonly AppDbContext _dbContext;
@@ -128,10 +128,9 @@ public class PublishController : Controller
 
 Add the Attribute `[CapSubscribe()]` on Action to subscribe message:
 
-```cs
+```c#
 public class PublishController : Controller
 {
-	[NoAction]
 	[CapSubscribe("xxx.services.account.check")]
 	public async Task CheckReceivedMessage(Person person)
 	{

README.zh-cn.md

@@ -97,29 +97,22 @@ public void Configure(IApplicationBuilder app)
 ```c#
 public class PublishController : Controller
 {
-	private readonly ICapPublisher _publisher;
-
-	public PublishController(ICapPublisher publisher)
-	{
-		_publisher = publisher;
-	}
-
+	private readonly AppDbContext _dbContext;
 
-	[Route("~/checkAccount")]
-	public async Task<IActionResult> PublishMessage()
+	public PublishController(AppDbContext dbContext)
 	{
-		//指定发送的消息头和内容
-		await _publisher.PublishAsync("xxx.services.account.check", new Person { Name = "Foo", Age = 11 });
-
-		return Ok();
+		_dbContext = dbContext;
 	}
 
 	[Route("~/checkAccountWithTrans")]
-	public async Task<IActionResult> PublishMessageWithTransaction([FromServices]AppDbContext dbContext)
+	public async Task<IActionResult> PublishMessageWithTransaction([FromServices]ICapPublisher publisher)
 	{
 		using (var trans = dbContext.Database.BeginTransaction())
 		{
-			await _publisher.PublishAsync("xxx.services.account.check", new Person { Name = "Foo", Age = 11 });
+			// your business code
+
+			//Achieving atomicity between original database operation and the publish event log thanks to a local transaction
+			await publisher.PublishAsync("xxx.services.account.check", new Person { Name = "Foo", Age = 11 });
 
 			trans.Commit();
 		}