ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [04/48] incubator-ignite git commit: # sprint-1 Fixed Visor code after streamer configuration changes.
Date Mon, 16 Feb 2015 09:51:35 GMT
# sprint-1 Fixed Visor code after streamer configuration changes.


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/157591e3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/157591e3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/157591e3

Branch: refs/heads/ignite-public-api-cleanup
Commit: 157591e307b3d0ca1d58c96bcb1cd67a30cf483e
Parents: e608da8
Author: AKuznetsov <akuznetsov@gridgain.com>
Authored: Sun Feb 15 22:33:47 2015 +0700
Committer: AKuznetsov <akuznetsov@gridgain.com>
Committed: Sun Feb 15 22:33:47 2015 +0700

----------------------------------------------------------------------
 .../streamer/VisorStreamerConfiguration.java      | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/157591e3/modules/core/src/main/java/org/apache/ignite/internal/visor/streamer/VisorStreamerConfiguration.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/streamer/VisorStreamerConfiguration.java
b/modules/core/src/main/java/org/apache/ignite/internal/visor/streamer/VisorStreamerConfiguration.java
index 3c32b6b..ab236a2 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/streamer/VisorStreamerConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/streamer/VisorStreamerConfiguration.java
@@ -48,6 +48,9 @@ public class VisorStreamerConfiguration implements Serializable {
     /** Maximum number of concurrent events to be processed. */
     private int maxConcurrentSessions;
 
+    /** Streamer thread pool size. */
+    private int poolSize;
+
     /**
      * @param scfg Streamer configuration.
      * @return Data transfer object for streamer configuration properties.
@@ -60,6 +63,7 @@ public class VisorStreamerConfiguration implements Serializable {
         cfg.atLeastOnce(scfg.isAtLeastOnce());
         cfg.maximumFailoverAttempts(scfg.getMaximumFailoverAttempts());
         cfg.maximumConcurrentSessions(scfg.getMaximumConcurrentSessions());
+        cfg.threadPoolSize(scfg.getThreadPoolSize());
 
         return cfg;
     }
@@ -152,6 +156,20 @@ public class VisorStreamerConfiguration implements Serializable {
         this.maxConcurrentSessions = maxConcurrentSessions;
     }
 
+    /**
+     * @return Streamer thread pool size.
+     */
+    public int threadPoolSize() {
+        return poolSize;
+    }
+
+    /**
+     * @param poolSize New streamer thread pool size.
+     */
+    public void threadPoolSize(int poolSize) {
+        this.poolSize = poolSize;
+    }
+
     /** {@inheritDoc} */
     @Override public String toString() {
         return S.toString(VisorStreamerConfiguration.class, this);


Mime
View raw message