docs: public <T> QueuePublisher<T> createQueuePublisher(final String name, final PublisherCallback<T> messageCallback)
      {
          Preconditions.checkState(connectionFactory != null, "connection factory was never injected!");
          return new QueuePublisher<T>(connectionFactory, amqpConfig, name, messageCallback);
      }