public void bootstrapMessagingSystem(){
    try{
      messagingSystem = new MessagingSystem(ACTIVEMQ_BROKER_URI, ACTIVEMQ_BROKER_PORT);
      messagingSystem.createConnection();
      messagingSystem.createSession();
      //TODO: handle topics, not just queues
      messagingSystem.createDestination(ACTIVEMQ_DESTINATION_NAME);
      messagingSystem.createProducer();
      System.out.println("SolrToActiveMQComponent: Bootstrapping messaging system done.");
      messagingSystem.validateConnection();
    }
    catch (JMSException e){
      System.out.println("SolrToActiveMQComponent: Bootstrapping messaging system failed.\n" + e);
      messagingSystem.invalidateConnection();
    }
  }
public void bootstrapMessagingSystem(){
    try{
      messagingSystem = new MessagingSystem(ACTIVEMQ_BROKER_URI, ACTIVEMQ_BROKER_PORT);
      messagingSystem.createConnection();
      messagingSystem.createSession();
     
      messagingSystem.createDestination(ACTIVEMQ_DESTINATION_NAME);
      messagingSystem.createProducer();
      System.out.println("SolrToActiveMQComponent: Bootstrapping messaging system done.");
      messagingSystem.validateConnection();
    }
    catch (JMSException e){
      System.out.println("SolrToActiveMQComponent: Bootstrapping messaging system failed.\n" + e);
      messagingSystem.invalidateConnection();
    }
  }
public void bootstrapmessagingsystem(){ try{ messagingsystem = new messagingsystem(activemq_broker_uri, activemq_broker_port); messagingsystem.createconnection(); messagingsystem.createsession(); messagingsystem.createdestination(activemq_destination_name); messagingsystem.createproducer(); system.out.println("solrtoactivemqcomponent: bootstrapping messaging system done."); messagingsystem.validateconnection(); } catch (jmsexception e){ system.out.println("solrtoactivemqcomponent: bootstrapping messaging system failed.\n" + e); messagingsystem.invalidateconnection(); } }