[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246602226 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/ConcurrentAppendOnlyChunkedList.java --- @@ -0,0 +1,291

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246602031 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user clebertsuconic commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246601217 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/ConcurrentAppendOnlyChunkedList.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user clebertsuconic commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246601169 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r24662 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -28,15 +28,49 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246599701 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246578304 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246577156 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246574781 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246574775 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246570552 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java --- @@ -864,21 +875,32 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246570293 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java --- @@ -864,21

[GitHub] activemq-artemis pull request #2483: ARTEMIS-2215 largemessage have been con...

Github user asfgit closed the pull request at: https://github.com/apache/activemq-artemis/pull/2483 ---

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246569626 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246569523 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246568743 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246568579 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246568552 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246568367 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54 +82,228 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246567995 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246567905 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -28,15 +28,49 @@

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246566042 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -48,54

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246563763 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -28,15

[GitHub] activemq-artemis pull request #2466: ARTEMIS-2206 The MQTT consumer reconnec...

Github user jbertram commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2466#discussion_r246563323 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/mqtt/imported/MQTTQueueCleanTest.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2466: ARTEMIS-2206 The MQTT consumer reconnec...

Github user jbertram commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2466#discussion_r246562512 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java --- @@ -3604,4 +3605,14 @@ private

[GitHub] activemq-artemis pull request #2489: ARTEMIS-2220 Fix PageCursorStressTest::...

Github user asfgit closed the pull request at: https://github.com/apache/activemq-artemis/pull/2489 ---

[GitHub] activemq-artemis pull request #2491: ARTEMIS-2217 remove state on clean MQTT...

Github user asfgit closed the pull request at: https://github.com/apache/activemq-artemis/pull/2491 ---

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

Github user clebertsuconic commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2494#discussion_r246558406 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/LivePageCacheImpl.java --- @@ -28,15 +28,49 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246558298 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246557671 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246555304 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2492: ARTEMIS-2222 why the position remains u...

Github user asfgit closed the pull request at: https://github.com/apache/activemq-artemis/pull/2492 ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246551345 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #2492: ARTEMIS-2222 why the position remains u...

Github user clebertsuconic commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2492#discussion_r246538095 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/cursor/impl/PageSubscriptionImpl.java --- @@ -1315,9

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246525755 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246523218 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246521520 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246520970 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiResettableIterator.java --- @@ -0,0 +1,44

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246520411 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246520138 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246520110 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246520121 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246518747 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246518669 --- Diff:

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246518313 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246516870 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246516479 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246515810 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java --- @@ -2409,14 +2410,10 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246515455 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java --- @@ -2497,45 +2484,36 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246513536 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@

[GitHub] activemq-artemis pull request #:

Github user clebertsuconic commented on the pull request: https://github.com/apache/activemq-artemis/commit/0f9bf15788096ad9dc795954174c3b496861932c#commitcomment-31886537 In artemis-ra/src/main/java/org/apache/activemq/artemis/ra/inflow/ActiveMQMessageHandler.java: In

[GitHub] activemq-artemis pull request #2485: ARTEMIS-2217 ‘MQTTSessionState’ in ...

Github user onlyMIT closed the pull request at: https://github.com/apache/activemq-artemis/pull/2485 ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246416127 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246398611 --- Diff: artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246403272 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/QueueConsumerPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246383235 --- Diff: artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246382311 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246337126 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246338675 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/PriorityCollection.java --- @@ -0,0 +1,319 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246377289 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java --- @@ -2409,14 +2410,10 @@ private void

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246374340 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246313269 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/* + *

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246323500 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/* + *

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246375651 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246323998 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiResettableIterator.java --- @@ -0,0 +1,44 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246376376 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246323602 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/* + *

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246322551 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/* + *

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246344280 --- Diff: artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246377787 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java --- @@ -2497,45 +2484,36 @@ private void

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246321398 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiIterator.java --- @@ -0,0 +1,78 @@ +/* + *

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246376356 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246323811 --- Diff: artemis-commons/src/main/java/org/apache/activemq/artemis/utils/collections/MultiResettableIterator.java --- @@ -0,0 +1,44 @@

[GitHub] activemq-artemis pull request #2490: V2 196

Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246376178 --- Diff: artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueConsumersImpl.java --- @@ -0,0 +1,124 @@ +/*

[GitHub] activemq-artemis pull request #1793: ARTEMIS-1498: Openwire internal headers...

Github user RaiSaurabh closed the pull request at: https://github.com/apache/activemq-artemis/pull/1793 ---

[GitHub] activemq-artemis pull request #2494: ARTEMIS-2224 Reduce contention on LiveP...

GitHub user franz1981 opened a pull request: https://github.com/apache/activemq-artemis/pull/2494 ARTEMIS-2224 Reduce contention on LivePageCacheImpl It includes: - **lock-free LivePageCache + tests**: LivePageCacheImpl has been reimplemented to be lock-free,

[GitHub] activemq-artemis pull request #2491: ARTEMIS-2217 remove state on clean MQTT...

Github user onlyMIT commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2491#discussion_r246247094 --- Diff: artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSession.java --- @@ -117,14

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246140306 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246140214 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246140041 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246135818 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/client/ConsumerPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246135697 --- Diff: artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246135542 --- Diff:

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246133832 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/client/ConsumerPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246132135 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/amq/QueueConsumerPriorityTest.java

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246128551 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246128143 --- Diff:

[GitHub] activemq-artemis pull request #2490: V2 196

Github user michaelandrepearce commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r246127864 --- Diff:

[GitHub] activemq-artemis pull request #2491: ARTEMIS-2217 remove state on clean MQTT...

Github user jbertram commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2491#discussion_r246123082 --- Diff: artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSession.java --- @@ -117,14

[GitHub] activemq-artemis pull request #2493: ARTEMIS-2223 when a new consumer is cre...

Github user onlyMIT closed the pull request at: https://github.com/apache/activemq-artemis/pull/2493 ---

[GitHub] activemq-artemis pull request #2491: ARTEMIS-2217 remove state on clean MQTT...

Github user onlyMIT commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2491#discussion_r246095670 --- Diff: artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSession.java --- @@ -117,14

[GitHub] activemq-artemis pull request #2491: ARTEMIS-2217 remove state on clean MQTT...

Github user jbertram commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2491#discussion_r246075935 --- Diff: artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSession.java --- @@ -117,14

[GitHub] activemq-artemis pull request #2467: ARTEMIS-2205 Performance improvements o...

Github user clebertsuconic commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2467#discussion_r246058995 --- Diff:

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245974624 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245973668 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245968414 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/client/ConsumerPriorityTest.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245955337 --- Diff: artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245973707 --- Diff: tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpReceiverPriorityTest.java --- @@ -0,0

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245953999 --- Diff: artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/wireformat/SessionCreateConsumerMessage.java ---

[GitHub] activemq-artemis pull request #2490: V2 196

Github user gemmellr commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/2490#discussion_r245965929 --- Diff: artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPSessionCallback.java ---

  1   2   3   4   5   6   7   8   9   10   >