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

Merge pull request #5 from markfisher/INT-2046

Browse Source 
INT-2046 added @ManagedAttribute to MessageStores
This commit is contained in:
Mark Fisher
2011-08-11 11:10:29 -07:00
parent bce562368c da2f275074
commit 5eaa57df11
3 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/store/GemfireMessageStore.java
View File

@@ -20,6 +20,7 @@ import java.util.UUID;
import org.springframework.integration.Message;
import org.springframework.integration.store.MessageStore;
import org.springframework.jmx.export.annotation.ManagedAttribute;
import org.springframework.util.Assert;
import com.gemstone.gemfire.cache.Region;
@@ -50,6 +51,7 @@ public class GemfireMessageStore implements MessageStore {
return this.region.remove(id);
}
@ManagedAttribute
public long getMessageCount() {
return this.region.size();
}

5
spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MongoDbMessageStore.java
View File

@@ -39,6 +39,7 @@ import org.springframework.integration.Message;
import org.springframework.integration.MessageHeaders;
import org.springframework.integration.message.GenericMessage;
import org.springframework.integration.store.MessageStore;
import org.springframework.jmx.export.annotation.ManagedAttribute;
import org.springframework.util.Assert;
import org.springframework.util.ClassUtils;
import org.springframework.util.StringUtils;
@@ -89,9 +90,9 @@ public class MongoDbMessageStore implements MessageStore, BeanClassLoaderAware {
return this.template.findOne(this.idQuery(id), Message.class, this.collectionName);
}
@ManagedAttribute
public long getMessageCount() {
// TODO: long to int
return new Long(this.template.getCollection(DEFAULT_COLLECTION_NAME).getCount()).intValue();
return this.template.getCollection(DEFAULT_COLLECTION_NAME).getCount();
}
public Message<?> removeMessage(UUID id) {

3
spring-integration-redis/src/main/java/org/springframework/integration/redis/store/RedisMessageStore.java
View File

@@ -38,6 +38,7 @@ import org.springframework.integration.store.AbstractMessageGroupStore;
import org.springframework.integration.store.MessageGroup;
import org.springframework.integration.store.MessageStore;
import org.springframework.integration.store.MessageStoreException;
import org.springframework.jmx.export.annotation.ManagedAttribute;
import org.springframework.util.Assert;
/**
@@ -105,7 +106,7 @@ public class RedisMessageStore extends AbstractMessageGroupStore implements Mess
}
}
@ManagedAttribute
public long getMessageCount() {
return redisTemplate.execute(new RedisCallback<Integer>() {
public Integer doInRedis(RedisConnection connection)