Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #203 - fixes mainly for test-suite

This commit is contained in:
jbertram 2015-04-09 14:14:52 -05:00
parent 238b2fe094 2fa74d0157
commit d9c9fc0e9e
5 changed files with 19 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-server/src/main/java/org/apache/activemq/core/paging/cursor/impl/PageSubscriptionImpl.java
View File

@ -1471,12 +1471,13 @@ final class PageSubscriptionImpl implements PageSubscription
public void remove()
{
deliveredCount.incrementAndGet();
if (currentDelivery != null)
PagedReference delivery = currentDelivery;
if (delivery != null)
{
PageCursorInfo info = PageSubscriptionImpl.this.getPageInfo(currentDelivery.getPosition());
PageCursorInfo info = PageSubscriptionImpl.this.getPageInfo(delivery.getPosition());
if (info != null)
{
info.remove(currentDelivery.getPosition());
info.remove(delivery.getPosition());
}
}
}

5
activemq-server/src/main/java/org/apache/activemq/core/transaction/impl/TransactionImpl.java
View File

@ -167,7 +167,10 @@ public class TransactionImpl implements Transaction
// so we reset it now
beforeRollback();
afterRollback();
operations.clear();
if (operations != null)
{
operations.clear();
}
throw exception;
}
else

2
pom.xml
View File

@ -203,7 +203,7 @@
<dependency>
<groupId>org.jboss.logging</groupId>
<artifactId>jboss-logging-processor</artifactId>
<version>2.0.0.Alpha1</version>
<version>2.0.0.Alpha2</version>
<optional>true</optional>
<!-- License: LGPL-->
</dependency>

1
tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/DuplicateDetectionTest.java
View File

@ -1245,6 +1245,7 @@ public class DuplicateDetectionTest extends ServiceTestBase
}
catch (XAException expected)
{
assertTrue(expected.getCause().toString().contains("DUPLICATE_ID_REJECTED"));
}
session.rollback(xid2);

20
tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/client/HangConsumerTest.java
View File

@ -15,12 +15,7 @@
* limitations under the License.
*/
package org.apache.activemq.tests.integration.client;
import org.apache.activemq.api.core.ActiveMQException;
import org.apache.activemq.core.server.ServerConsumer;
import org.junit.Before;
import org.junit.After;
import org.junit.Test;
import javax.management.MBeanServer;
import java.lang.management.ManagementFactory;
import java.util.LinkedList;
import java.util.concurrent.CountDownLatch;
@ -29,9 +24,7 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
import javax.management.MBeanServer;
import org.junit.Assert;
import org.apache.activemq.api.core.ActiveMQException;
import org.apache.activemq.api.core.Interceptor;
import org.apache.activemq.api.core.SimpleString;
import org.apache.activemq.api.core.client.ClientConsumer;
@ -56,6 +49,7 @@ import org.apache.activemq.core.protocol.core.Packet;
import org.apache.activemq.core.protocol.core.impl.wireformat.SessionReceiveMessage;
import org.apache.activemq.core.server.ActiveMQServer;
import org.apache.activemq.core.server.Queue;
import org.apache.activemq.core.server.ServerConsumer;
import org.apache.activemq.core.server.ServerMessage;
import org.apache.activemq.core.server.ServerSessionFactory;
import org.apache.activemq.core.server.impl.ActiveMQServerImpl;
@ -72,6 +66,10 @@ import org.apache.activemq.spi.core.security.ActiveMQSecurityManagerImpl;
import org.apache.activemq.tests.util.ServiceTestBase;
import org.apache.activemq.utils.ExecutorFactory;
import org.apache.activemq.utils.ReusableLatch;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
/**
* This test will simulate a consumer hanging on the delivery packet due to unbehaved clients
@ -150,8 +148,8 @@ public class HangConsumerTest extends ServiceTestBase
sessionProducer.commit();
// These three operations should finish without the test hanging
getMessagesAdded(queue);
getMessageCount(queue);
queue.getMessagesAdded();
queue.getMessageCount();
releaseConsumers();