easyabp / abp.eventbus.boxes.dtm Goto Github PK

2023-05-19 14:28:58.594 +02:00 [ERR] Object reference not set to an instance of an object.
System.NullReferenceException: Object reference not set to an instance of an object.
   at System.Runtime.CompilerServices.ConfiguredTaskAwaitable`1.ConfiguredTaskAwaiter.get_IsCompleted()
   at EasyAbp.Abp.EventBus.Boxes.Dtm.AbpDtmgRPCClient.DtmGrpcCall(TransBase transBase, String operation)
   at Dtmgrpc.MsgGrpc.Prepare(String queryPrepared, CancellationToken cancellationToken)
   at EasyAbp.Abp.EventBus.Boxes.Dtm.GrpcDtmMessageManager.PrepareTransMessagesAsync(DtmOutboxEventBag eventBag, CancellationToken cancellationToken)
   at EasyAbp.Abp.EventBus.Boxes.Dtm.GrpcDtmMessageManager.PrepareAndInsertBarriersAsync(DtmOutboxEventBag eventBag, CancellationToken cancellationToken)
   at EasyAbp.Abp.EventBus.Distributed.Dtm.DtmUnitOfWork.CommitTransactionsAsync()
   at Volo.Abp.Uow.UnitOfWork.CompleteAsync(CancellationToken cancellationToken)
   at Volo.Abp.AspNetCore.Uow.AbpUnitOfWorkMiddleware.InvokeAsync(HttpContext context, RequestDelegate next)
   at Microsoft.AspNetCore.Builder.UseMiddlewareExtensions.<>c__DisplayClass6_1.<<UseMiddlewareInterface>b__1>d.MoveNext()
--- End of stack trace from previous location ---
   at Volo.Abp.AspNetCore.ExceptionHandling.AbpExceptionHandlingMiddleware.InvokeAsync(HttpContext context, RequestDelegate next)

"RabbitMQ": {
    "Connections": {
      "Default": {
        "HostName": "localhost",
        "Port": "5672",
        "UserName": "guest",
        "Password": "guest"
      }
    },
    "EventBus": {
      "ClientName": "rabbit@dev-rabbit",
      "ExchangeName": "amq.direct"
    }
  },
  "DTM": {
    "ActionApiToken": "1q2w3e",
    "AppGrpcUrl": "http://localhost:54358",
    "DtmGrpcUrl": "http://localhost:36790"
  }

typeof(AbpEventBusRabbitMqModule),
    typeof(AbpEventBusBoxesDtmGrpcModule),
    typeof(AbpEventBusBoxesDtmEntityFrameworkCoreModule)

Configure<AbpDistributedEventBusOptions>(options =>
        {
            options.Outboxes.Configure(config =>
            {
                config.UseDbContextWithDtmOutbox<AbpDtmApp1DbContext>();
            });

            options.Inboxes.Configure(config =>
            {
                config.UseDbContextWithDtmInbox<AbpDtmApp1DbContext>();
            });
        });

        // Use `AddDtmOutbox` and `AddDtmInbox` separately if you only need one of them.
        context.Services.AddDtmBoxes();

        context.Services.AddGrpc();
        context.Services.AddAbpDtmGrpc(options =>
        {
            options.ActionApiToken = "1q2w3e";  // DTM Server invokes app's action APIs with this token for authorization.
            options.AppGrpcUrl = "https://localhost:44336";  // Base URL for DTM Server to invoke the current app. Only HTTP now!
            options.DtmGrpcUrl = "http://127.0.0.1:36790";  // Base URL for the current app to invoke DTM Server.
        });

app.UseConfiguredEndpoints(endpoints =>
        {
            endpoints.MapAbpDtmGrpcService();
        });