|
51 | 51 | import com.amazonaws.services.pinpoint.model.EventItemResponse; |
52 | 52 | import com.amazonaws.services.pinpoint.model.EventsBatch; |
53 | 53 | import com.amazonaws.services.pinpoint.model.EventsRequest; |
| 54 | +import com.amazonaws.services.pinpoint.model.ItemResponse; |
54 | 55 | import com.amazonaws.services.pinpoint.model.PublicEndpoint; |
55 | 56 | import com.amazonaws.services.pinpoint.model.PutEventsRequest; |
56 | 57 | import com.amazonaws.services.pinpoint.model.PutEventsResult; |
@@ -436,12 +437,28 @@ private void submitEventsAndEndpoint(final JSONArray eventArray, |
436 | 437 | } |
437 | 438 |
|
438 | 439 | private void processEndpointResponse(EndpointProfile endpoint, PutEventsResult resultResponse) { |
439 | | - final EndpointItemResponse endpointItemResponse = resultResponse |
| 440 | + final Map<String, ItemResponse> results = resultResponse |
440 | 441 | .getEventsResponse() |
441 | | - .getResults() |
| 442 | + .getResults(); |
| 443 | + if (results == null || results.isEmpty()) { |
| 444 | + log.error("PutEventsResult is empty!"); |
| 445 | + return; |
| 446 | + } |
| 447 | + |
| 448 | + if (endpoint.getEndpointId().isEmpty()) { |
| 449 | + log.error("EndpointId is missing!"); |
| 450 | + return; |
| 451 | + } |
| 452 | + |
| 453 | + final EndpointItemResponse endpointItemResponse = results |
442 | 454 | .get(endpoint.getEndpointId()) |
443 | 455 | .getEndpointItemResponse(); |
444 | | - if(202 == endpointItemResponse.getStatusCode()) { |
| 456 | + if (endpointItemResponse == null) { |
| 457 | + log.error("EndPointItemResponse is null!"); |
| 458 | + return; |
| 459 | + } |
| 460 | + |
| 461 | + if (202 == endpointItemResponse.getStatusCode()) { |
445 | 462 | log.info("EndpointProfile updated successfully."); |
446 | 463 | } else { |
447 | 464 | log.error("AmazonServiceException occurred during endpoint update: " + |
|
0 commit comments