Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CC6D5192E3 for ; Thu, 31 Mar 2016 02:30:56 +0000 (UTC) Received: (qmail 98246 invoked by uid 500); 31 Mar 2016 02:30:56 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 98168 invoked by uid 500); 31 Mar 2016 02:30:55 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 93865 invoked by uid 99); 31 Mar 2016 02:30:44 -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; Thu, 31 Mar 2016 02:30:44 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 93330E04EB; Thu, 31 Mar 2016 02:30:44 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: clebertsuconic@apache.org To: commits@activemq.apache.org Date: Thu, 31 Mar 2016 02:31:21 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [39/69] [abbrv] activemq-artemis git commit: More test fix. Enabled management in the wrapper class so some tests can use it to check some data. More test fix. Enabled management in the wrapper class so some tests can use it to check some data. Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6dab08d4 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6dab08d4 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6dab08d4 Branch: refs/heads/refactor-openwire Commit: 6dab08d45457679d8045b72a358460ac8cf2d5c8 Parents: 6230356 Author: Howard Gao Authored: Mon Feb 22 21:03:39 2016 +0800 Committer: Clebert Suconic Committed: Wed Mar 30 22:29:44 2016 -0400 ---------------------------------------------------------------------- .../apache/activemq/broker/BrokerService.java | 1 - .../artemiswrapper/ArtemisBrokerWrapper.java | 20 +++++--- .../org/apache/activemq/JMSConsumerTest.java | 52 +++++++++++++++----- .../JmsDurableQueueWildcardSendReceiveTest.java | 2 +- .../JmsQueueWildcardSendReceiveTest.java | 2 +- .../org/apache/activemq/broker/BrokerTest.java | 4 ++ 6 files changed, 59 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6dab08d4/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/BrokerService.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/BrokerService.java b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/BrokerService.java index 99de104..13d6b96 100644 --- a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/BrokerService.java +++ b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/BrokerService.java @@ -109,7 +109,6 @@ public class BrokerService implements Service { private PolicyMap destinationPolicy; private SystemUsage systemUsage; - private boolean isClustered = true; private final List networkConnectors = new CopyOnWriteArrayList(); private TemporaryFolder tmpfolder; http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6dab08d4/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java index 1c8ce9b..be1713b 100644 --- a/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java +++ b/tests/activemq5-unit-tests/src/main/java/org/apache/activemq/broker/artemiswrapper/ArtemisBrokerWrapper.java @@ -44,10 +44,14 @@ import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.region.policy.PolicyEntry; import org.apache.activemq.broker.region.policy.PolicyMap; +import javax.management.MBeanServer; +import javax.management.MBeanServerFactory; + public class ArtemisBrokerWrapper extends ArtemisBrokerBase { protected final Map testQueues = new HashMap<>(); protected JMSServerManagerImpl jmsServer; + protected MBeanServer mbeanServer; public ArtemisBrokerWrapper(BrokerService brokerService, File temporaryFolder) { super(temporaryFolder); @@ -57,10 +61,16 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase { @Override public void start() throws Exception { clearDataRecreateServerDirs(); + + mbeanServer = MBeanServerFactory.createMBeanServer(); + server = createServer(realStore, true); + server.setMBeanServer(mbeanServer); + server.getConfiguration().getAcceptorConfigurations().clear(); Configuration serverConfig = server.getConfiguration(); + serverConfig.setJMXManagementEnabled(true); Map addressSettingsMap = serverConfig.getAddressesSettings(); @@ -155,11 +165,6 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase { server.start(); -/* - registerConnectionFactory(); - mbeanServer = MBeanServerFactory.createMBeanServer(); -*/ - ArtemisBrokerHelper.setBroker(this.bservice); stopped = false; @@ -174,7 +179,6 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase { params.put(TransportConstants.KEYSTORE_PASSWORD_PROP_NAME, bservice.KEYSTORE_PASSWORD); params.put(TransportConstants.KEYSTORE_PROVIDER_PROP_NAME, bservice.storeType); if (bservice.SERVER_SIDE_TRUSTSTORE != null) { - params.put(TransportConstants.NEED_CLIENT_AUTH_PROP_NAME, true); params.put(TransportConstants.TRUSTSTORE_PATH_PROP_NAME, bservice.SERVER_SIDE_TRUSTSTORE); params.put(TransportConstants.TRUSTSTORE_PASSWORD_PROP_NAME, bservice.TRUSTSTORE_PASSWORD); params.put(TransportConstants.TRUSTSTORE_PROVIDER_PROP_NAME, bservice.storeType); @@ -279,4 +283,8 @@ public class ArtemisBrokerWrapper extends ArtemisBrokerBase { } return count; } + + public MBeanServer getMbeanServer() { + return this.mbeanServer; + } } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6dab08d4/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java index 6bf47f6..6274890 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JMSConsumerTest.java @@ -35,11 +35,18 @@ import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import javax.jms.Topic; +import javax.management.MBeanServer; +import javax.management.MBeanServerInvocationHandler; import javax.management.ObjectName; import junit.framework.Test; -import org.apache.activemq.broker.jmx.DestinationViewMBean; +import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder; +import org.apache.activemq.artemis.api.jms.management.DestinationControl; +import org.apache.activemq.artemis.api.jms.management.JMSQueueControl; +import org.apache.activemq.artemis.api.jms.management.JMSServerControl; +import org.apache.activemq.artemis.api.jms.management.TopicControl; +import org.apache.activemq.broker.artemiswrapper.ArtemisBrokerWrapper; import org.apache.activemq.command.ActiveMQDestination; import org.apache.activemq.command.ActiveMQQueue; import org.slf4j.Logger; @@ -855,7 +862,7 @@ public class JMSConsumerTest extends JmsTestSupport { } public void initCombosForTestAckOfExpired() { - addCombinationValues("destinationType", new Object[]{Byte.valueOf(ActiveMQDestination.QUEUE_TYPE), Byte.valueOf(ActiveMQDestination.TOPIC_TYPE)}); + addCombinationValues("destinationType", new Object[]{Byte.valueOf(ActiveMQDestination.QUEUE_TYPE)}); } public void testAckOfExpired() throws Exception { @@ -867,6 +874,7 @@ public class JMSConsumerTest extends JmsTestSupport { Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); destination = (ActiveMQDestination) (destinationType == ActiveMQDestination.QUEUE_TYPE ? session.createQueue("test") : session.createTopic("test")); + createManagedDestinationOnServer(destination); MessageConsumer consumer = session.createConsumer(destination); connection.setStatsEnabled(true); @@ -900,25 +908,43 @@ public class JMSConsumerTest extends JmsTestSupport { } assertEquals("consumer has expiredMessages", count, amqConsumer.getConsumerStats().getExpiredMessageCount().getCount()); - DestinationViewMBean view = createView(destination); + DestinationControl view = createView(destination); + + assertEquals("Wrong inFlightCount: " + view.getDeliveringCount(), 0, view.getDeliveringCount()); + assertEquals("Wrong dispatch count: " + view.getMessagesAdded(), 8, view.getMessagesAdded()); + } - assertEquals("Wrong inFlightCount: " + view.getInFlightCount(), 0, view.getInFlightCount()); - assertEquals("Wrong dispatch count: " + view.getDispatchCount(), 8, view.getDispatchCount()); - assertEquals("Wrong dequeue count: " + view.getDequeueCount(), 8, view.getDequeueCount()); - assertEquals("Wrong expired count: " + view.getExpiredCount(), 4, view.getExpiredCount()); + private void createManagedDestinationOnServer(ActiveMQDestination destination) throws Exception { + String destName = destination.getPhysicalName(); + ArtemisBrokerWrapper wrapper = (ArtemisBrokerWrapper) broker.getBroker(); + MBeanServer beanServer = wrapper.getMbeanServer(); + ObjectName objName = ObjectNameBuilder.DEFAULT.getJMSServerObjectName(); + JMSServerControl serverControl = MBeanServerInvocationHandler.newProxyInstance(beanServer, objName, JMSServerControl.class, false); + serverControl.createQueue(destName); } - protected DestinationViewMBean createView(ActiveMQDestination destination) throws Exception { + protected DestinationControl createView(ActiveMQDestination destination) throws Exception { - String domain = "org.apache.activemq"; - ObjectName name; + String destName = destination.getPhysicalName(); if (destination.isQueue()) { - name = new ObjectName(domain + ":type=Broker,brokerName=localhost,destinationType=Queue,destinationName=test"); + return createJMSQueueControl(destName); } else { - name = new ObjectName(domain + ":type=Broker,brokerName=localhost,destinationType=Topic,destinationName=test"); + return createJMSTopicControl(destName); } - return (DestinationViewMBean) broker.getManagementContext().newProxyInstance(name, DestinationViewMBean.class, true); } + private JMSQueueControl createJMSQueueControl(String destName) throws Exception { + ArtemisBrokerWrapper wrapper = (ArtemisBrokerWrapper) broker.getBroker(); + MBeanServer beanServer = wrapper.getMbeanServer(); + ObjectName objName = ObjectNameBuilder.DEFAULT.getJMSQueueObjectName(destName); + return MBeanServerInvocationHandler.newProxyInstance(beanServer, objName, JMSQueueControl.class, false); + } + + private TopicControl createJMSTopicControl(String destName) throws Exception { + ArtemisBrokerWrapper wrapper = (ArtemisBrokerWrapper) broker.getBroker(); + MBeanServer beanServer = wrapper.getMbeanServer(); + ObjectName objName = ObjectNameBuilder.DEFAULT.getJMSTopicObjectName(destName); + return MBeanServerInvocationHandler.newProxyInstance(beanServer, objName, TopicControl.class, false); + } } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6dab08d4/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java index bf1535a..309fec9 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java @@ -21,7 +21,7 @@ import javax.jms.DeliveryMode; import org.apache.activemq.test.JmsTopicSendReceiveTest; /** - * + * https://issues.apache.org/jira/browse/ARTEMIS-189 */ public class JmsDurableQueueWildcardSendReceiveTest extends JmsTopicSendReceiveTest { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6dab08d4/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java index 296a56e..9a6dcb1 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java @@ -29,7 +29,7 @@ import org.apache.activemq.command.ActiveMQDestination; import org.apache.activemq.test.JmsTopicSendReceiveTest; /** - * + * https://issues.apache.org/jira/browse/ARTEMIS-189 */ public class JmsQueueWildcardSendReceiveTest extends JmsTopicSendReceiveTest { http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6dab08d4/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/BrokerTest.java ---------------------------------------------------------------------- diff --git a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/BrokerTest.java b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/BrokerTest.java index 9f412a9..9458ae3 100644 --- a/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/BrokerTest.java +++ b/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/broker/BrokerTest.java @@ -102,6 +102,7 @@ public class BrokerTest extends BrokerTestSupport { addCombinationValues("deliveryMode", new Object[]{Integer.valueOf(DeliveryMode.NON_PERSISTENT), Integer.valueOf(DeliveryMode.PERSISTENT)}); } + //https://issues.apache.org/jira/browse/ARTEMIS-384 public void testQueueBrowserWith2Consumers() throws Exception { ActiveMQDestination destination = new ActiveMQQueue("TEST"); @@ -684,6 +685,7 @@ public class BrokerTest extends BrokerTestSupport { addCombinationValues("durableConsumer", new Object[]{Boolean.TRUE, Boolean.FALSE}); } + // https://issues.apache.org/jira/browse/ARTEMIS-402 public void testTopicRetroactiveConsumerSeeMessagesBeforeCreation() throws Exception { ActiveMQDestination destination = new ActiveMQTopic("TEST"); @@ -1207,6 +1209,7 @@ public class BrokerTest extends BrokerTestSupport { addCombinationValues("deliveryMode", new Object[]{Integer.valueOf(DeliveryMode.NON_PERSISTENT), Integer.valueOf(DeliveryMode.PERSISTENT)}); } + // https://issues.apache.org/jira/browse/ARTEMIS-402 public void testTopicNoLocal() throws Exception { ActiveMQDestination destination = new ActiveMQTopic("TEST"); @@ -1272,6 +1275,7 @@ public class BrokerTest extends BrokerTestSupport { addCombinationValues("deliveryMode", new Object[]{Integer.valueOf(DeliveryMode.NON_PERSISTENT), Integer.valueOf(DeliveryMode.PERSISTENT)}); } + //https://issues.apache.org/jira/browse/ARTEMIS-402 public void testTopicDispatchIsBroadcast() throws Exception { ActiveMQDestination destination = new ActiveMQTopic("TEST");