date:20180427

activemq git commit: AMQ-6707 - skip tracked ack dependent test for leveldb

2018-04-27 Thread gtully

Repository: activemq
Updated Branches:
  refs/heads/master ceb97f6ba -> 314d5a516


AMQ-6707 - skip tracked ack dependent test for leveldb


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

Branch: refs/heads/master
Commit: 314d5a51688186bf1a21bae0137b3e6cee407f43
Parents: ceb97f6
Author: gtully 
Authored: Fri Apr 27 14:06:04 2018 +0100
Committer: gtully 
Committed: Fri Apr 27 14:06:04 2018 +0100

--
 .../org/apache/activemq/broker/mLevelDBXARecoveryBrokerTest.java  | 3 +++
 1 file changed, 3 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/314d5a51/activemq-unit-tests/src/test/java/org/apache/activemq/broker/mLevelDBXARecoveryBrokerTest.java
--
diff --git 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/mLevelDBXARecoveryBrokerTest.java
 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/mLevelDBXARecoveryBrokerTest.java
index 147d89a..5322338 100644
--- 
a/activemq-unit-tests/src/test/java/org/apache/activemq/broker/mLevelDBXARecoveryBrokerTest.java
+++ 
b/activemq-unit-tests/src/test/java/org/apache/activemq/broker/mLevelDBXARecoveryBrokerTest.java
@@ -66,4 +66,7 @@ public class mLevelDBXARecoveryBrokerTest extends 
XARecoveryBrokerTest {
 public void testQueuePersistentUncommittedAcksLostOnRestart() throws 
Exception {
 // super.testQueuePersistentUncommittedAcksLostOnRestart();
 }
+public void testQueuePersistentPreparedAcksNotLostOnRestart() throws 
Exception {
+// pending acks are not tracked in leveldb
+}
 }

activemq git commit: AMQ-6707 - mKahadb, track recovered tx per store for completion, resolve test regression

2018-04-27 Thread gtully

Repository: activemq
Updated Branches:
  refs/heads/master ea70e827c -> ceb97f6ba


AMQ-6707 - mKahadb, track recovered tx per store for completion, resolve test 
regression


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

Branch: refs/heads/master
Commit: ceb97f6baa471006cf176f298e763224f8d1b58f
Parents: ea70e82
Author: gtully 
Authored: Fri Apr 27 13:48:51 2018 +0100
Committer: gtully 
Committed: Fri Apr 27 13:48:51 2018 +0100

--
 .../kahadb/MultiKahaDBTransactionStore.java | 36 +++-
 1 file changed, 28 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq/blob/ceb97f6b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MultiKahaDBTransactionStore.java
--
diff --git 
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MultiKahaDBTransactionStore.java
 
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MultiKahaDBTransactionStore.java
index ff70076..f13fc53 100644
--- 
a/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MultiKahaDBTransactionStore.java
+++ 
b/activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MultiKahaDBTransactionStore.java
@@ -19,7 +19,9 @@ package org.apache.activemq.store.kahadb;
 import java.io.File;
 import java.io.IOException;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.HashSet;
+import java.util.Map;
 import java.util.Set;
 import java.util.TreeSet;
 import java.util.concurrent.ConcurrentHashMap;
@@ -189,17 +191,25 @@ public class MultiKahaDBTransactionStore implements 
TransactionStore {
 }
 
 public class Tx {
-private final Set stores = new 
HashSet();
+private final HashMap stores = new 
HashMap();
 private int prepareLocationId = 0;
 
+public void trackStore(TransactionStore store, XATransactionId xid) {
+stores.put(store, xid);
+}
+
 public void trackStore(TransactionStore store) {
-stores.add(store);
+stores.put(store, null);
 }
 
-public Set getStores() {
+public HashMap getStoresMap() {
 return stores;
 }
 
+public Set getStores() {
+return stores.keySet();
+}
+
 public void trackPrepareLocation(Location location) {
 this.prepareLocationId = location.getDataFileId();
 }
@@ -240,8 +250,13 @@ public class MultiKahaDBTransactionStore implements 
TransactionStore {
 
 Tx tx = getTx(txid);
 if (wasPrepared) {
-for (TransactionStore store : tx.getStores()) {
-store.commit(txid, true, null, null);
+for (Map.Entry storeTx : 
tx.getStoresMap().entrySet()) {
+TransactionId recovered = storeTx.getValue();
+if (recovered != null) {
+storeTx.getKey().commit(recovered, true, null, null);
+} else {
+storeTx.getKey().commit(txid, true, null, null);
+}
 }
 } else {
 // can only do 1pc on a single store
@@ -289,8 +304,13 @@ public class MultiKahaDBTransactionStore implements 
TransactionStore {
 public void rollback(TransactionId txid) throws IOException {
 Tx tx = removeTx(txid);
 if (tx != null) {
-for (TransactionStore store : tx.getStores()) {
-store.rollback(txid);
+for (Map.Entry storeTx : 
tx.getStoresMap().entrySet()) {
+TransactionId recovered = storeTx.getValue();
+if (recovered != null) {
+storeTx.getKey().rollback(recovered);
+} else {
+storeTx.getKey().rollback(txid);
+}
 }
 }
 }
@@ -387,7 +407,7 @@ public class MultiKahaDBTransactionStore implements 
TransactionStore {
 @Override
 public void recover(XATransactionId xid, Message[] 
addedMessages, MessageAck[] acks) {
 try {
-
getTx(xid).trackStore(adapter.createTransactionStore());
+
getTx(xid).trackStore(adapter.createTransactionStore(), xid);
 } catch (IOException e) {
 LOG.error("Failed to access transaction store: " + 
adapter

Build failed in Jenkins: ActiveMQ-Trunk-Deploy #2005

2018-04-27 Thread Apache Jenkins Server

See 

--
Started by an SCM change
[EnvInject] - Loading node environment variables.
Building remotely on H32 (ubuntu xenial) in workspace 

Cloning the remote Git repository
Cloning repository https://git-wip-us.apache.org/repos/asf/activemq.git
 > git init  # 
 > timeout=10
ERROR: Error cloning remote repo 'origin'
hudson.plugins.git.GitException: Could not init 

at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl$5.execute(CliGitAPIImpl.java:772)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl$2.execute(CliGitAPIImpl.java:564)
at 
org.jenkinsci.plugins.gitclient.RemoteGitImpl$CommandInvocationHandler$1.call(RemoteGitImpl.java:153)
at 
org.jenkinsci.plugins.gitclient.RemoteGitImpl$CommandInvocationHandler$1.call(RemoteGitImpl.java:146)
at hudson.remoting.UserRequest.perform(UserRequest.java:207)
at hudson.remoting.UserRequest.perform(UserRequest.java:53)
at hudson.remoting.Request$2.run(Request.java:358)
at 
hudson.remoting.InterceptingExecutorService$1.call(InterceptingExecutorService.java:72)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
Suppressed: hudson.remoting.Channel$CallSiteStackTrace: Remote call to 
H32
at 
hudson.remoting.Channel.attachCallSiteStackTrace(Channel.java:1693)
at hudson.remoting.UserResponse.retrieve(UserRequest.java:310)
at hudson.remoting.Channel.call(Channel.java:908)
at 
org.jenkinsci.plugins.gitclient.RemoteGitImpl$CommandInvocationHandler.execute(RemoteGitImpl.java:146)
at sun.reflect.GeneratedMethodAccessor743.invoke(Unknown Source)
at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at 
org.jenkinsci.plugins.gitclient.RemoteGitImpl$CommandInvocationHandler.invoke(RemoteGitImpl.java:132)
at com.sun.proxy.$Proxy137.execute(Unknown Source)
at hudson.plugins.git.GitSCM.retrieveChanges(GitSCM.java:1120)
at hudson.plugins.git.GitSCM.checkout(GitSCM.java:1160)
at hudson.scm.SCM.checkout(SCM.java:495)
at 
hudson.model.AbstractProject.checkout(AbstractProject.java:1202)
at 
hudson.model.AbstractBuild$AbstractBuildExecution.defaultCheckout(AbstractBuild.java:574)
at 
jenkins.scm.SCMCheckoutStrategy.checkout(SCMCheckoutStrategy.java:86)
at 
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:499)
at hudson.model.Run.execute(Run.java:1724)
at 
hudson.maven.MavenModuleSetBuild.run(MavenModuleSetBuild.java:543)
at 
hudson.model.ResourceController.execute(ResourceController.java:97)
at hudson.model.Executor.run(Executor.java:429)
Caused by: hudson.plugins.git.GitException: Error performing git command
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:2005)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:1964)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:1960)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommand(CliGitAPIImpl.java:1597)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl$5.execute(CliGitAPIImpl.java:770)
... 11 more
Caused by: java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:717)
at hudson.Proc$LocalProc.(Proc.java:269)
at hudson.Proc$LocalProc.(Proc.java:218)
at hudson.Launcher$LocalLauncher.launch(Launcher.java:930)
at hudson.Launcher$ProcStarter.start(Launcher.java:450)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:1992)
... 15 more
ERROR: Error cloning remote repo 'origin'
Retrying after 10 seconds
 > git rev-parse --is-inside-work-tree # timeout=10
ERROR: Workspace has a .git repository, but it appears to be corrupt.
hudson.plugins.git.GitException: Error performing git command
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:2005)
at 
org.jenkinsci.plugins.gitclient.CliGitAPIImpl.launchCommandIn(CliGitAPIImpl.java:1964)
at

[2/3] activemq-artemis git commit: NO-JIRA: Simplifying AMQP JMS LargeMessage test

2018-04-27 Thread clebertsuconic

NO-JIRA: Simplifying AMQP JMS LargeMessage test


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

Branch: refs/heads/master
Commit: 6d2a464319034ce01190a72c7ed9105a8270de2b
Parents: 8a73fdd
Author: Clebert Suconic 
Authored: Fri Apr 27 10:12:28 2018 -0400
Committer: Clebert Suconic 
Committed: Fri Apr 27 10:16:37 2018 -0400

--
 .../amqp/JMSDurableConsumerTest.java| 32 +---
 1 file changed, 7 insertions(+), 25 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6d2a4643/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
index 13453a0..00ea410 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
@@ -38,6 +38,7 @@ import javax.jms.Topic;
 import org.apache.activemq.artemis.api.core.client.ActiveMQClient;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
 import org.apache.activemq.artemis.tests.util.Wait;
+import org.junit.Assert;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.Parameterized;
@@ -244,32 +245,13 @@ public class JMSDurableConsumerTest extends 
JMSClientTestSupport {
  objMessage.setObject(bigObject);
  producer.send(objMessage);
 
- final AtomicReference msg1 = new AtomicReference<>();
- final AtomicReference msg2 = new AtomicReference<>();
+ ObjectMessage msg1 = (ObjectMessage)consumer1.receive(5000);
+ Assert.assertNotNull(msg1);
+ assertTrue("Should be an instance of TextMessage", msg1 instanceof 
ObjectMessage);
 
- assertTrue(Wait.waitFor(new Wait.Condition() {
-
-@Override
-public boolean isSatisfied() throws Exception {
-   msg1.set(consumer1.receiveNoWait());
-   return msg1.get() != null;
-}
- }, TimeUnit.SECONDS.toMillis(25), 
TimeUnit.MILLISECONDS.toMillis(200)));
-
- assertTrue(Wait.waitFor(new Wait.Condition() {
-
-@Override
-public boolean isSatisfied() throws Exception {
-   msg2.set(consumer2.receiveNoWait());
-   return msg2.get() != null;
-}
- }, TimeUnit.SECONDS.toMillis(25), 
TimeUnit.MILLISECONDS.toMillis(200)));
-
- assertNotNull("Should have received a message by now.", msg1.get());
- assertTrue("Should be an instance of TextMessage", msg1.get() 
instanceof ObjectMessage);
-
- assertNotNull("Should have received a message by now.", msg2.get());
- assertTrue("Should be an instance of TextMessage", msg2.get() 
instanceof ObjectMessage);
+ ObjectMessage msg2 = (ObjectMessage)consumer2.receive(5000);
+ assertNotNull("Should have received a message by now.", msg2);
+ assertTrue("Should be an instance of TextMessage", msg2 instanceof 
ObjectMessage);
   } finally {
  connection.close();
   }

[1/3] activemq-artemis git commit: NO-JIRA: Added a AMQP JMS LargeMessage test

2018-04-27 Thread clebertsuconic

Repository: activemq-artemis
Updated Branches:
  refs/heads/master d3c83898f -> be61adc00


NO-JIRA: Added a AMQP JMS LargeMessage test


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

Branch: refs/heads/master
Commit: 8a73fdd3a243ac8c3f0cd8063bd43ed96bfa82d0
Parents: d3c8389
Author: Howard Gao 
Authored: Fri Apr 27 20:22:28 2018 +0800
Committer: Clebert Suconic 
Committed: Fri Apr 27 10:12:34 2018 -0400

--
 .../amqp/JMSDurableConsumerTest.java| 65 
 1 file changed, 65 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/8a73fdd3/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
--
diff --git 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
index 31de59d..13453a0 100644
--- 
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
+++ 
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMSDurableConsumerTest.java
@@ -16,6 +16,7 @@
  */
 package org.apache.activemq.artemis.tests.integration.amqp;
 
+import java.io.Serializable;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.concurrent.CountDownLatch;
@@ -29,10 +30,12 @@ import javax.jms.Message;
 import javax.jms.MessageConsumer;
 import javax.jms.MessageListener;
 import javax.jms.MessageProducer;
+import javax.jms.ObjectMessage;
 import javax.jms.Session;
 import javax.jms.TextMessage;
 import javax.jms.Topic;
 
+import org.apache.activemq.artemis.api.core.client.ActiveMQClient;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
 import org.apache.activemq.artemis.tests.util.Wait;
 import org.junit.Test;
@@ -221,4 +224,66 @@ public class JMSDurableConsumerTest extends 
JMSClientTestSupport {
  connection.close();
   }
}
+
+   @Test(timeout = 3)
+   public void testDurableConsumerLarge() throws Exception {
+  String durableClientId = getTopicName() + "-ClientId";
+
+  Connection connection = createConnection(durableClientId);
+  try {
+ Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
+ Topic topic = session.createTopic(getTopicName());
+ final MessageConsumer consumer1 = 
session.createDurableSubscriber(topic, "DurbaleSub1");
+ final MessageConsumer consumer2 = 
session.createDurableSubscriber(topic, "DurbaleSub2");
+ MessageProducer producer = session.createProducer(topic);
+ producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+ connection.start();
+
+ ObjectMessage objMessage = session.createObjectMessage();
+ BigObject bigObject = new 
BigObject(ActiveMQClient.DEFAULT_MIN_LARGE_MESSAGE_SIZE);
+ objMessage.setObject(bigObject);
+ producer.send(objMessage);
+
+ final AtomicReference msg1 = new AtomicReference<>();
+ final AtomicReference msg2 = new AtomicReference<>();
+
+ assertTrue(Wait.waitFor(new Wait.Condition() {
+
+@Override
+public boolean isSatisfied() throws Exception {
+   msg1.set(consumer1.receiveNoWait());
+   return msg1.get() != null;
+}
+ }, TimeUnit.SECONDS.toMillis(25), 
TimeUnit.MILLISECONDS.toMillis(200)));
+
+ assertTrue(Wait.waitFor(new Wait.Condition() {
+
+@Override
+public boolean isSatisfied() throws Exception {
+   msg2.set(consumer2.receiveNoWait());
+   return msg2.get() != null;
+}
+ }, TimeUnit.SECONDS.toMillis(25), 
TimeUnit.MILLISECONDS.toMillis(200)));
+
+ assertNotNull("Should have received a message by now.", msg1.get());
+ assertTrue("Should be an instance of TextMessage", msg1.get() 
instanceof ObjectMessage);
+
+ assertNotNull("Should have received a message by now.", msg2.get());
+ assertTrue("Should be an instance of TextMessage", msg2.get() 
instanceof ObjectMessage);
+  } finally {
+ connection.close();
+  }
+   }
+
+   public static class BigObject implements Serializable {
+
+  private char[] contents;
+
+  public BigObject(int size) {
+ contents = new char[size];
+ for (int i

Jenkins build is still unstable: ActiveMQ-Java8-All-UnitTests #805

2018-04-27 Thread Apache Jenkins Server

See

Build failed in Jenkins: ActiveMQ-Artemis-Master #1779

2018-04-27 Thread Apache Jenkins Server

See 


Changes:

[clebertsuconic] NO-JIRA: Added a AMQP JMS LargeMessage test

[clebertsuconic] NO-JIRA: Simplifying AMQP JMS LargeMessage test

--
[...truncated 311.08 KB...]
shouldStartTwoIfTableNotExist(org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManagerTest)
  Time elapsed: 10.735 sec  <<< ERROR!
java.lang.Exception: test timed out after 1 milliseconds
at java.io.FileDescriptor.sync(Native Method)
at org.apache.derby.impl.io.DirRandomAccessFile.sync(Unknown Source)
at 
org.apache.derby.impl.store.raw.data.RAFContainer.writeRAFHeader(Unknown Source)
at org.apache.derby.impl.store.raw.data.RAFContainer.run(Unknown Source)
at java.security.AccessController.doPrivileged(Native Method)
at 
org.apache.derby.impl.store.raw.data.RAFContainer.createContainer(Unknown 
Source)
at 
org.apache.derby.impl.store.raw.data.RAFContainer4.createContainer(Unknown 
Source)
at 
org.apache.derby.impl.store.raw.data.FileContainer.createIdent(Unknown Source)
at 
org.apache.derby.impl.store.raw.data.FileContainer.createIdentity(Unknown 
Source)
at org.apache.derby.impl.services.cache.ConcurrentCache.create(Unknown 
Source)
at 
org.apache.derby.impl.store.raw.data.BaseDataFileFactory.addContainer(Unknown 
Source)
at org.apache.derby.impl.store.raw.xact.Xact.addContainer(Unknown 
Source)
at org.apache.derby.impl.store.access.heap.Heap.create(Unknown Source)
at 
org.apache.derby.impl.store.access.heap.HeapConglomerateFactory.createConglomerate(Unknown
 Source)
at 
org.apache.derby.impl.store.access.RAMTransaction.createConglomerate(Unknown 
Source)
at 
org.apache.derby.impl.sql.execute.CreateTableConstantAction.executeConstantAction(Unknown
 Source)
at org.apache.derby.impl.sql.execute.MiscResultSet.open(Unknown Source)
at 
org.apache.derby.impl.sql.GenericPreparedStatement.executeStmt(Unknown Source)
at org.apache.derby.impl.sql.GenericPreparedStatement.execute(Unknown 
Source)
at org.apache.derby.impl.jdbc.EmbedStatement.executeStatement(Unknown 
Source)
at org.apache.derby.impl.jdbc.EmbedStatement.execute(Unknown Source)
at org.apache.derby.impl.jdbc.EmbedStatement.executeLargeUpdate(Unknown 
Source)
at org.apache.derby.impl.jdbc.EmbedStatement.executeUpdate(Unknown 
Source)
at 
org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver.createTableIfNotExists(AbstractJDBCDriver.java:243)
at 
org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver.createTable(AbstractJDBCDriver.java:113)
at 
org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManager.createSchema(JdbcSharedStateManager.java:106)
at 
org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver.start(AbstractJDBCDriver.java:82)
at 
org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManager.usingConnectionUrl(JdbcSharedStateManager.java:96)
at 
org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManager.usingConnectionUrl(JdbcSharedStateManager.java:74)
at 
org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManagerTest.createSharedStateManager(JdbcSharedStateManagerTest.java:52)
at 
org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManagerTest.shouldStartTwoIfTableNotExist(JdbcSharedStateManagerTest.java:98)

shouldStartIfTableExistInitialized(org.apache.activemq.artemis.core.server.impl.jdbc.JdbcSharedStateManagerTest)
  Time elapsed: 11.731 sec  <<< ERROR!
java.lang.Exception: test timed out after 1 milliseconds
at java.io.FileDescriptor.sync(Native Method)
at org.apache.derby.impl.io.DirRandomAccessFile.sync(Unknown Source)
at 
org.apache.derby.impl.store.raw.data.RAFContainer.writeRAFHeader(Unknown Source)
at org.apache.derby.impl.store.raw.data.RAFContainer.run(Unknown Source)
at java.security.AccessController.doPrivileged(Native Method)
at 
org.apache.derby.impl.store.raw.data.RAFContainer.createContainer(Unknown 
Source)
at 
org.apache.derby.impl.store.raw.data.RAFContainer4.createContainer(Unknown 
Source)
at 
org.apache.derby.impl.store.raw.data.FileContainer.createIdent(Unknown Source)
at 
org.apache.derby.impl.store.raw.data.FileContainer.createIdentity(Unknown 
Source)
at org.apache.derby.impl.services.cache.ConcurrentCache.create(Unknown 
Source)
at 
org.apache.derby.impl.store.raw.data.BaseDataFileFactory.addContainer(Unknown 
Source)
at org.apache.derby.impl.store.raw.xact.Xact.addContainer(Unknown 
Source)
at org.apache.derby.impl.store.access.btree.BTree.create(Unknown Source)
at org.apache.derby.impl.store.access.btree.index.B2I.create(Unknown

[3/3] activemq-artemis git commit: This closes #2049

2018-04-27 Thread clebertsuconic

This closes #2049


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

Branch: refs/heads/master
Commit: be61adc00254ca88820062e82b710e32c8204381
Parents: d3c8389 6d2a464
Author: Clebert Suconic 
Authored: Fri Apr 27 10:16:51 2018 -0400
Committer: Clebert Suconic 
Committed: Fri Apr 27 10:16:51 2018 -0400

--
 .../amqp/JMSDurableConsumerTest.java| 47 
 1 file changed, 47 insertions(+)
--