diff --git a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreTests.java b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreTests.java index e31e52887a..dbea45e4a8 100644 --- a/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreTests.java +++ b/spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2010 the original author or authors. + * Copyright 2002-2011 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -152,8 +152,20 @@ public class JdbcMessageStoreTests { Message saved = messageStore.addMessage(message); Message copy = MessageBuilder.fromMessage(saved).build(); Message result = messageStore.addMessage(copy); + assertEquals(copy, result); + assertEquals(saved, result); + assertNotNull(messageStore.getMessage(saved.getHeaders().getId())); + } + + @Test + @Transactional + public void testAddAndUpdateWithChange() throws Exception { + Message message = MessageBuilder.withPayload("foo").build(); + Message saved = messageStore.addMessage(message); + Message copy = MessageBuilder.fromMessage(saved).setHeader("newHeader", 1).build(); + Message result = messageStore.addMessage(copy); assertNotSame(copy, result); - assertThat(saved, sameExceptIgnorableHeaders(result, JdbcMessageStore.CREATED_DATE_KEY)); + assertThat(saved, sameExceptIgnorableHeaders(result, JdbcMessageStore.CREATED_DATE_KEY, "newHeader")); assertNotNull(messageStore.getMessage(saved.getHeaders().getId())); }