import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
@Test
@DirtiesContext
public void testInvalidTaskName() throws Exception {
	String exceptionMessage = null;
	final String ERROR_MESSAGE =
			"Could not find task definition named " + TASK_NAME;
	VndErrors errors = new VndErrors("message", ERROR_MESSAGE, new Link("ref"));
	Mockito.doThrow(new DataFlowClientException(errors))
			.when(this.taskOperations)
			.launch(Matchers.anyString(),
					(Map<String, String>) Matchers.any(),
					(List<String>) Matchers.any());
	TaskLauncherTasklet taskLauncherTasklet = getTaskExecutionTasklet();
	ChunkContext chunkContext = chunkContext();
	try {
		taskLauncherTasklet.execute(null, chunkContext);
	}
	catch (DataFlowClientException dfce) {
		exceptionMessage = dfce.getMessage();
	}
	assertEquals(ERROR_MESSAGE+"\n", exceptionMessage);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Log the exception message at warn level and stack trace as trace level.
 * Return response status HttpStatus.NOT_FOUND
 */
@ExceptionHandler({NoSuchAppRegistrationException.class,
		NoSuchTaskDefinitionException.class,
		NoSuchTaskExecutionException.class,
		NoSuchJobExecutionException.class,
		NoSuchJobInstanceException.class,
		NoSuchJobException.class,
		NoSuchStepExecutionException.class,
		MetricsMvcEndpoint.NoSuchMetricException.class})
@ResponseStatus(HttpStatus.NOT_FOUND)
@ResponseBody
public VndErrors onNotFoundException(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Client did not formulate a correct request.
 * Log the exception message at warn level and stack trace as trace level.
 * Return response status HttpStatus.BAD_REQUEST (400).
 */
@ExceptionHandler({
	MissingServletRequestParameterException.class,
	MethodArgumentTypeMismatchException.class,
	InvalidStreamDefinitionException.class
})
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ResponseBody
public VndErrors onClientGenericBadRequest(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * The exception handler is trigger if a JSR303 {@link ConstraintViolationException}
 * is being raised.
 *
 * Log the exception message at warn level and stack trace as trace level.
 * Return response status HttpStatus.BAD_REQUEST (400).
 */
@ExceptionHandler({ConstraintViolationException.class})
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ResponseBody
public VndErrors onConstraintViolationException(ConstraintViolationException e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}

	final StringBuilder errorMessage = new StringBuilder();
	boolean first = true;
	for (ConstraintViolation<?> violation : e.getConstraintViolations()) {
		if (!first) {
			errorMessage.append("; ");
		}
		errorMessage.append(violation.getMessage());
		first = false;
	}

	return new VndErrors(logref, errorMessage.toString());
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Log the exception message at warn level and stack trace as trace level. Return
 * response status HttpStatus.NOT_FOUND
 *
 * @param e one of the exceptions, {@link NoSuchStreamDefinitionException},
 * {@link NoSuchAppRegistrationException}, {@link NoSuchTaskDefinitionException},
 * {@link NoSuchTaskExecutionException}, {@link NoSuchJobExecutionException},
 * {@link NoSuchJobInstanceException}, {@link NoSuchJobException},
 * {@link NoSuchStepExecutionException},
 * {@link MetricsMvcEndpoint.NoSuchMetricException}, {@link NoSuchAppException}, or
 * {@link NoSuchAppInstanceException}
 * @return the error response in JSON format with media type
 * application/vnd.error+json
 */
@ExceptionHandler({ NoSuchStreamDefinitionException.class, NoSuchAppRegistrationException.class,
		NoSuchTaskDefinitionException.class, NoSuchTaskExecutionException.class, NoSuchJobExecutionException.class,
		NoSuchJobInstanceException.class, NoSuchJobException.class, NoSuchStepExecutionException.class,
		MetricsMvcEndpoint.NoSuchMetricException.class, NoSuchAppException.class,
		NoSuchAppInstanceException.class, ApplicationDoesNotExistException.class })
@ResponseStatus(HttpStatus.NOT_FOUND)
@ResponseBody
public VndErrors onNotFoundException(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * The exception handler is trigger if a JSR303 {@link ConstraintViolationException}
 * is being raised.
 * <p>
 * Log the exception message at warn level and stack trace as trace level. Return
 * response status HttpStatus.BAD_REQUEST (400).
 *
 * @param e the exceptions, {@link ConstraintViolationException}
 * @return the error response in JSON format with media type
 * application/vnd.error+json
 */
@ExceptionHandler({ ConstraintViolationException.class })
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ResponseBody
public VndErrors onConstraintViolationException(ConstraintViolationException e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}

	final StringBuilder errorMessage = new StringBuilder();
	boolean first = true;
	for (ConstraintViolation<?> violation : e.getConstraintViolations()) {
		if (!first) {
			errorMessage.append("; ");
		}
		errorMessage.append(violation.getMessage());
		first = false;
	}

	return new VndErrors(logref, errorMessage.toString());
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
@Override
public String getMessage() {
	StringBuilder builder = new StringBuilder();
	for (VndErrors.VndError e : vndErrors) {
		builder.append(e.getMessage()).append('\n');
	}
	return builder.toString();
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
@Override
public void handleError(ClientHttpResponse response) throws IOException {
	VndErrors error = null;
	try {
		error = errorExtractor.extractData(response);
	}
	catch (Exception e) {
		super.handleError(response);
	}
	throw new DataFlowClientException(error);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Handles the general error case. Log track trace at error level
 */
@ExceptionHandler(Exception.class)
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
@ResponseBody
public VndErrors onException(Exception e) {
	logger.error("Caught exception while handling a request", e);
	String logref = e.getClass().getSimpleName();
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Log the exception message at warn level and stack trace as trace level.
 * Return response status HttpStatus.CONFLICT
 */
@ExceptionHandler({
		AppAlreadyRegisteredException.class,
		DuplicateTaskException.class})
@ResponseStatus(HttpStatus.CONFLICT)
@ResponseBody
public VndErrors onConflictException(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
@ResponseBody
@ExceptionHandler({Exception.class})
@ResponseStatus(HttpStatus.BAD_REQUEST)
/**Reports the given Exception with messages localized according to the given Locale of the web request.*/
VndErrors reportException(final Exception ex, final Locale requestLocale) {
	//prepare messages for client with the Locale of the request:
	/** Message texts for exceptions. */
	final ResourceBundle requestResourceBundle = ResourceBundle.getBundle(BASE_NAME, requestLocale);
	final StringBuffer clientMessages = new StringBuffer();
	multex.Msg.printMessages(clientMessages, ex, requestResourceBundle);
	final String clientMesagesString = clientMessages.toString();

	//prepare log report with messages and stack trace:
	final StringBuffer serverMessages = new StringBuffer();
	serverMessages.append("Processing REST request threw exception:\n");
	final Locale defaultLocale = Locale.getDefault();
	final ResourceBundle defaultResourceBundle = ResourceBundle.getBundle(BASE_NAME, defaultLocale);
	if(!defaultResourceBundle.equals(requestResourceBundle)) {
		serverMessages.append(clientMesagesString);
		serverMessages.append("\n-----\n");
	}
	Msg.printReport(serverMessages, ex, defaultResourceBundle);
	
	//log the report on the server:
	log.error(serverMessages.toString());
	//respond with localized messages to the client:
	return new VndErrors("error", clientMesagesString);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
@ResponseBody
@ExceptionHandler
@ResponseStatus(HttpStatus.FORBIDDEN)
VndErrors methodArgumentTypeMismatchExceptionHandler(MethodArgumentTypeMismatchException ex) {
    Throwable th = ex;
    while (th != null) {
        if (th instanceof InvalidAccessException) {
            return invalidAccessExceptionHandler((InvalidAccessException) th);
        } else {
            th = th.getCause();
        }
    }
    throw ex;
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Handles the general error case. Log track trace at error level
 *
 * @param e the exception not handled by other exception handler methods
 * @return the error response in JSON format with media type
 * application/vnd.error+json
 */
@ExceptionHandler(Exception.class)
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
@ResponseBody
public VndErrors onException(Exception e) {
	logger.error("Caught exception while handling a request", e);
	String logref = e.getClass().getSimpleName();
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Log the exception message at warn level and stack trace as trace level. Return
 * response status HttpStatus.CONFLICT
 *
 * @param e one of the exceptions, {@link AppAlreadyRegisteredException},
 * {@link DuplicateStreamDefinitionException}, {@link DuplicateTaskException},
 * {@link StreamAlreadyDeployedException}, {@link StreamAlreadyDeployingException}, or
 * {@link StreamAlreadyDeployingException}
 * @return the error response in JSON format with media type
 * application/vnd.error+json
 */
@ExceptionHandler({ AppAlreadyRegisteredException.class, DuplicateStreamDefinitionException.class,
		DuplicateTaskException.class, StreamAlreadyDeployedException.class, StreamAlreadyDeployingException.class })
@ResponseStatus(HttpStatus.CONFLICT)
@ResponseBody
public VndErrors onConflictException(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Log the exception message at warn level and stack trace as trace level. Return
 * response status HttpStatus.UNPROCESSABLE_ENTITY
 *
 * @param e one of the exceptions, {@link JobNotRestartableException} or
 * {@link JobExecutionNotRunningException}
 * @return the error response in JSON format with media type
 * application/vnd.error+json
 */
@ExceptionHandler({ JobNotRestartableException.class, JobExecutionNotRunningException.class })
@ResponseStatus(HttpStatus.UNPROCESSABLE_ENTITY)
@ResponseBody
public VndErrors onUnprocessableEntityException(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * Client did not formulate a correct request. Log the exception message at warn level
 * and stack trace as trace level. Return response status HttpStatus.BAD_REQUEST
 * (400).
 *
 * @param e one of the exceptions, {@link MissingServletRequestParameterException},
 * {@link UnsatisfiedServletRequestParameterException},
 * {@link MethodArgumentTypeMismatchException}, or
 * {@link InvalidStreamDefinitionException}
 * @return the error response in JSON format with media type
 * application/vnd.error+json
 */
@ExceptionHandler({ MissingServletRequestParameterException.class, HttpMessageNotReadableException.class,
		UnsatisfiedServletRequestParameterException.class, MethodArgumentTypeMismatchException.class,
		InvalidStreamDefinitionException.class })
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ResponseBody
public VndErrors onClientGenericBadRequest(Exception e) {
	String logref = logWarnLevelExceptionMessage(e);
	if (logger.isTraceEnabled()) {
		logTraceLevelStrackTrace(e);
	}
	String msg = getExceptionMessage(e);
	return new VndErrors(logref, msg);
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * 
 * 
 * @param ex
 * @return
 */
@ResponseBody
@ExceptionHandler(Exception.class)
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
VndErrors internalServerErrorHandler(Exception ex) {
	return new VndErrors(HttpStatus.INTERNAL_SERVER_ERROR.getReasonPhrase(), ex.getLocalizedMessage());
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * 
 * 
 * @param ex
 * @return
 */
@ResponseBody
@ExceptionHandler(EntityNotUpdatedException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
VndErrors entityNotUpdatedExceptionHandler(EntityNotUpdatedException ex) {
	return new VndErrors(HttpStatus.BAD_REQUEST.getReasonPhrase(), ex.getLocalizedMessage());
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * 
 * 
 * @param ex
 * @return
 */
@ResponseBody
@ExceptionHandler(DuplicateKeyException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
VndErrors duplicateFieldHandler(DuplicateKeyException ex) {
	return new VndErrors(HttpStatus.BAD_REQUEST.getReasonPhrase(), ex.getMostSpecificCause().getLocalizedMessage());
}
 

import org.springframework.hateoas.VndErrors; //导入依赖的package包/类
/**
 * 
 * 
 * @param ex
 * @return
 */
@ResponseBody
@ExceptionHandler(Exception.class)
@ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
VndErrors internalServerErrorHandler(Exception ex) {
    return new VndErrors(HttpStatus.INTERNAL_SERVER_ERROR.getReasonPhrase(), ex.getLocalizedMessage());
}