svn commit: r922484 - /servicemix/smx4/nmr/trunk/nmr/commands/src/main/java/org/apache/servicemix/nmr/commands/ListCommand.java

[ff...@apache.org]

Author: ffang
Date: Sat Mar 13 05:58:47 2010
New Revision: 922484

URL: http://svn.apache.org/viewvc?rev=922484&view=rev
Log:
[SMX4NMR-183]nmr:list command can't list all endpoint registered to the EndpointRegister.

Modified:
    servicemix/smx4/nmr/trunk/nmr/commands/src/main/java/org/apache/servicemix/nmr/commands/ListCommand.java

Modified: servicemix/smx4/nmr/trunk/nmr/commands/src/main/java/org/apache/servicemix/nmr/commands/ListCommand.java
URL: http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/nmr/commands/src/main/java/org/apache/servicemix/nmr/commands/ListCommand.java?rev=922484&r1=922483&r2=922484&view=diff
==============================================================================
--- servicemix/smx4/nmr/trunk/nmr/commands/src/main/java/org/apache/servicemix/nmr/commands/ListCommand.java (original)
+++ servicemix/smx4/nmr/trunk/nmr/commands/src/main/java/org/apache/servicemix/nmr/commands/ListCommand.java Sat Mar 13 05:58:47 2010
@@ -16,7 +16,10 @@
  */
 package org.apache.servicemix.nmr.commands;
 
+import java.util.Set;
+
 import org.apache.servicemix.nmr.api.Endpoint;
+import org.apache.servicemix.nmr.api.NMR;
 import org.apache.felix.gogo.commands.Command;
 import org.osgi.framework.ServiceReference;
 
@@ -29,11 +32,15 @@ public class ListCommand extends NmrComm
     protected Object doExecute() throws Exception {
         System.out.println("Endpoints");
         System.out.println("---------");
-        ServiceReference[] references = getBundleContext().getAllServiceReferences(Endpoint.class.getName(), null);
-        if (references != null) {
-            for (ServiceReference ref : references) {
-                String name = (String) ref.getProperty(Endpoint.NAME);
-                System.out.println(name);
+        ServiceReference reference = getBundleContext().getServiceReference(NMR.class.getName());
+        if (reference != null) {
+            NMR nmr = (NMR)getBundleContext().getService(reference);
+            if (nmr != null) {
+            	Set<Endpoint> endpoints = nmr.getEndpointRegistry().getServices();
+            	for (Endpoint endpoint : endpoints) {
+            		String name = (String)nmr.getEndpointRegistry().getProperties(endpoint).get(Endpoint.NAME);
+            		System.out.println(name);
+            	}
             }
         }
         System.out.println();