Writing to Service Bus or Database from Application layer

[sforsandeep]

I am trying to build an Azure function using this Architecture. In my application I have a requirement of writing into DB and also writing some messages into Service Bus.

So in my infrastructure layer I have created a class like this MessageBroker.cs

public class MessageBrokerService : IMessageBrokerService
{
    private readonly IConfiguration _configuration;

    public MessageBrokerService(IConfiguration configuration)
    {
        _configuration = configuration;
    }
    public async Task<Message> PushToTopic(string topic, string message)
    {
        string connectionString = "myconnectionstring"
        topic= "mytopic"
        ServiceBusClient client = new ServiceBusClient(connectionString);
        Message m = new Message();
        try
        {
            var sender = client.CreateSender(topic);
            var msg = new ServiceBusMessage(message);
            await sender.SendMessageAsync(msg);
            m.Status = Domain.Enums.Status.Success;
            m.Remarks = "Message posted successfull";
            

        }
        catch (ServiceBusException ex)
        {
            m.Status = Domain.Enums.Status.Failure;
            m.Remarks = ex.Message;
            
        }
        catch(Exception ex)
        {
            m.Status = Domain.Enums.Status.Failure;
            m.Remarks = ex.Message;
        }
        
        m.Timestamp = "";
        return m;
    }

}


```And in my application layer I have created an interface **IMessageBroker.cs**

public interface IMessageBrokerService
{
Task PushToTopic(string topic, string message);

}

Also in the infrastructure Dependencyinjection.cs file

**services.AddScoped<IMessageBrokerService, MessageBrokerService>();**


So in my Azure Function App I am calling some transformation method in my Application layer. In that method what it does is transforming a given JSON with some values. So after transforming I need to write that into DB and Service Bus.

But since my PushTopic message in infrastrucure layer how can I call that since I cant inject the IMessageBroker into Application layer since application layer has no dependency to the infra project.

Please help me. I am really got stucked.