try {
    producer.send(createMessage(session, i));
    System.out.println("Message: " + i);
  } catch (Exception e) {
    Thread.sleep(1000);
    producer.send(createMessage(session, i));
  }

int numberOfRetries = 0;

while (numberOfRetries < maxRetries) {
   try {
      producer.send(msg);
      return;
   } catch (JMSException ex) {
      numberOfRetries++;
   }
}
// this is an error - failover was not succeed
throw new Exception("FAILURE - MaxRetry reached");