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)));
}
}