Commit Graph

8232 Commits

Author SHA1 Message Date
gtully 52e1a05aaa https://issues.apache.org/jira/browse/AMQ-5347 - variant of patch and additional tests applied, prefetch=0 test without restart exposed ordering bug with fix for https://issues.apache.org/jira/browse/AMQ-2719 2014-10-31 16:40:41 +00:00
Timothy Bish 0b148ade32 https://issues.apache.org/jira/browse/AMQ-5402
Revert the changes here as the mapping is moving in a different
direction.

4881a848dc
2014-10-29 14:16:34 -04:00
Dejan Bosanac dffccb1c7d https://issues.apache.org/jira/browse/AMQ-5417 - use proper classloader in TaskRunnerFactory 2014-10-29 11:30:15 +01:00
Timothy Bish adafdfe97d Make BrokerService visible to the protocol converter so that in the
future we can use it to better manage durable subscriptions and link
reattach behavior.
2014-10-28 14:58:17 -04:00
gtully 135226533f https://issues.apache.org/jira/browse/AMQ-5394 - applied patch for kahadb lastUpdate tracking from Jesse Fugitt with thanks 2014-10-24 14:42:25 +01:00
gtully 350889c1eb https://issues.apache.org/jira/browse/AMQ-5266 - fix regression in levedlb xa recovery and durable sub scan - org.apache.activemq.broker.mLevelDBXARecoveryBrokerTest and org.apache.activemq.bugs.AMQ2149LevelDBTest 2014-10-24 14:28:00 +01:00
Timothy Bish 1948fe41a3 https://issues.apache.org/jira/browse/AMQ-5407
Allow config of enabled protocols for nio+ssl and stomp+nio+ssl etc to
match the capability of the non-nio transports.
2014-10-23 15:03:35 -04:00
gtully 33089f3fbb https://issues.apache.org/jira/browse/AMQ-5266 track cursor pending additions size in debug logging 2014-10-23 16:56:24 +01:00
gtully 3042797b41 https://issues.apache.org/jira/browse/AMQ-5266 tidy up leveldb impl with additional scenario tests 2014-10-23 16:29:57 +01:00
Timothy Bish 642cc43216 https://issues.apache.org/jira/browse/AMQ-5406
Add support for disable of consumer expiration checks.
2014-10-22 14:42:45 -04:00
Timothy Bish e3377edb06 https://issues.apache.org/jira/browse/AMQ-5401
Free the broker side sender right away so that client's that don't close
their end properly after error don't prevent future remove attempts.
2014-10-22 10:48:11 -04:00
gtully 8b8f630080 isolate cursor storeHasMessage logic into durable topic sub cursor b/c only durable sub cursors have selectors that won't match, otherwise we should always read a page if the store has messages 2014-10-21 23:23:15 +01:00
Timothy Bish 74d2c2425f https://issues.apache.org/jira/browse/AMQ-5390
Adds a test case to show that things work as expected.
2014-10-21 17:59:32 -04:00
Timothy Bish d9d9d5b666 https://issues.apache.org/jira/browse/AMQ-5389
https://issues.apache.org/jira/browse/AMQ-5387

Fixes some issues around processing of back to back frames and reading
of null blocks between messages.
2014-10-21 17:14:47 -04:00
Timothy Bish 6c4f15e220 https://issues.apache.org/jira/browse/AMQ-5381
Apply fix and test for error when restoring old content and treating it
as compressed when it was not.
2014-10-21 17:14:47 -04:00
gtully 67ead201e1 https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - single dest test with low limit exposed ignored setbatch in kahadb when sequence was not found in the index due to acking - resolved and validated with test that verifies dlq is empty 2014-10-21 16:05:46 +01:00
Dejan Bosanac ab3de0c4c2 https://issues.apache.org/jira/browse/AMQ-5379 - amqp prefetch; split producer and consumer prefetch settings; allow consumer prefetch to be adjusted using link credit 2014-10-21 14:52:39 +02:00
Timothy Bish 3873ecfe5d https://issues.apache.org/jira/browse/AMQ-5396
Reviewed the patch and it looks good, I made a small change to prevent
logging in the case where no old context exists so we don't spam the
logs.
2014-10-20 19:06:21 -04:00
Timothy Bish 6885ff0a62 https://issues.apache.org/jira/browse/AMQ-5365
Trap VirtualTopic names that leak from messages sent across a broker
network.
2014-10-20 15:05:08 -04:00
Timothy Bish 4881a848dc https://issues.apache.org/jira/browse/AMQ-5402
Add support for encoding the destination type in transformed messages as
a byte value to supoort future JMS->AMQP spec mappings.
2014-10-20 09:49:36 -04:00
Timothy Bish 5a6129b512 https://issues.apache.org/jira/browse/AMQ-5403
Remove now unnecessary workaround for older proton-j TTL issue.
2014-10-20 09:42:56 -04:00
Timothy Bish 004568234b https://issues.apache.org/jira/browse/AMQ-5401
Ensure that the sender is closed on error and add some tests for
unsubscribe failures.
2014-10-17 14:58:56 -04:00
Timothy Bish 226e012d88 Restore test case removed last commit. 2014-10-17 12:22:27 -04:00
gtully 1d39f08c12 https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - fix warn logging from kahadb on set batch when message already consumed using seq from messageId, additional single dest test that hammers this case 2014-10-17 16:55:23 +01:00
Dejan Bosanac 28b45341d1 https://issues.apache.org/jira/browse/AMQ-5399 - mqtt - out of order acks 2014-10-17 14:40:33 +02:00
gtully 1a0bd45a4e https://issues.apache.org/jira/browse/AMQ-4485 - leveldb version - shows the need to flag async adds so they can get suppressed as duplicates \(and not go to the dlq\) when the cursor order is out of sync on cache full 2014-10-17 13:35:31 +01:00
gtully 4705f95bec https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - tidy up exception trace and async check, fix leveldb async test regressions 2014-10-17 11:25:47 +01:00
Kevin Earls 76e29bdf9c Changed or added timeouts to try to prevent CI hangs 2014-10-17 12:03:04 +02:00
gtully 51a2596c52 run leveldb tests on osx 2014-10-16 23:53:44 +01:00
gtully 9c2b1d2572 https://issues.apache.org/jira/browse/AMQ-5266 https://issues.apache.org/jira/browse/AMQ-4485 - store has messages must be aware of pending also kahadb setBatch for async sends. additional tests and tidy up of cusror sync with store to reflect async/sync additions 2014-10-16 23:35:18 +01:00
gtully 243db1c289 rework npe avoidance in vmtransport stop to resolve thread leakage test failure 2014-10-16 23:35:18 +01:00
gtully 2050498c67 ensure vm transport is started in this test so that stop does some work 2014-10-16 23:35:18 +01:00
gtully 5f865f0f80 fix off by one in this unit test 2014-10-16 23:35:17 +01:00
gtully 8216e7f4d5 https://issues.apache.org/jira/browse/AMQ-4930 - limit browse page in iterations in case cursor and store are out of sync - avoid a spin when store does not return messages 2014-10-16 23:35:17 +01:00
Timothy Bish 41ca0d9464 Add a test case for durable topic unsubscribe. 2014-10-16 16:11:26 -04:00
Timothy Bish e90f1decb2 https://issues.apache.org/jira/browse/AMQ-5391
Fix temp queue creation.
2014-10-15 10:35:36 -04:00
Timothy Bish 78cb1120b7 https://issues.apache.org/jira/browse/AMQ-5391
Allow for an anonymous relay using a configurable node name when
creating the new link, default is $relay.  Message's that arrive without
a to field set are rejected as this is required for a relay.
2014-10-14 17:32:23 -04:00
Timothy Bish 27833d025e Remove unused imports 2014-10-14 11:47:48 -04:00
Timothy Bish 78446ad175 https://issues.apache.org/jira/browse/AMQ-5395
Check for the presence of a prefix before asking for a substring
2014-10-14 11:46:49 -04:00
gtully 0cf7c0bc47 add trace logging to cursor page in 2014-10-09 22:16:54 +01:00
Timothy Bish 62c20ebdcf Apply fix and add test for:
https://issues.apache.org/jira/browse/AMQ-5385
2014-10-09 12:40:13 -04:00
gtully 97c127d2d4 https://issues.apache.org/jira/browse/AMQ-4485 - fix test regression with browse test - AMQ4595Test - reduce replay window when sync and asnyc cursor updates flip message order - concurrentStoreAndDispatch=true - https://issues.apache.org/jira/browse/AMQ-5266 - increse default audit depth to match async jobs for concurrent store 2014-10-09 13:47:31 +01:00
gtully a56996dd6c avoid npe on network bridge failure, dispose when not started on vm transport 2014-10-09 13:44:30 +01:00
gtully ad770ea79d https://issues.apache.org/jira/browse/AMQ-5384 - apply variant of patch from Tomasz Skorka with thanks 2014-10-07 15:54:21 +01:00
gtully b5581166be https://issues.apache.org/jira/browse/AMQ-5182 - apply patch from colin mondesir with thanks 2014-10-07 15:11:31 +01:00
gtully 140ce1bc8f https://issues.apache.org/jira/browse/AMQ-4485 - reenable test. concurrentStoreandDispatch case cannot be reconciled via setBatch, best we can do is trap duplicates from inflight messages as they occur. tagged async stores to support this. the revert of serialization with tx and non aysnc send brings perf back to where it was. https://issues.apache.org/jira/browse/AMQ-5266 2014-10-07 14:50:41 +01:00
gtully c1c82beb2d fix deadlock that blocks remote broker start in duplex case with durable sub recreation on restart - dynamicOnly=true works around 2014-10-07 14:50:41 +01:00
gtully 57fc29b6ce remove npe when no jars on classpath, in ide 2014-10-07 14:50:41 +01:00
Dejan Bosanac 838bbebeeb https://issues.apache.org/jira/browse/AMQ-5379 - amqp prefetch size 2014-10-02 11:32:31 +02:00
Dejan Bosanac fc3d90e8b7 https://issues.apache.org/jira/browse/AMQ-5377 - mqtt wildcard conversion 2014-10-01 12:18:32 +02:00