You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2008/09/12 09:56:41 UTC
svn commit: r694638 -
/servicemix/smx4/nmr/trunk/nmr/management/src/main/java/org/apache/servicemix/nmr/management/ManagementEndpointRegistry.java
Author: gnodet
Date: Fri Sep 12 00:56:41 2008
New Revision: 694638
URL: http://svn.apache.org/viewvc?rev=694638&view=rev
Log:
SMX4NMR-47: A full stack trace is displayed when NPE occurs in the ManagementEndpointRegistry when endpoints are not registered
Modified:
servicemix/smx4/nmr/trunk/nmr/management/src/main/java/org/apache/servicemix/nmr/management/ManagementEndpointRegistry.java
Modified: servicemix/smx4/nmr/trunk/nmr/management/src/main/java/org/apache/servicemix/nmr/management/ManagementEndpointRegistry.java
URL: http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/nmr/management/src/main/java/org/apache/servicemix/nmr/management/ManagementEndpointRegistry.java?rev=694638&r1=694637&r2=694638&view=diff
==============================================================================
--- servicemix/smx4/nmr/trunk/nmr/management/src/main/java/org/apache/servicemix/nmr/management/ManagementEndpointRegistry.java (original)
+++ servicemix/smx4/nmr/trunk/nmr/management/src/main/java/org/apache/servicemix/nmr/management/ManagementEndpointRegistry.java Fri Sep 12 00:56:41 2008
@@ -94,7 +94,11 @@
String id = ((InternalExchange) exchange).getSource().getId();
LOG.info("Source endpoint: " + id + " (known endpoints: " + endpoints + ")");
ManagedEndpoint me = endpoints.get(id);
- me.incrementOutbound();
+ if (me == null) {
+ LOG.warn("No managed endpoint registered with id: " + id);
+ } else {
+ me.incrementOutbound();
+ }
}
} catch (Throwable t) {
LOG.warn("Caught exception while processing exchange: " + t, t);
@@ -112,7 +116,11 @@
String id = ((InternalExchange) exchange).getDestination().getId();
LOG.info("Dest endpoint: " + id + " (known endpoints: " + endpoints + ")");
ManagedEndpoint me = endpoints.get(id);
- me.incrementInbound();
+ if (me == null) {
+ LOG.warn("No managed endpoint registered with id: " + id);
+ } else {
+ me.incrementInbound();
+ }
}
} catch (Throwable t) {
LOG.warn("Caught exception while processing exchange: " + t, t);