//TODO: handle topics, not just queues
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();
    }
  }
messagingSystem.createConnection();
messagingSystem.createSession();
//TODO: handle topics, not just queues
messagingSystem.createDestination(ACTIVEMQ_DESTINATION_NAME);
messagingSystem.createProducer();
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();
//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();
}
}