Repository: incubator-ignite Updated Branches: refs/heads/sprint-1 e608da8fe -> 157591e30
# 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/sprint-1 Commit: 157591e307b3d0ca1d58c96bcb1cd67a30cf483e Parents: e608da8 Author: AKuznetsov <akuznet...@gridgain.com> Authored: Sun Feb 15 22:33:47 2015 +0700 Committer: AKuznetsov <akuznet...@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);
