Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

renaming MongoMessageStore to MongoDbMessageStore for consistency

Browse Source
This commit is contained in:
Mark Fisher
2011-08-05 10:13:56 -04:00
parent b727868306
commit 00ffa9c0a5
3 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoMessageStore.java → spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java
View File

@@ -48,8 +48,9 @@ import com.mongodb.DBObject;
/**
* @author Mark Fisher
* @author Oleg Zhurakousky
* @since 2.1
*/
public class MongoMessageStore implements MessageStore, BeanClassLoaderAware {
public class MongoDbMessageStore implements MessageStore, BeanClassLoaderAware {
private final static String DEFAULT_COLLECTION_NAME = "messages";
@@ -61,11 +62,11 @@ public class MongoMessageStore implements MessageStore, BeanClassLoaderAware {
private volatile ClassLoader classLoader = ClassUtils.getDefaultClassLoader();
public MongoMessageStore(MongoDbFactory mongoDbFactory) {
public MongoDbMessageStore(MongoDbFactory mongoDbFactory) {
this(mongoDbFactory, null);
}
public MongoMessageStore(MongoDbFactory mongoDbFactory, String collectionName) {
public MongoDbMessageStore(MongoDbFactory mongoDbFactory, String collectionName) {
Assert.notNull(mongoDbFactory, "mongoDbFactory must not be null");
MessageReadingMongoConverter converter = new MessageReadingMongoConverter(mongoDbFactory, new MongoMappingContext());
this.template = new MongoTemplate(mongoDbFactory, converter);

6
spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/MongoClaimCheckIntegrationTests.java → spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/MongoDbMessageStoreClaimCheckIntegrationTests.java
View File

@@ -33,13 +33,13 @@ import static org.junit.Assert.assertEquals;
/**
* @author Mark Fisher
*/
public class MongoClaimCheckIntegrationTests extends MongoDbAvailableTests{
public class MongoDbMessageStoreClaimCheckIntegrationTests extends MongoDbAvailableTests{
@Test
@MongoDbAvailable
public void stringPayload() throws Exception {
MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(new Mongo(), "test");
MongoMessageStore messageStore = new MongoMessageStore(mongoDbFactory);
MongoDbMessageStore messageStore = new MongoDbMessageStore(mongoDbFactory);
ClaimCheckInTransformer checkin = new ClaimCheckInTransformer(messageStore);
ClaimCheckOutTransformer checkout = new ClaimCheckOutTransformer(messageStore);
Message<?> originalMessage = MessageBuilder.withPayload("test1").build();
@@ -58,7 +58,7 @@ public class MongoClaimCheckIntegrationTests extends MongoDbAvailableTests{
@MongoDbAvailable
public void objectPayload() throws Exception {
MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(new Mongo(), "test");
MongoMessageStore messageStore = new MongoMessageStore(mongoDbFactory);
MongoDbMessageStore messageStore = new MongoDbMessageStore(mongoDbFactory);
ClaimCheckInTransformer checkin = new ClaimCheckInTransformer(messageStore);
ClaimCheckOutTransformer checkout = new ClaimCheckOutTransformer(messageStore);
Beverage payload = new Beverage();

6
spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/MongoMessageStoreTests.java → spring-integration-mongodb/src/test/java/org/springframework/integration/mongodb/store/MongoDbMessageStoreTests.java
View File

@@ -34,13 +34,13 @@ import com.mongodb.Mongo;
* @author Mark Fisher
* @author Oleg Zhurakousky
*/
public class MongoMessageStoreTests extends MongoDbAvailableTests{
public class MongoDbMessageStoreTests extends MongoDbAvailableTests{
@Test
@MongoDbAvailable
public void addGetWithStringPayload() throws Exception {
MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(new Mongo(), "test");
MongoMessageStore store = new MongoMessageStore(mongoDbFactory);
MongoDbMessageStore store = new MongoDbMessageStore(mongoDbFactory);
Message<?> messageToStore = MessageBuilder.withPayload("Hello").build();
store.addMessage(messageToStore);
Message<?> retrievedMessage = store.getMessage(messageToStore.getHeaders().getId());
@@ -54,7 +54,7 @@ public class MongoMessageStoreTests extends MongoDbAvailableTests{
@MongoDbAvailable
public void addGetWithObjectDefaultConstructorPayload() throws Exception {
MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(new Mongo(), "test");
MongoMessageStore store = new MongoMessageStore(mongoDbFactory);
MongoDbMessageStore store = new MongoDbMessageStore(mongoDbFactory);
Person p = new Person();
p.setFname("John");
p.setLname("Doe");