public class MessageBroker : IMessageBroker, IDisposable
{
    private readonly MessagingFactory messagingFactory;

    public MessageBroker(IAppConfiguration appConfiguration)
    {
        this.messagingFactory = MessagingFactory.CreateFromConnectionString(appConfiguration.BrokerConnectionString);
    }

    public async Task SendMessageToQueueAsync(string queueName, string message)
    {
        QueueClient queueClient = this.messagingFactory.CreateQueueClient(queueName);
        BrokeredMessage brokeredMessage = new BrokeredMessage(message);
        await queueClient.SendAsync(brokeredMessage);
    }

    public async Task SendMessageToTopicAsync(string topicName, string message)
    {
        TopicClient topicClient = this.messagingFactory.CreateTopicClient(topicName);
        BrokeredMessage brokeredMessage = new BrokeredMessage(message);
        await topicClient.SendAsync(brokeredMessage);
    }

    public void Dispose()
    {
        this.messagingFactory.Close();
    }
}