code: public TopicConsumer createTopicTextMessageListener(final String topic, final ConsumerCallback<String> messageCallback)
      {
          Preconditions.checkState(connectionFactory != null, "connection factory was never injected!");
          return new TopicConsumer(connectionFactory, jmsConfig, topic, new TextMessageConsumerCallback(messageCallback));
      }
docs: Creates a new {@link TopicConsumer}. For every text message received, the callback
  is invoked with the contents of the text message as string.