activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: performance tests on openwire
Date Fri, 14 Aug 2015 19:39:59 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master d3602200a -> 3dd9ce6b0


performance tests on openwire


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/27b98a25
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/27b98a25
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/27b98a25

Branch: refs/heads/master
Commit: 27b98a2514475ba34150ca01ae70703fca18f9a3
Parents: d360220
Author: Clebert Suconic <clebertsuconic@apache.org>
Authored: Fri Aug 14 14:49:57 2015 -0400
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Fri Aug 14 15:39:27 2015 -0400

----------------------------------------------------------------------
 .../artemis/cli/commands/etc/broker.xml         |   3 +-
 .../protocol/openwire/OpenWireConnection.java   |   3 +-
 examples/features/perf/perf/pom.xml             | 137 ++++++++++---------
 .../activemq/artemis/jms/example/PerfBase.java  |  38 +++--
 .../artemis/jms/example/PerfParams.java         |  47 ++++---
 .../main/resources/activemq/server0/broker.xml  |  46 -------
 .../perf/src/main/resources/jndi.properties     |  20 ---
 .../perf/src/main/resources/perf.properties     |   9 +-
 examples/pom.xml                                |   2 +
 9 files changed, 134 insertions(+), 171 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
index 75cd6ee..35b7725 100644
--- a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
+++ b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/broker.xml
@@ -46,7 +46,8 @@ ${journal-buffer.settings}
 ${connector-config.settings}
       <acceptors>
          <!-- Default ActiveMQ Artemis Acceptor.  Multi-protocol adapter.  Currently supports
Core, OpenWire, Stomp and AMQP. -->
-         <acceptor name="artemis">tcp://${host}:${default.port}</acceptor>
+         <!-- performance tests have shown that openWire performs best with these buffer
sizes -->
+         <acceptor name="artemis">tcp://${host}:${default.port}?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576</acceptor>
 
          <!-- AMQP Acceptor.  Listens on default AMQP port for AMQP traffic.-->
          <acceptor name="amqp">tcp://${host}:${amqp.port}?protocols=AMQP</acceptor>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
index ada2a70..fc14382 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireConnection.java
@@ -194,9 +194,8 @@ public class OpenWireConnection implements RemotingConnection, CommandVisitor
{
    @Override
    public void bufferReceived(Object connectionID, ActiveMQBuffer buffer) {
       try {
-         Object object = wireFormat.unmarshal(buffer);
+         Command command = (Command) wireFormat.unmarshal(buffer);
 
-         Command command = (Command) object;
          boolean responseRequired = command.isResponseRequired();
          int commandId = command.getCommandId();
          // the connection handles pings, negotiations directly.

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/features/perf/perf/pom.xml
----------------------------------------------------------------------
diff --git a/examples/features/perf/perf/pom.xml b/examples/features/perf/perf/pom.xml
index bcab911..190f505 100644
--- a/examples/features/perf/perf/pom.xml
+++ b/examples/features/perf/perf/pom.xml
@@ -18,7 +18,8 @@ specific language governing permissions and limitations
 under the License.
 -->
 
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
    <modelVersion>4.0.0</modelVersion>
 
    <parent>
@@ -27,9 +28,9 @@ under the License.
       <version>1.0.1-SNAPSHOT</version>
    </parent>
 
-   <artifactId>perf</artifactId>
+   <artifactId>openwire-perf</artifactId>
    <packaging>jar</packaging>
-   <name>ActiveMQ Artemis JMS PerfExample Example</name>
+   <name>ActiveMQ Artemis JMS Perf example for openwire</name>
 
    <properties>
       <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
@@ -37,33 +38,24 @@ under the License.
 
    <dependencies>
       <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-server</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-jms-server</artifactId>
-         <version>${project.version}</version>
-      </dependency>
-      <dependency>
-         <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-core-client</artifactId>
-         <version>${project.version}</version>
+         <groupId>org.apache.geronimo.specs</groupId>
+         <artifactId>geronimo-jms_1.1_spec</artifactId>
+         <version>1.1</version>
       </dependency>
       <dependency>
          <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-commons</artifactId>
-         <version>${project.version}</version>
+         <artifactId>activemq-client</artifactId>
+         <version>${activemq5-version}</version>
       </dependency>
       <dependency>
-         <groupId>io.netty</groupId>
-         <artifactId>netty-all</artifactId>
-         <version>${netty.version}</version>
+         <groupId>org.slf4j</groupId>
+         <artifactId>slf4j-nop</artifactId>
+         <version>${slf4j-version}</version>
       </dependency>
       <dependency>
+         <!-- this is to have the ServerUtil -->
          <groupId>org.apache.activemq</groupId>
-         <artifactId>artemis-jms-client</artifactId>
+         <artifactId>artemis-cli</artifactId>
          <version>${project.version}</version>
       </dependency>
    </dependencies>
@@ -76,30 +68,37 @@ under the License.
                <plugin>
                   <groupId>org.apache.activemq</groupId>
                   <artifactId>artemis-maven-plugin</artifactId>
-                     <executions>
-                        <execution>
-                           <id>create</id>
-                           <goals>
-                              <goal>create</goal>
-                           </goals>
-                        </execution>
-                        <execution>
-                           <id>runClient</id>
-                           <goals>
-                              <goal>runClient</goal>
-                           </goals>
-                           <configuration>
-                              <clientClass>org.apache.activemq.artemis.jms.example.Server</clientClass>
-                           </configuration>
-                        </execution>
-                     </executions>
-                     <dependencies>
-                        <dependency>
-                           <groupId>org.apache.activemq.examples.soak</groupId>
-                           <artifactId>perf</artifactId>
-                           <version>${project.version}</version>
-                        </dependency>
-                     </dependencies>
+                  <executions>
+                     <execution>
+                        <id>create</id>
+                        <configuration>
+                           <noAutoTune>false</noAutoTune>
+                           <args>
+                              <arg>--queues</arg>
+                              <arg>perfQueue</arg>
+                           </args>
+                        </configuration>
+                        <goals>
+                           <goal>create</goal>
+                        </goals>
+                     </execution>
+                     <execution>
+                        <id>runClient</id>
+                        <goals>
+                           <goal>runClient</goal>
+                        </goals>
+                        <configuration>
+                           <clientClass>org.apache.activemq.artemis.jms.example.Server</clientClass>
+                        </configuration>
+                     </execution>
+                  </executions>
+                  <dependencies>
+                     <dependency>
+                        <groupId>org.apache.activemq.examples.soak</groupId>
+                        <artifactId>openwire-perf</artifactId>
+                        <version>${project.version}</version>
+                     </dependency>
+                  </dependencies>
                </plugin>
             </plugins>
          </build>
@@ -109,20 +108,26 @@ under the License.
          <build>
             <plugins>
                <plugin>
-                  <groupId>org.codehaus.mojo</groupId>
-                  <artifactId>exec-maven-plugin</artifactId>
-                  <version>1.1</version>
+                  <groupId>org.apache.activemq</groupId>
+                  <artifactId>artemis-maven-plugin</artifactId>
                   <executions>
                      <execution>
-                        <phase>package</phase>
+                        <id>runClient</id>
                         <goals>
-                           <goal>java</goal>
+                           <goal>runClient</goal>
                         </goals>
+                        <configuration>
+                           <clientClass>org.apache.activemq.artemis.jms.example.PerfListener</clientClass>
+                        </configuration>
                      </execution>
                   </executions>
-                  <configuration>
-                     <mainClass>org.apache.activemq.artemis.jms.example.PerfListener</mainClass>
-                  </configuration>
+                  <dependencies>
+                     <dependency>
+                        <groupId>org.apache.activemq.examples.soak</groupId>
+                        <artifactId>openwire-perf</artifactId>
+                        <version>${project.version}</version>
+                     </dependency>
+                  </dependencies>
                </plugin>
             </plugins>
          </build>
@@ -132,25 +137,29 @@ under the License.
          <build>
             <plugins>
                <plugin>
-                  <groupId>org.codehaus.mojo</groupId>
-                  <artifactId>exec-maven-plugin</artifactId>
-                  <version>1.1</version>
+                  <groupId>org.apache.activemq</groupId>
+                  <artifactId>artemis-maven-plugin</artifactId>
                   <executions>
                      <execution>
-                        <phase>package</phase>
+                        <id>runClient</id>
                         <goals>
-                           <goal>java</goal>
+                           <goal>runClient</goal>
                         </goals>
+                        <configuration>
+                           <clientClass>org.apache.activemq.artemis.jms.example.PerfSender</clientClass>
+                        </configuration>
                      </execution>
                   </executions>
-                  <configuration>
-                     <mainClass>org.apache.activemq.artemis.jms.example.PerfSender</mainClass>
-                  </configuration>
+                  <dependencies>
+                     <dependency>
+                        <groupId>org.apache.activemq.examples.soak</groupId>
+                        <artifactId>openwire-perf</artifactId>
+                        <version>${project.version}</version>
+                     </dependency>
+                  </dependencies>
                </plugin>
             </plugins>
          </build>
       </profile>
    </profiles>
-
-
 </project>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfBase.java
----------------------------------------------------------------------
diff --git a/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfBase.java
b/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfBase.java
index bf18077..8fcafa4 100644
--- a/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfBase.java
+++ b/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfBase.java
@@ -27,7 +27,6 @@ import javax.jms.MessageConsumer;
 import javax.jms.MessageListener;
 import javax.jms.MessageProducer;
 import javax.jms.Session;
-import javax.naming.InitialContext;
 import java.io.FileInputStream;
 import java.io.InputStream;
 import java.util.Properties;
@@ -60,7 +59,7 @@ public abstract class PerfBase {
    protected static String getPerfFileName(final String[] args) {
       String fileName;
 
-      if (args.length > 0) {
+      if (args != null && args.length > 0) {
          fileName = args[0];
       }
       else {
@@ -95,12 +94,13 @@ public abstract class PerfBase {
       boolean transacted = Boolean.valueOf(props.getProperty("transacted"));
       int batchSize = Integer.valueOf(props.getProperty("batch-size"));
       boolean drainQueue = Boolean.valueOf(props.getProperty("drain-queue"));
-      String destinationLookup = props.getProperty("destination-lookup");
-      String connectionFactoryLookup = props.getProperty("connection-factory-lookup");
+      String destinationName = props.getProperty("destination-name");
       int throttleRate = Integer.valueOf(props.getProperty("throttle-rate"));
       boolean dupsOK = Boolean.valueOf(props.getProperty("dups-ok-acknowlege"));
       boolean disableMessageID = Boolean.valueOf(props.getProperty("disable-message-id"));
       boolean disableTimestamp = Boolean.valueOf(props.getProperty("disable-message-timestamp"));
+      boolean openwire = Boolean.valueOf(props.getProperty("openwire", "true"));
+      String uri = props.getProperty("server-uri", "tcp://localhost:61616");
 
       PerfBase.log.info("num-messages: " + noOfMessages);
       PerfBase.log.info("num-warmup-messages: " + noOfWarmupMessages);
@@ -110,11 +110,12 @@ public abstract class PerfBase {
       PerfBase.log.info("batch-size: " + batchSize);
       PerfBase.log.info("drain-queue: " + drainQueue);
       PerfBase.log.info("throttle-rate: " + throttleRate);
-      PerfBase.log.info("connection-factory-lookup: " + connectionFactoryLookup);
-      PerfBase.log.info("destination-lookup: " + destinationLookup);
+      PerfBase.log.info("destination-name: " + destinationName);
       PerfBase.log.info("disable-message-id: " + disableMessageID);
       PerfBase.log.info("disable-message-timestamp: " + disableTimestamp);
       PerfBase.log.info("dups-ok-acknowledge: " + dupsOK);
+      PerfBase.log.info("server-uri: " + uri);
+      PerfBase.log.info("openwire:" + openwire);
 
       PerfParams perfParams = new PerfParams();
       perfParams.setNoOfMessagesToSend(noOfMessages);
@@ -124,12 +125,13 @@ public abstract class PerfBase {
       perfParams.setSessionTransacted(transacted);
       perfParams.setBatchSize(batchSize);
       perfParams.setDrainQueue(drainQueue);
-      perfParams.setConnectionFactoryLookup(connectionFactoryLookup);
-      perfParams.setDestinationLookup(destinationLookup);
+      perfParams.setDestinationName(destinationName);
       perfParams.setThrottleRate(throttleRate);
       perfParams.setDisableMessageID(disableMessageID);
       perfParams.setDisableTimestamp(disableTimestamp);
       perfParams.setDupsOK(dupsOK);
+      perfParams.setOpenwire(openwire);
+      perfParams.setUri(uri);
 
       return perfParams;
    }
@@ -151,17 +153,23 @@ public abstract class PerfBase {
    private long start;
 
    private void init() throws Exception {
-      InitialContext ic = new InitialContext();
-      System.out.println("ic = " + ic);
-      factory = (ConnectionFactory) ic.lookup(perfParams.getConnectionFactoryLookup());
+      if (perfParams.isOpenwire()) {
+         factory = new org.apache.activemq.ActiveMQConnectionFactory(perfParams.getUri());
 
-      destination = (Destination) ic.lookup(perfParams.getDestinationLookup());
+         destination = new org.apache.activemq.command.ActiveMQQueue(perfParams.getDestinationName());
 
-      connection = factory.createConnection();
+         connection = factory.createConnection();
+      }
+      else {
+         factory = new  org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory(perfParams.getUri());
 
-      session = connection.createSession(perfParams.isSessionTransacted(), perfParams.isDupsOK()
? Session.DUPS_OK_ACKNOWLEDGE : Session.AUTO_ACKNOWLEDGE);
+         destination = new org.apache.activemq.artemis.jms.client.ActiveMQQueue(perfParams.getDestinationName());
+
+         connection = factory.createConnection();
 
-      ic.close();
+      }
+
+      session = connection.createSession(perfParams.isSessionTransacted(), perfParams.isDupsOK()
? Session.DUPS_OK_ACKNOWLEDGE : Session.AUTO_ACKNOWLEDGE);
    }
 
    private void displayAverage(final long numberOfMessages, final long start, final long
end) {

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfParams.java
----------------------------------------------------------------------
diff --git a/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfParams.java
b/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfParams.java
index c358171..ce78ffd 100644
--- a/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfParams.java
+++ b/examples/features/perf/perf/src/main/java/org/apache/activemq/artemis/jms/example/PerfParams.java
@@ -39,9 +39,7 @@ public class PerfParams implements Serializable {
 
    private boolean drainQueue = true;
 
-   private String connectionFactoryLookup;
-
-   private String destinationLookup;
+   private String destinationName;
 
    private int throttleRate;
 
@@ -49,8 +47,20 @@ public class PerfParams implements Serializable {
 
    private boolean disableTimestamp;
 
+   private boolean openwire;
+
    private boolean dupsOK;
 
+   private String uri;
+
+   public String getUri() {
+      return uri;
+   }
+
+   public void setUri(String uri) {
+      this.uri = uri;
+   }
+
    public synchronized int getNoOfMessagesToSend() {
       return noOfMessagesToSend;
    }
@@ -99,28 +109,20 @@ public class PerfParams implements Serializable {
       this.batchSize = batchSize;
    }
 
-   public synchronized boolean isDrainQueue() {
-      return drainQueue;
-   }
-
-   public synchronized void setDrainQueue(final boolean drainQueue) {
-      this.drainQueue = drainQueue;
-   }
-
-   public synchronized String getConnectionFactoryLookup() {
-      return connectionFactoryLookup;
+   public String getDestinationName() {
+      return destinationName;
    }
 
-   public synchronized void setConnectionFactoryLookup(final String connectionFactoryLookup)
{
-      this.connectionFactoryLookup = connectionFactoryLookup;
+   public void setDestinationName(String destinationName) {
+      this.destinationName = destinationName;
    }
 
-   public synchronized String getDestinationLookup() {
-      return destinationLookup;
+   public synchronized boolean isDrainQueue() {
+      return drainQueue;
    }
 
-   public synchronized void setDestinationLookup(final String destinationLookup) {
-      this.destinationLookup = destinationLookup;
+   public synchronized void setDrainQueue(final boolean drainQueue) {
+      this.drainQueue = drainQueue;
    }
 
    public synchronized int getThrottleRate() {
@@ -155,4 +157,11 @@ public class PerfParams implements Serializable {
       this.dupsOK = dupsOK;
    }
 
+   public boolean isOpenwire() {
+      return openwire;
+   }
+
+   public void setOpenwire(boolean openwire) {
+      this.openwire = openwire;
+   }
 }

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/features/perf/perf/src/main/resources/activemq/server0/broker.xml
----------------------------------------------------------------------
diff --git a/examples/features/perf/perf/src/main/resources/activemq/server0/broker.xml b/examples/features/perf/perf/src/main/resources/activemq/server0/broker.xml
deleted file mode 100644
index a642ac5..0000000
--- a/examples/features/perf/perf/src/main/resources/activemq/server0/broker.xml
+++ /dev/null
@@ -1,46 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements.  See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership.  The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License.  You may obtain a copy of the License at
-
-  http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied.  See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-               xmlns="urn:activemq"
-               xsi:schemaLocation="urn:activemq /schema/artemis-server.xsd">
-
-   <jms xmlns="urn:activemq:jms">
-      <queue name="perfQueue"/>
-   </jms>
-
-   <core xmlns="urn:activemq:core">
-
-      <security-enabled>false</security-enabled>
-      <persistence-enabled>true</persistence-enabled>
-
-      <!-- Acceptors -->
-      <acceptors>
-         <acceptor name="netty-acceptor">tcp://localhost:61616?tcpNoDelay=false;tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576</acceptor>
-      </acceptors>
-
-      <queues>
-         <queue name="perfQueue">
-            <address>perfAddress</address>
-         </queue>
-      </queues>
-
-   </core>
-</configuration>

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/features/perf/perf/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/features/perf/perf/src/main/resources/jndi.properties b/examples/features/perf/perf/src/main/resources/jndi.properties
deleted file mode 100644
index bcf6926..0000000
--- a/examples/features/perf/perf/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,20 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-#   http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied.  See the License for the
-# specific language governing permissions and limitations
-# under the License.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=tcp://localhost:61616?tcp-no-delay=false&tcp-send-buffer-size=1048576&tcp-receive-buffer-size=1048576
-queue.perfQueue=perfQueue

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/features/perf/perf/src/main/resources/perf.properties
----------------------------------------------------------------------
diff --git a/examples/features/perf/perf/src/main/resources/perf.properties b/examples/features/perf/perf/src/main/resources/perf.properties
index f5ca7be..7a0242a 100644
--- a/examples/features/perf/perf/src/main/resources/perf.properties
+++ b/examples/features/perf/perf/src/main/resources/perf.properties
@@ -15,16 +15,17 @@
 # specific language governing permissions and limitations
 # under the License.
 
-num-messages=100000
+num-messages=25000
 num-warmup-messages=1000
 message-size=1024
-durable=false
+durable=true
 transacted=false
 batch-size=1000
 drain-queue=false
-destination-lookup=perfQueue
-connection-factory-lookup=ConnectionFactory
+destination-name=perfQueue
 throttle-rate=-1
 dups-ok-acknowledge=false
 disable-message-id=true
 disable-message-timestamp=true
+server-uri=tcp://localhost:61616
+openwire=false

http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/27b98a25/examples/pom.xml
----------------------------------------------------------------------
diff --git a/examples/pom.xml b/examples/pom.xml
index e17ee02..4381cbb 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -33,6 +33,8 @@ under the License.
    <name>ActiveMQ Artemis Examples</name>
 
    <properties>
+      <slf4j-version>1.7.10</slf4j-version>
+      <activemq5-version>5.12.0</activemq5-version>
       <udp-address>231.7.7.7</udp-address>
       <activemq.basedir>${project.basedir}/..</activemq.basedir>
    </properties>


Mime
View raw message