User: juha
Date: 01/01/23 10:54:31
Modified: src/org/jboss/admin MetricsConnector.java
Log:
the metrics topic connector allows a selector to be set
Revision Changes Path
1.2 +14 -4 admin/src/org/jboss/admin/MetricsConnector.java
Index: MetricsConnector.java
===================================================================
RCS file: /products/cvs/ejboss/admin/src/org/jboss/admin/MetricsConnector.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- MetricsConnector.java 2000/12/17 20:11:22 1.1
+++ MetricsConnector.java 2001/01/23 18:54:31 1.2
@@ -4,6 +4,8 @@
import java.util.Properties;
import java.io.Serializable;
+import javax.rmi.PortableRemoteObject;
+
import javax.jms.MessageListener;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicConnection;
@@ -32,11 +34,10 @@
"topic/metrics";
private Properties jndiProperties = null;
+ private String messageSelector = null;
private transient Context namingContext = null;
-
private transient TopicConnectionFactory topicConnectionFactory = null;
-
private transient Topic topic = null;
/*
@@ -81,10 +82,11 @@
namingContext.lookup(topicConnectionFactoryName);
topic = (Topic)namingContext.lookup(topicName);
-
+
// Create a topic subscriber, attach a listener to it and start
// receiving messages from the topic session.
final boolean TRANSACTED_SESSION = false;
+ final boolean NO_LOCAL_MESSAGES = false;
TopicConnection connection = topicConnectionFactory.createTopicConnection();
TopicSession session = connection.createTopicSession(
@@ -92,12 +94,20 @@
Session.DUPS_OK_ACKNOWLEDGE
);
- TopicSubscriber subscriber = session.createSubscriber(topic);
+ TopicSubscriber subscriber = session.createSubscriber(
+ topic,
+ messageSelector,
+ NO_LOCAL_MESSAGES
+ );
subscriber.setMessageListener(listener);
connection.start();
}
+ public void setMessageSelector(String selector) {
+ this.messageSelector = selector;
+ }
+
public void setTopic(String topic) {
this.topicName = topic;
}
