Jessica Dauphin: The mayor’s budget proposed just under $63 million (for WeGo), and the (Metro) Council wound up taking $1 million away from WeGo to put towards priorities in MNPS, which was needed. How did public transportation fare in this budget? In an episode last week, a few of our guests talked about how budgets reflect a city’s priorities. This Is Nashville Host Khalil Ekulona: The M etro budget was recently passed. You can listen to the full episode about public transportation here. On Wednesday, This Is Nashville invited Cathy Carrillo, education and engagement manager at Walk Bike Nashville, and Transit Alliance of Middle Tennessee CEO Jessica Dauphin to answer listener questions about the current state of public transportation and infrastructure. Var globalPublicationTasks = Task.WhenAll(globalPublicationTasks) Īm i missing something? What am i doing wrong? I would expect that HandleAsync method is called when some integration event is published on the bus.Driving a personal vehicle is the main way to travel in Nashville, but residents would still like to see the city invest in public transit, sidewalks, bike lanes and other modes of transportation. Additionaly i append the code responsible for publishing my events: public async Task PublishAsync(params IIntegrationEvent events) ![]() But the problem is the HandleAsync method is never called, although some events are published. Public override async Task HandleAsync(IIntegrationEvent readyToBeSavedEvent = new _eventRepository.CreateAsync(readyToBeSavedEvent) Īwait _eventRepository.SaveChangesAsync() ĮventHandler base class implements the IConsumer interface, so i thought it should be somehow connected with all integration events occured on the bus. Public EventHandler(IEventRepository eventRepository) Private readonly IEventRepository _eventRepository Public abstract Task HandleAsync(TIntegrationEvent sealed class EventHandler : IntegrationEventHandler Public async Task Consume(ConsumeContext context) => IConsumer where TIntegrationEvent : class, IIntegrationEvent Here i attach the definition of EventHandler class, and it's parent: public abstract class IntegrationEventHandler : IIntegrationEventHandler, As you have noticed - i have only one consumer called "EventHandler" which has to handle all the IntegrationEvents. The connection parameters are correct, i've checked them few times. I've configured the communication in the event store like shown below: public static IServiceCollection RegisterMessagingDependencies(this IServiceCollection services, My event store has to handle all the integration events which are travelling across the bus. Back to the implementation - i have an event store (different container). The problem is any of my consumers don't respond to the corresponding message (probably due to some configuration errors). The messages from the service are published properly because i can notice them in RabbitMq Management System. It has no consumer due to our simplification - it only has to publish some message to the bus. Configure(configuration.GetSection(RabbitMQSettingsSectionKey)) AddSingleton(provider => provider.GetRequiredService()) HostConfigurator.Password(rabbitMQSettings.Password) Ĭonfigurator.ExchangeType = ExchangeType.Fanout AddSingleton(serviceProvider => (configurator => ![]() To register broker dependencies i use the following code: internal static IServiceCollection RegisterRabbitMQDependencies(this IServiceCollection services, Let's simplify my solution, so imagine i have a simple common service which has to broadcast some messages to the bus. I am new to messaging with RabbitMQ, and probably i've configured something improperly. I would like to attach some kind of event store to my solution. ![]() I am implementing application in microservices architecture.
0 Comments
Leave a Reply. |
Details
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |