Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

http://issues.apache.org/activemq/browse/AMQ-754 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414652 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-06-15 18:42:52 +00:00
parent f6041bb839
commit 944f9d60d7
2 changed files with 78 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
View File

@ -13,11 +13,13 @@
*/
package org.apache.activemq.broker.jmx;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Iterator;
import java.util.Map;
import javax.jms.Connection;
import javax.jms.InvalidSelectorException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.management.openmbean.CompositeData;
@ -35,8 +37,11 @@ import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ActiveMQMessage;
import org.apache.activemq.command.ActiveMQTextMessage;
import org.apache.activemq.command.Message;
import org.apache.activemq.filter.BooleanExpression;
import org.apache.activemq.filter.MessageEvaluationContext;
import org.apache.activemq.selector.SelectorParser;
public class DestinationView {
public class DestinationView implements DestinationViewMBean {
protected final Destination destination;
protected final ManagedRegionBroker broker;
@ -91,27 +96,80 @@ public class DestinationView {
}
public CompositeData[] browse() throws OpenDataException{
try {
return browse(null);
} catch (InvalidSelectorException e) {
// should not happen.
throw new RuntimeException(e);
}
}
public CompositeData[] browse(String selector) throws OpenDataException, InvalidSelectorException{
Message[] messages=destination.browse();
CompositeData c[]=new CompositeData[messages.length];
for(int i=0;i<c.length;i++){
ArrayList c = new ArrayList();
MessageEvaluationContext ctx = new MessageEvaluationContext();
ctx.setDestination(destination.getActiveMQDestination());
BooleanExpression selectorExpression = selector==null ? null : new SelectorParser().parse(selector);
for(int i=0;i<messages.length;i++){
try{
c[i]=OpenTypeSupport.convert(messages[i]);
}catch(Throwable e){
if( selectorExpression==null ) {
c.add(OpenTypeSupport.convert(messages[i]));
} else {
ctx.setMessageReference(messages[i]);
if ( selectorExpression.matches(ctx) ) {
c.add(OpenTypeSupport.convert(messages[i]));
}
}
} catch(Throwable e) {
e.printStackTrace();
}
}
return c;
CompositeData rc[]=new CompositeData[c.size()];
c.toArray(rc);
return rc;
}
public TabularData browseAsTable() throws OpenDataException{
try {
return browseAsTable(null);
} catch (InvalidSelectorException e) {
throw new RuntimeException(e);
}
}
public TabularData browseAsTable(String selector) throws OpenDataException, InvalidSelectorException{
OpenTypeFactory factory=OpenTypeSupport.getFactory(ActiveMQMessage.class);
Message[] messages=destination.browse();
CompositeType ct=factory.getCompositeType();
TabularType tt=new TabularType("MessageList","MessageList",ct,new String[] { "JMSMessageID" });
TabularDataSupport rc=new TabularDataSupport(tt);
MessageEvaluationContext ctx = new MessageEvaluationContext();
ctx.setDestination(destination.getActiveMQDestination());
BooleanExpression selectorExpression = selector==null ? null : new SelectorParser().parse(selector);
for(int i=0;i<messages.length;i++){
rc.put(new CompositeDataSupport(ct,factory.getFields(messages[i])));
try {
if( selectorExpression==null ) {
rc.put(new CompositeDataSupport(ct,factory.getFields(messages[i])));
} else {
ctx.setMessageReference(messages[i]);
if ( selectorExpression.matches(ctx) ) {
rc.put(new CompositeDataSupport(ct,factory.getFields(messages[i])));
}
}
rc.put(new CompositeDataSupport(ct,factory.getFields(messages[i])));
} catch(Throwable e) {
e.printStackTrace();
}
}
return rc;
}

13
activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java
View File

@ -18,6 +18,7 @@ package org.apache.activemq.broker.jmx;
import java.util.Map;
import javax.jms.InvalidSelectorException;
import javax.management.openmbean.CompositeData;
import javax.management.openmbean.OpenDataException;
import javax.management.openmbean.TabularData;
@ -65,6 +66,18 @@ public interface DestinationViewMBean {
*/
public TabularData browseAsTable() throws OpenDataException;
/**
* @return An array of all the messages in the destination's queue.
* @throws InvalidSelectorException
*/
public CompositeData[] browse(String selector) throws OpenDataException, InvalidSelectorException;
/**
* @return A list of all the messages in the destination's queue.
* @throws InvalidSelectorException
*/
public TabularData browseAsTable(String selector) throws OpenDataException, InvalidSelectorException;
/**
* Sends a TextMesage to the destination.
* @param body the text to send