Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 67A0E180BF for ; Wed, 28 Oct 2015 12:37:48 +0000 (UTC) Received: (qmail 15789 invoked by uid 500); 28 Oct 2015 12:37:48 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 15753 invoked by uid 500); 28 Oct 2015 12:37:48 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 15744 invoked by uid 99); 28 Oct 2015 12:37:48 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 28 Oct 2015 12:37:48 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id E51BDDFE34; Wed, 28 Oct 2015 12:37:47 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: raulk@apache.org To: commits@ignite.apache.org Message-Id: <9afac356ceba4c3b9fd30436655d7673@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: ignite git commit: Ignite JMS 1.1 Streamer tests: Remove dependency on KahaDB & persistence. Date: Wed, 28 Oct 2015 12:37:47 +0000 (UTC) Repository: ignite Updated Branches: refs/heads/master e769c3a80 -> 7f0b3fce5 Ignite JMS 1.1 Streamer tests: Remove dependency on KahaDB & persistence. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7f0b3fce Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7f0b3fce Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7f0b3fce Branch: refs/heads/master Commit: 7f0b3fce5ae6ed0652f3dbf64f0482e63d36c38d Parents: e769c3a Author: Raul Kripalani Authored: Wed Oct 28 12:37:38 2015 +0000 Committer: Raul Kripalani Committed: Wed Oct 28 12:37:38 2015 +0000 ---------------------------------------------------------------------- modules/jms11/pom.xml | 7 ------- .../apache/ignite/stream/jms11/IgniteJmsStreamerTest.java | 9 +++++++-- 2 files changed, 7 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7f0b3fce/modules/jms11/pom.xml ---------------------------------------------------------------------- diff --git a/modules/jms11/pom.xml b/modules/jms11/pom.xml index 72a643b..3c37e7f 100644 --- a/modules/jms11/pom.xml +++ b/modules/jms11/pom.xml @@ -66,13 +66,6 @@ - org.apache.activemq - activemq-kahadb-store - ${activemq.version} - test - - - org.apache.ignite ignite-log4j ${project.version} http://git-wip-us.apache.org/repos/asf/ignite/blob/7f0b3fce/modules/jms11/src/test/java/org/apache/ignite/stream/jms11/IgniteJmsStreamerTest.java ---------------------------------------------------------------------- diff --git a/modules/jms11/src/test/java/org/apache/ignite/stream/jms11/IgniteJmsStreamerTest.java b/modules/jms11/src/test/java/org/apache/ignite/stream/jms11/IgniteJmsStreamerTest.java index 0e110a5..238d939 100644 --- a/modules/jms11/src/test/java/org/apache/ignite/stream/jms11/IgniteJmsStreamerTest.java +++ b/modules/jms11/src/test/java/org/apache/ignite/stream/jms11/IgniteJmsStreamerTest.java @@ -83,14 +83,19 @@ public class IgniteJmsStreamerTest extends GridCommonAbstractTest { grid().getOrCreateCache(defaultCacheConfiguration()); broker = new BrokerService(); - broker.deleteAllMessages(); + broker.setDeleteAllMessagesOnStartup(true); broker.setPersistent(false); + broker.setPersistenceAdapter(null); + broker.setPersistenceFactory(null); PolicyMap policyMap = new PolicyMap(); PolicyEntry policy = new PolicyEntry(); + policy.setQueuePrefetch(1); + broker.setDestinationPolicy(policyMap); broker.getDestinationPolicy().setDefaultEntry(policy); + broker.setSchedulerSupport(false); broker.start(true); @@ -102,8 +107,8 @@ public class IgniteJmsStreamerTest extends GridCommonAbstractTest { public void afterTest() throws Exception { grid().cache(null).clear(); - broker.deleteAllMessages(); broker.stop(); + broker.deleteAllMessages(); } public void testQueueFromName() throws Exception {