consumer/src/main/java/net/devfront/aws/sqslambda/consumer/service/impl/DequeueServiceImpl.java
/**
     * Handle each individual message.
     *
     * @param message {@link Message}
     */
Handle each individual message.
@param message  Message
Handle each individual message . @param message Message
private void handleMessage(Message message) {
        Event event = getEventFromMessage(message);
        String payload = getPayloadFromEvent(event);
        if (payload != null && !payload.isEmpty()) {
            invokeWorkerLambda(payload);
        }
        queueService.deleteMessage(message);
    }
private void handleMessage ( Message message ) { Event event = getEventFromMessage ( message ) ; String payload = getPayloadFromEvent ( event ) ; if ( payload != null && ! payload . isEmpty ( ) ) { invokeWorkerLambda ( payload ) ; } queueService . deleteMessage ( message ) ; }
Handle each individual message.
Handle each individual message .