public void consumeStringMessage(String messageString) throws IOException {
    logger.info("Consuming message '{}'", messageString);
    UserCreatedMessage message = objectMapper.readValue(messageString, UserCreatedMessage.class);
    Validator validator = Validation.buildDefaultValidatorFactory().getValidator();
    Set<ConstraintViolation<UserCreatedMessage>> violations = validator.validate(message);
    if(!violations.isEmpty()){
      throw new ConstraintViolationException(violations);
    }
    // pass message into business use case
  }
@Test
	@PactVerification("userCreatedMessagePact")
	public void verifyCreatePersonPact() throws IOException {
		messageConsumer.consumeStringMessage(new String(this.currentMessage));
	}