You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2012/05/17 06:14:58 UTC
svn commit: r1339473 - in /camel/trunk:
components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java
platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/EndpointList.java
Author: ningjiang
Date: Thu May 17 04:14:57 2012
New Revision: 1339473
URL: http://svn.apache.org/viewvc?rev=1339473&view=rev
Log:
Fixed the CS errors
Modified:
camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java
camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/EndpointList.java
Modified: camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java?rev=1339473&r1=1339472&r2=1339473&view=diff
==============================================================================
--- camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java (original)
+++ camel/trunk/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdConsumer.java Thu May 17 04:14:57 2012
@@ -84,9 +84,9 @@ public class CometdConsumer extends Defa
addService(channel, "push");
}
- private CometdBinding createBinding(BayeuxServerImpl bayeux) {
- boolean enableSessionHeaders = endpoint == null ? false : endpoint.areSessionHeadersEnabled();
- return new CometdBinding(bayeux, enableSessionHeaders);
+ private CometdBinding createBinding(BayeuxServerImpl bayeux) {
+ boolean enableSessionHeaders = endpoint == null ? false : endpoint.areSessionHeadersEnabled();
+ return new CometdBinding(bayeux, enableSessionHeaders);
}
public void push(ServerSession remote, String channelName, ServerMessage cometdMessage, String messageId) throws Exception {
Modified: camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/EndpointList.java
URL: http://svn.apache.org/viewvc/camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/EndpointList.java?rev=1339473&r1=1339472&r2=1339473&view=diff
==============================================================================
--- camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/EndpointList.java (original)
+++ camel/trunk/platforms/karaf/commands/src/main/java/org/apache/camel/karaf/commands/EndpointList.java Thu May 17 04:14:57 2012
@@ -16,6 +16,8 @@
*/
package org.apache.camel.karaf.commands;
+import java.util.List;
+
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.ServiceStatus;
@@ -23,8 +25,6 @@ import org.apache.camel.StatefulService;
import org.apache.felix.gogo.commands.Command;
import org.apache.karaf.shell.console.OsgiCommandSupport;
-import java.util.List;
-
/**
* List the Camel endpoints available in the Karaf instance.
*/
@@ -47,7 +47,7 @@ public class EndpointList extends OsgiCo
for (CamelContext camelContext : camelContexts) {
List<Endpoint> endpoints = (List<Endpoint>) camelContext.getEndpoints();
for (Endpoint endpoint : endpoints) {
- System.out.println(String.format(OUTPUT_FORMAT, camelContext.getName(), endpoint.getEndpointUri(), getState(endpoint)));
+ System.out.println(String.format(OUTPUT_FORMAT, camelContext.getName(), endpoint.getEndpointUri(), getState(endpoint)));
}
}