public void subscribe(AWSIotMessage message) throws AWSIotException {
  try {
    subscribeTopic(message);
  }
 catch (  AwsIotRetryableException e) {
    if (client.getMaxOfflineQueueSize() > 0 && subscribeQueue.size() < client.getMaxOfflineQueueSize()) {
      subscribeQueue.add(message);
    }
 else {
      LOGGER.info("Failed to subscribe to " + message.getTopic());
      throw new AWSIotException(e);
    }
  }
}

public void subscribe ( AWSIotMessage message ) throws AWSIotException { try { subscribeTopic ( message ) ; } catch ( AwsIotRetryableException e ) { if ( client . getMaxOfflineQueueSize ( ) > 0 && subscribeQueue . size ( ) < client . getMaxOfflineQueueSize ( ) ) { subscribeQueue . add ( message ) ; } else { LOGGER . info ( "Failed to subscribe to " + message . getTopic ( ) ) ; throw new AWSIotException ( e ) ; } } }
the actual subscribe method exposed by this class .
