code: public TopicProducer<String> createTopicTextMessageProducer(final String topic)
      {
          Preconditions.checkState(connectionFactory != null, "connection factory was never injected!");
          return new TopicProducer<String>(connectionFactory, jmsConfig, topic, new TextMessageProducerCallback());
      }
docs: Creates a new {@link TopicProducer}. The producer accepts strings and sends them as a text message.