You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by bv...@apache.org on 2012/01/29 18:30:23 UTC
svn commit: r1237372 - /camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java

Author: bvahdat
Date: Sun Jan 29 17:30:22 2012
New Revision: 1237372

URL: http://svn.apache.org/viewvc?rev=1237372&view=rev
Log:
Polished.

Modified:
    camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java

Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java?rev=1237372&r1=1237371&r2=1237372&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/management/mbean/JMXNotificationTraceEventHandler.java Sun Jan 29 17:30:22 2012
@@ -43,17 +43,14 @@ public final class JMXNotificationTraceE
         this.tracer = tracer;
     }
 
-    @SuppressWarnings("rawtypes")
-    public void traceExchangeOut(ProcessorDefinition node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange, Object traceState) throws Exception {
+    public void traceExchangeOut(ProcessorDefinition<?> node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange, Object traceState) throws Exception {
     }
 
-    @SuppressWarnings("rawtypes")
-    public Object traceExchangeIn(ProcessorDefinition node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange) throws Exception {
+    public Object traceExchangeIn(ProcessorDefinition<?> node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange) throws Exception {
         return null;
     }
 
-    @SuppressWarnings("rawtypes")
-    public void traceExchange(ProcessorDefinition node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange) throws Exception {
+    public void traceExchange(ProcessorDefinition<?> node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange) throws Exception {
         if (notificationSender != null && tracer.isJmxTraceNotifications()) {
             String body = MessageHelper.extractBodyForLogging(exchange.getIn(), "", false, true, tracer.getTraceBodySize());
             
@@ -61,7 +58,7 @@ public final class JMXNotificationTraceE
                 body = "";
             }
             String message = body.substring(0, Math.min(body.length(), MAX_MESSAGE_LENGTH));
-            Map tm = createTraceMessage(node, exchange, body);
+            Map<String, Object> tm = createTraceMessage(node, exchange, body);
 
             Notification notification = new Notification("TraceNotification", exchange.toString(), num++, System.currentTimeMillis(), message);
             notification.setUserData(tm);