camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r611552 - in /activemq/camel/trunk: components/camel-amqp/ components/camel-csv/ components/camel-groovy/ components/camel-jcr/ components/camel-jhc/src/main/java/org/apache/camel/component/jhc/ components/camel-xstream/ examples/camel-exam...
Date Sun, 13 Jan 2008 09:08:18 GMT
Author: ningjiang
Date: Sun Jan 13 01:08:11 2008
New Revision: 611552

URL: http://svn.apache.org/viewvc?rev=611552&view=rev
Log:
Updated the svn:ignore property

Modified:
    activemq/camel/trunk/components/camel-amqp/   (props changed)
    activemq/camel/trunk/components/camel-csv/   (props changed)
    activemq/camel/trunk/components/camel-groovy/   (props changed)
    activemq/camel/trunk/components/camel-jcr/   (props changed)
    activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcComponent.java
    activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcEndpoint.java
    activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
    activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcServerEngine.java
    activemq/camel/trunk/components/camel-xstream/   (props changed)
    activemq/camel/trunk/examples/camel-example-cxf/   (props changed)
    activemq/camel/trunk/examples/camel-example-osgi/   (props changed)
    activemq/camel/trunk/examples/camel-example-spring-xquery/   (props changed)

Propchange: activemq/camel/trunk/components/camel-amqp/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Propchange: activemq/camel/trunk/components/camel-csv/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Propchange: activemq/camel/trunk/components/camel-groovy/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Propchange: activemq/camel/trunk/components/camel-jcr/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Modified: activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcComponent.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcComponent.java?rev=611552&r1=611551&r2=611552&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcComponent.java
(original)
+++ activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcComponent.java
Sun Jan 13 01:08:11 2008
@@ -59,10 +59,10 @@
 
     public JhcComponent() {
         params = new BasicHttpParams(null)
-            .setIntParameter(HttpConnectionParams.SO_TIMEOUT, 5000)
-            .setIntParameter(HttpConnectionParams.CONNECTION_TIMEOUT, 10000)
+            .setIntParameter(HttpConnectionParams.SO_TIMEOUT, 15000)
+            .setIntParameter(HttpConnectionParams.CONNECTION_TIMEOUT, 20000)
             .setIntParameter(HttpConnectionParams.SOCKET_BUFFER_SIZE, 8 * 1024)
-            .setBooleanParameter(HttpConnectionParams.STALE_CONNECTION_CHECK, false)
+            .setBooleanParameter(HttpConnectionParams.STALE_CONNECTION_CHECK, true)
             .setBooleanParameter(HttpConnectionParams.TCP_NODELAY, true)
             .setParameter(HttpProtocolParams.USER_AGENT, "Camel-JhcComponent/1.1");
     }

Modified: activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcEndpoint.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcEndpoint.java?rev=611552&r1=611551&r2=611552&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcEndpoint.java
(original)
+++ activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcEndpoint.java
Sun Jan 13 01:08:11 2008
@@ -37,6 +37,7 @@
 
     private HttpParams params;
     private URI httpUri;
+    private int workers = 2;
 
     public JhcEndpoint(String endpointUri, JhcComponent component, URI httpUri) {
         super(endpointUri, component);
@@ -50,6 +51,14 @@
 
     public void setParams(HttpParams params) {
         this.params = params;
+    }
+
+    public void setWorkers(int workers) {
+        this.workers = workers;
+    }
+
+    public int getWorkers() {
+        return workers;
     }
 
     public URI getHttpUri() {

Modified: activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java?rev=611552&r1=611551&r2=611552&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
(original)
+++ activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcProducer.java
Sun Jan 13 01:08:11 2008
@@ -60,7 +60,7 @@
 
     private static Log LOG = LogFactory.getLog(JhcProducer.class);
 
-    private int nbThreads = 2;
+    private int nbThreads = 50;
     private ConnectingIOReactor ioReactor;
     private ThreadFactory threadFactory;
     private Thread runner;
@@ -78,6 +78,7 @@
     protected void doStart() throws Exception {
         super.doStart();
         HttpParams params = getEndpoint().getParams();
+        nbThreads = getEndpoint().getWorkers();
         ioReactor = new DefaultConnectingIOReactor(nbThreads, threadFactory, params);
         BasicHttpProcessor httpproc = new BasicHttpProcessor();
         httpproc.addInterceptor(new RequestContent());
@@ -238,7 +239,7 @@
 
         public void finalizeContext(HttpContext arg0) {
             // TODO Auto-generated method stub
-            
+
         }
     }
 

Modified: activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcServerEngine.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcServerEngine.java?rev=611552&r1=611551&r2=611552&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcServerEngine.java
(original)
+++ activemq/camel/trunk/components/camel-jhc/src/main/java/org/apache/camel/component/jhc/JhcServerEngine.java
Sun Jan 13 01:08:11 2008
@@ -42,66 +42,66 @@
     private final HttpParams params;
     private int port;
     private String protocol;
-    private int nbThreads = 2;
+    private int nbThreads = 50;
     private ListeningIOReactor ioReactor;
     private ThreadFactory threadFactory;
-    private Thread runner;   
-    private SSLContext sslContext;    
+    private Thread runner;
+    private SSLContext sslContext;
     private AsyncBufferingHttpServiceHandler serviceHandler;
     private HttpRequestHandlerRegistry handlerRegistry;
     private boolean isStarted;
     private int referenceCounter;
-    
+
     JhcServerEngine(HttpParams params, int port, String protocol) {
         this.params = params;
-        serviceHandler = new AsyncBufferingHttpServiceHandler(params);        
+        serviceHandler = new AsyncBufferingHttpServiceHandler(params);
         handlerRegistry = new HttpRequestHandlerRegistry();
         serviceHandler.setHandlerResolver(handlerRegistry);
         this.port = port;
         this.protocol = protocol;
     }
-    
-       
+
+
     public int getPort() {
         return port;
     }
-    
+
     public String getProtocol() {
         return this.protocol;
     }
-    
+
     public void setSslContext(SSLContext sslContext) {
         this.sslContext = sslContext;
     }
-    
+
     public SSLContext getSslContext() {
         return this.sslContext;
     }
-    
+
     public synchronized void register(String pattern, AsyncHttpRequestHandler handler) {
         handlerRegistry.register(pattern, handler);
         referenceCounter ++;
     }
-    
+
     public synchronized void unregister(String pattern) {
         handlerRegistry.unregister(pattern);
         referenceCounter --;
     }
-    
+
     public int getReferenceCounter() {
         return referenceCounter;
     }
-    
+
     public boolean isStarted() {
         return isStarted;
     }
-    
+
     public void start() throws IOReactorException {
-        final SocketAddress addr = new InetSocketAddress(port);        
+        final SocketAddress addr = new InetSocketAddress(port);
         ioReactor = new DefaultListeningIOReactor(nbThreads, threadFactory, params);
 
         final IOEventDispatch ioEventDispatch;
-        if ("https".equals(protocol)) {            
+        if ("https".equals(protocol)) {
             ioEventDispatch = new SSLServerIOEventDispatch(serviceHandler, sslContext, params);
         } else {
             ioEventDispatch = new DefaultServerIOEventDispatch(serviceHandler, params);
@@ -111,7 +111,7 @@
                 try {
                     ioReactor.listen(addr);
                     isStarted = true;
-                    ioReactor.execute(ioEventDispatch);                    
+                    ioReactor.execute(ioEventDispatch);
                 } catch (InterruptedIOException ex) {
                     LOG.info("Interrupted");
                 } catch (IOException e) {
@@ -122,7 +122,7 @@
         };
         runner.start();
     }
-    
+
     public void stop() throws IOException {
         LOG.debug("Stopping the jhc ioReactor ");
         ioReactor.shutdown();

Propchange: activemq/camel/trunk/components/camel-xstream/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Propchange: activemq/camel/trunk/examples/camel-example-cxf/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Propchange: activemq/camel/trunk/examples/camel-example-osgi/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes

Propchange: activemq/camel/trunk/examples/camel-example-spring-xquery/
------------------------------------------------------------------------------
--- svn:ignore (added)
+++ svn:ignore Sun Jan 13 01:08:11 2008
@@ -0,0 +1,7 @@
+.project
+.pmd
+.checkstyle
+.classpath
+target
+.settings
+eclipse-classes



Mime
View raw message