Merge pull request #12 from natureglobal/fix-panic

be careful handling pointers

firequeue.go

@@ -306,7 +306,7 @@ func (q *Queue) attemptToSendBatch(batch []*firehose.Record) error {
 			return nil
 		}
 		// Retry failed records.
-		if resp != nil && *resp.FailedPutCount > 0 {
+		if resp != nil && resp.FailedPutCount != nil && *resp.FailedPutCount > 0 {
 			q.successCount.Add(int64(len(batch)) - int64(*resp.FailedPutCount))
 			q.retryFailedRecords(batch, resp)
 			return nil
@@ -322,7 +322,7 @@ func (q *Queue) retryFailedRecords(batch []*firehose.Record, resp *firehose.PutR
 	retryRecords := make([]*firehose.Record, 0, *resp.FailedPutCount)
 
 	for i, record := range batch {
-		if resp.RequestResponses[i].ErrorCode != nil {
+		if resp.RequestResponses != nil && resp.RequestResponses[i] != nil && resp.RequestResponses[i].ErrorCode != nil {
 			q.retryCount.Add(1)
 			retryRecords = append(retryRecords, record)
 		}