ea70e827c0
AMQ-6707 - JDBC XA recovery and completion.
...
ensure pending transactions are visible for recovery without restart
sync store and cursor size during and after completion
ensure pending messages are not visible to browsers
retain transaction state on jdbc error
a bunch of new tests around xa completion
2018-04-26 14:58:48 +01:00
84126d8a7a
AMQ-6940 - test fix for AMQ6477 test
...
Need to remove the portion of the test that looks at the dispatched list
for TopicSubscription as that class no longer tracks message references
2018-03-30 06:34:36 -04:00
65b0f2ad0d
AMQ-6940 - Add flag to disable TopicSubscription in flight stats
...
To save memory usage in some use cases add a new flag to PolicyEntry
called useTopicSubscriptionInflightStats to allow disabling the
inflight stats
2018-03-29 13:25:36 -04:00
060817552d
[AMQ-4261] use WARN level for producer flow control events, DEBUG if blockedProducerWarningInterval=0
2018-03-02 12:17:24 +00:00
b57f4f3211
[no jira] extend the timeout b/c it was on the margins
2018-03-01 11:38:16 +00:00
82c9f9531e
[AMQ-6907] add selectorAware option to conditionalNetworkBridgeFilterFactory such that replay back to origin can happen if there are no matching local consumers
2018-02-28 16:07:52 +00:00
efaf9cd77e
[AMQ-6906] jdbc store; ensure rolled back prepared ack messages are recovered asap
2018-02-28 13:31:12 +00:00
dd2572bcb1
[AMQ-6891] test and fix non tx variant of this leak
2018-01-30 10:51:30 +00:00
e5de25f4fc
NO-JIRA: Add missing license headers
2018-01-29 08:10:50 -05:00
f96a20e831
[AMQ-6891] apply fix and test from Radek Kraus with thanks. Pending cursor adds are now dropped on rollback
2018-01-26 13:18:00 +00:00
ec6fa19099
[AMQ-6815] rework to drop the batch reference from Location such that batches are free for gc when index pages are agressively cached
2018-01-11 12:56:40 +00:00
a8a032af09
AMQ-6861 Allow customisation of network bridge creation logic.
2017-12-20 22:00:54 -05:00
b40e5f93bd
[AMQ-6601] AMQ with master and slave broker, shutting down slave causes dead-lock.
2017-12-18 23:08:22 -05:00
56baba96c6
AMQ-6875 - Use the correct destination for Virtual destination consumers
...
when using Virtual Topics
2017-12-14 16:01:10 -05:00
5fa0bbd515
AMQ-6871 - By default only send generic platform details
...
The default behavior by the OpenWire client will be to send generic
platform details to the server with a new flag to send more specific
information.
2017-12-06 08:41:51 -05:00
08aa5118ff
(AMQ-6858) - add extra precautionary check for demand subs
...
also remove test that intermittently fails with timing issues
2017-11-16 07:44:33 -05:00
2e3a7f6114
(AMQ-6858) - test fix
2017-11-15 09:21:44 -05:00
6013441a9a
AMQ-6858 - handle resync of network proxy durables after restart
...
We need to properly handle the re-addition of network proxy durables
after the brokers are restarted so removal is done properly
2017-11-15 08:56:43 -05:00
3ca439cada
AMQ-6858 - Allow configuration of the client Id token in network bridge
...
The client id token that is used to separate parts of a generated local
client id in a network bridge should be configurable so bridge names and
broker names can contain underscores if desired
2017-11-14 15:23:26 -05:00
41211c78d1
AMQ-6858 - reworking durable subscription propagation fix
...
Significantly reworking previous fix so that the client id is properly
changed when tracking network proxy subscriptions. This makes it so
removal is done properly
2017-11-13 11:07:43 -05:00
96ce14b278
AMQ-6858 - Fix several durable subscription bridge propagation issues
...
Durable network proxy subs will now be properly created across multiple
bridges when 3 or more brokers are used. Demand will be properly synced
and removed.
2017-11-09 11:21:18 -05:00
b29ccf3488
[AMQ-6854] log warn if page in is blocked on usage preventing dispatch. Reuse blockedProducerWarningInterval to tweak reporting
2017-11-02 16:04:30 +00:00
03b19b9da4
[AMQ-6847] limit the retry loop to one iteration overa all pending messages such that new additions are not replayed to avoid duplicates
2017-11-01 11:26:36 +00:00
2ea5d1420b
[AMQ-6847] pause dispatch for message move to avoid redelivery with pending ack/remove/audit rollback
2017-10-27 11:40:06 +01:00
005403e94b
[no jira] more lenient for ci builds - intermittetnt failure
2017-10-27 11:37:04 +01:00
8e576be1d9
[AMQ-6849] - fix sendFailIfNoSpaceAfterTimeout policy entry default value
2017-10-26 11:36:03 +01:00
6da08b245e
[AMQ-6849] provide a virtualTopic dropOnResourceLimit attribute, default to false.
...
Enabling will allow dispatch to continue even when end to some consumer queues
fail due to resource constraints.
The existing systemUsage sendFailIfNoSpace and sendFailIfNoSpaceAfterTimeout are
promoted to destination policy options allowing selective destinations to fail a
send with an exception. The global system usage options are still in place.
When dropOnResourceLimit=true dispatch will continue in the event that any
subscription queue throws a resource limit exception on send failure.
2017-10-25 14:53:20 +01:00
be6f4b69c1
[no jira] calm this test a bit due to oom in ci builds
2017-10-25 13:08:00 +01:00
578eacab45
[AMQ-6824] remove time dependency in test assertion
2017-09-28 11:36:11 +01:00
41a100766c
[AMQ-6824] - fix up prefetchExtension growth on transaction completion and delivered ack and tie in boolean usePrefetchExtension
2017-09-26 11:30:18 +01:00
61d3231d36
AMQ-6809 Fix issue where stream message getBytes returned wrong value
...
StreamMessage implementation should return zero when the full value of a
written byte array has been consumed before then returning -1 on the
next read. Ands fix and additional testing of ActiveMQStreamMessage
2017-09-20 15:50:09 -04:00
c691124d32
AMQ-6808 preserve destination for browsed scheduled messages
2017-09-15 09:02:36 -04:00
a359d8152c
[AMQ-6277] take account of producer audit not being updatated on recovery check, avoid unnecessary partial journal replay
2017-09-15 13:48:03 +01:00
5e656d394c
https://issues.apache.org/jira/browse/AMQ-6799 - stop the jmx server connector properly
2017-09-01 13:02:53 +02:00
35bd3ad938
AMQ-6798 - Clean up store usage object on Queue stop
...
When queues are stopped the StoreUsage object needs to be stopped so it
will be removed from the parent StoreUsage. This allows the object to
be garbage collected and prevents a memory leak.
2017-08-24 09:24:36 -04:00
c7291f1ecf
https://issues.apache.org/jira/browse/AMQ-6799 - IOExceptionHandler during the startup
2017-08-24 14:04:36 +02:00
068b7946ce
[AMQ-6643][AMQ-5594] fix test regression to reflect match strategy
2017-08-09 11:40:39 +01:00
a67c75a9e1
[AMQ-6643] refine fix to allow wildcard subs to non wildcard subscription queues, enable simple wildcard sub to drain all subscription queues
2017-08-08 16:38:11 +01:00
a15626193c
[AMQ-6787] release securty context on failure to addConnection subsequent to auth, resolve leak. fix and test
2017-08-04 13:46:16 +01:00
206f77adac
[AMQ-6778] - fix test regression that needs to account for presence of correct advisory dests
2017-07-26 11:58:04 +01:00
ddfa96028c
[AMQ-6778] fix and test - no longer gate firing advisory on broker start flag b/c consumers may be present once transport connectors have started
2017-07-25 13:02:13 +01:00
d7f70837b7
[AMQ-6764] add logging of exit of jmx ops such that overlaps and delays are visible in the audit. fix and test
2017-07-10 14:10:05 +01:00
a9fe4e33c3
[maven-release-plugin] prepare for next development iteration
2017-06-27 13:41:28 -04:00
5f0d6943cb
[maven-release-plugin] prepare release activemq-5.15.0
2017-06-27 13:41:01 -04:00
d70852eec8
[AMQ-6625] fix mock test expectation regression
2017-06-16 10:29:32 +01:00
b07821ab64
[AMQ-6625] remove kahadbioexceptionhandler by pushing allowIOResumption into persistence adapter. This allows the lease locker to still be used with kahadb for stopStartConnectors support
2017-06-15 17:28:31 +01:00
99f3d4c505
[AMQ-6703] have jmx purge clear the audit such that messages can be copied back, fix and test
2017-06-15 10:46:23 +01:00
b6cb0eacea
[AMQ-6702] add maxProducersToAudit and maxAuditDepth to dead letter strategy to cofigure the audit, fix and test
2017-06-13 14:26:15 +01:00
2a0b785a04
AMQ-6698 - Allow timeout of SSL handshake for auto+nio+ssl
...
The handshake now takes place inside of the async task that timesout so
that if the SSL handshake takes too long the connection attempt will
honor protocolDetectionTimeout and actually timeout. Also, change the
default of protocolDetectionTimeout to 30 seconds so it matches the rest
of the broker's default connection timeout settings.
2017-06-08 12:34:15 -04:00
7413ee00e1
[AMQ-6696] zero out usage for forwarded messages such that the original target is no longer referenced. fix and test
2017-06-02 12:23:58 +01:00
c50dc6ff00
[AMQ-6693] ignore the long term connection associated with the broker context, fix and test
2017-06-01 12:00:04 +01:00
d2c0eddaad
[AMQ-6691] allow dlq flag to be set via jmx to allow retry op after a restart - use destinations element for long term persistence
2017-05-31 12:39:48 +01:00
8023b9ee44
[AMQ-6690] do nothing for move/copy jmx ops that try to modify self
2017-05-31 11:26:46 +01:00
30d3162982
[no jira] tidy up test teardown - prevent subsequent ci failures in error
2017-05-26 11:49:04 +01:00
25f112c5c9
[AMQ-6687] ensure transacted sends blocked on pfc do not resume after tx completion. AMQ-4467 refine the fix such that PFC kicks in such that the cache will accept messsages that push it over it's limit while it is still under the limit
2017-05-25 12:43:08 +01:00
acab282d9c
[AMQ-6678] sync destructive queue view mbean (jmx) operations such that concurrent calls see consistent state
2017-05-18 12:37:54 +01:00
ae97fbd52e
fix cn to match jdk8 cert
2017-05-05 11:01:33 +01:00
b30ae4e846
[AMQ-6665] - remove extranious import from test
2017-05-05 10:48:13 +01:00
07b0d913af
conform to jdk8 algorithm constraints with keystores
2017-05-04 13:14:31 +01:00
dcd9b9e186
use jdk8 allowed cypher in the restricted set
2017-05-04 12:58:25 +01:00
18d05ba5e0
modify test to validate setting isDLQ flag via startup destination query options
2017-05-03 16:17:29 +01:00
35f30102a6
[AMQ-2100] fix for intermittent ci failure
2017-05-03 12:31:09 +01:00
c4a1346875
[AMQ-6465] fix up test interplay - clean on start and consume what is produced
2017-05-03 12:22:24 +01:00
a0ba0bf4c6
[AMQ-6667] gate cursor cache enablement on a single pending send and tidy up setbatch to always check outstanding async future list. Fix and test
2017-05-03 11:36:06 +01:00
57795bafce
[AMQ-6665] - check for peercerts is now on tcp transport such that the bridge connection info can have the correct context
2017-04-27 12:07:12 +01:00
b64ac1dd77
[AMQ-6646] improve error reporting to include url
2017-04-04 17:30:29 +01:00
729766e492
[AMQ-6494] ensure vm transport propagates onCommand exceptions to peer
2017-04-04 14:17:27 +01:00
0f7561e85a
Revert "AMQ-6494 Return ExceptionResponse during broker service shutdown"
...
the root cause seems to be in the vm transport iterator
This reverts commit dce2b61f87
2017-04-04 14:15:00 +01:00
8b064889c6
[AMQ-6643] final modifier for test in the right place
2017-04-04 10:57:57 +01:00
2a2cb3997f
[AMQ-6643] final modifier for test
2017-04-04 10:52:38 +01:00
679db08db3
[AMQ-6643] ensure a wildcard virtual topic subscriber is restricted to the wildcard destination - avoid duplicate and spurious dispatch. fix and test
2017-04-04 10:16:48 +01:00
4ef1fc74cf
[AMQ-6640] either broker dispatch to bridge or bridge dispatch to broker needs to be async - dispatchAsync network option is the trigger for the vm transport to be sync in line with the current defaults. original BacklogNetworkCrossTalkTest scenario exposed this. upshot is dispatchAsync=false is not compatible with duplicate subscription suppression which is fair.
2017-03-30 12:12:13 +01:00
5ac9657c12
[AMQ-6640] shrink test duration for ci boxes
2017-03-30 10:16:18 +01:00
d84a58656c
[AMQ-6640] allign use of sync vm transport usage on duplex end of networkconnector with initiator end. only duplexinbound for forwarding is async to allow thread for responses. vm transport options applied in one place and test more deterministic w.r.t the hang scenario
2017-03-29 23:50:47 +01:00
770a73e9ba
[no jira] add identity option to consumer bean to aid logging/debugging
2017-03-29 22:19:15 +01:00
8e00c6c2bc
[AMQ-6640] fix duplicate suppression sync request on responder end of duplex network connector only b/c that has the async local transport. Additional test. Ensure broker sync is conditional on the need for duplicate suppression which should only be necessary in ring topologies when properly configured
2017-03-28 14:49:23 +01:00
36689beff7
[AMQ-6561] fix up unit test that expects socket to remain open after InvalidClientIDException, dubious expectation in the test that wants to verify broker is ok
2017-03-14 11:59:13 +00:00
01b1f7f694
[AMQ-3233] respect policy entry blockedProducerWarningInterval for flow control warning, 0 disables and Xmillis makes it periodic, default period of 30s is not unlike the existing once behaviour. fix and tests
2017-03-03 11:23:23 +00:00
2809befff5
[AMQ-6610] - fix up brittle jmock test
2017-03-03 10:14:30 +00:00
e67d48680f
[AMQ-6614] fix up jmx blockedSendsCount and producer view blocking flag for async send case. fix and test
2017-03-02 17:00:16 +00:00
90b808ab98
AMQ-6603 Stop tracking producer if creation failed
...
Track the message producer create and ensure it is not recreated on
failover if the creation resulted in an error response. Add failover
level tests to cover consumer and producer failed create tracking.
2017-02-28 16:17:32 -05:00
a1f6261fb2
[AMQ-6414] additional test that reproduces and validates
2017-02-27 16:35:54 +00:00
bab0887ed6
AMQ-6610 - Network connector mbean not registered on reload
...
On network connector add or update after broker start (such as the
runtime plugins) the mbean was not created. There was also a couple of
other properties not set. Fixed the network connector start to be the
same for normal broker start and runtime reload.
2017-02-24 14:05:27 -05:00
816f81e605
[AMQ-6517] resolve intermittent test failure - wait for client connection to see broker disconnect
2017-02-22 14:35:27 +00:00
f6bf823ded
AMQ-6599 - Properly apply soTimeout value to TcpTransport
...
https://issues.apache.org/jira/browse/AMQ-6599
The soTimeout value needs to be applied to the TcpTransport as well as
the socket because the NIO transports use the value later on when
establishing a connection
2017-02-17 08:03:50 -05:00
da5742762a
[AMQ-6547] final for inner class reference
2017-02-14 11:49:00 +00:00
fad50812af
[AMQ-6547] revert mod from AMQ-3143 such that waitForSpace respects child usage, fix test and validate mKahadb blocking send
2017-02-14 11:33:59 +00:00
f5baebb001
intermittent failure - disable periodic expiry as it may use memory that effects the assertions
2017-02-10 16:03:15 +00:00
d86c98a687
[AMQ-6587] - fix root cause of deletion candidate seeing sub. contention between adding sub to dests and adding dests to sub, also removing sub from dests twice could leave dest stat negative allowing invalid candidate for gc
2017-02-10 11:38:03 +00:00
0ee4f5b843
[AMQ-6587] additional contention window with new sub while gc is in progress - need to verify new sub is actually subscribed to the candidate for deletion. Fix and test
2017-02-07 13:53:40 +00:00
9b64e188b5
[AMQ-6432] issue was journal scan on newly created ack file. I left the relevant braces from AMQ-6288 in place. Fix and test
2017-02-03 16:58:52 +00:00
64b3203713
[AMQ-6587] - fix typo in test that needs 1.7 final
2017-02-01 16:43:02 +00:00
e415d2921e
[AMQ-6587] ensure subs added to new destination before destination is exposed in the destination map. sort gc contention with wildcard subs and anonymous publish. fix and test
2017-02-01 15:08:46 +00:00
f09493727f
[AMQ-6586] Compilation of activemq-unit-test fails
...
(cherry picked from commit 659d1f6ba5
2017-01-31 15:32:34 -05:00
687badb4fd
AMQ-6577: honour usePrefetchExtension in TopicSubscription.
...
AMQ-6577: move usePrefetchExtension flag to AbstractSubscription to promote reuse.
2017-01-30 11:13:57 -05:00
d0c95146c3
https://issues.apache.org/jira/browse/AMQ-6579
...
Remove incorrect dispatch counter increment on message expiration in
TopicSubscription when a pending limit strategy is set
2017-01-25 11:16:43 -05:00
56bb079c82
https://issues.apache.org/jira/browse/AMQ-1940
...
Queue purge now acquires the sendLock to prevent new messages from
coming in while purging. The statistics are no longer zeroed out as
they should properly decrement as messages are removed. These changes
should prevent the statistics from going negative.
2017-01-24 08:46:15 -05:00
030c44a554
[no jira] ensure clean db for test AMQ6463Test - intermittent ci failure
2017-01-16 11:11:45 +00:00
511b9b642a
[AMQ-6562] - suppress warn of durable sub duplicate from the store on cache exhaustion - expected in the absense of ordered sequenceid and setBatch. Fix leak of duplicates pending processing on batch fill for the durable sub case and remove eager page in for prefetch=0
2017-01-13 11:06:05 +00:00
d9c74d7317
https://issues.apache.org/jira/browse/AMQ-6561
...
Stop connections on all connection attempt errors, not just security
exceptions, to prevent dangling open sockets.
2017-01-12 10:21:08 -05:00
3a0a7238b1
[no jira] remove hard coded 1099 dep to resolve ci failure in JmxAuditLogTest
2017-01-12 11:53:20 +00:00
c76f109692
https://issues.apache.org/jira/browse/AMQ-4467 - modify fix check full against shared limit and high water mark against local limit, additional test
2017-01-10 11:18:00 +00:00
0ae90c0897
https://issues.apache.org/jira/browse/AMQ-6547 - add storeUsage attribute to mKahadb filtered adapter such that disk utilisation is available as a QOS
2016-12-20 14:47:22 +00:00
25703fbd1f
https://issues.apache.org/jira/browse/AMQ-6538
...
Fixing an issue with syncDurableSubs that cause a bridge failure when
adding multiple bridges between the same brokers
2016-12-13 11:58:57 -05:00
4b3f07e90e
https://issues.apache.org/jira/browse/AMQ-6441
...
https://issues.apache.org/jira/browse/AMQ-6526
Adding missing license headers
2016-12-07 13:32:18 -05:00
8a28c06555
[AMQ-6441] add option to specify the hard limits on a usage such that spurious values from the file system can be overridden. this closes #202 thanks William Crowell for the patch with test
2016-12-07 18:09:34 +00:00
41bec0d658
Fixes AMQ-6441 where a negative value can be returned with large AWS EFS files systems when calling java.io.File.getTotalSpace()
2016-12-07 10:45:12 +00:00
f225120f61
Fixes AMQ-6441 where a negative value can be returned with large AWS EFS files systems when calling java.io.File.getTotalSpace()
2016-12-07 10:45:12 +00:00
dc68ad8967
[AMQ-5875] add queue test variant to validate shared mkahaDb remains when one dest is deleted
2016-12-06 14:54:24 +00:00
6a0c65828a
Revert "fix up createPublisher contract to throw on null topic param, match the java doc"
...
the java doc allows null for an anonymous publish - the check needs to go in TopicRequestor part of the jdk
This reverts commit 29ecfd6cdb
2016-12-02 13:57:44 +00:00
29ecfd6cdb
fix up createPublisher contract to throw on null topic param, match the java doc
2016-12-02 12:46:32 +00:00
4e766d92c5
Add example using retroactive customer with a fixedsubscriptionrecoverypolicy for JMS Topic and broker restarted. Thanks to Charles Moulliard for the patch. This fixes #94 .
2016-11-29 17:38:06 +01:00
cf57559f1c
[no jira] unit test that exercises failover with xa and missing replys
2016-11-29 12:04:24 +00:00
dad629e889
[AMQ-6522] - remove hardcoded 32k batch limit from recovery check of the journal, fix and test
2016-11-29 11:32:03 +00:00
0a29533ed7
[AMQ-6520] respect kahadb indexDirectory for perDestination mKahaDB - fix and test
2016-11-25 16:44:28 +00:00
cfdff4edc5
[AMQ-6518] - fix up aveMessageSize dest stat and test
2016-11-25 10:38:09 +00:00
b6bca3976c
[AMQ-6517] make pre dispatch redelivery policy check optional jms.redeliveryPolicy.preDispatchCheck=false
2016-11-24 17:02:37 +00:00
99b7a28ccb
[AMQ-3166] fix typo that removed class name, sorry
2016-11-22 16:27:29 +00:00
7077d2b910
[AMQ-3166] init rollbackonly exception cause such that xaexception has meaning, thanks to james (jtahlborn) for the suggestion
2016-11-22 16:07:55 +00:00
e050519ff6
https://issues.apache.org/jira/browse/AMQ-6500
...
Better handle prefetch extension and pull consumers over Topics to avoid
the remote not receiving all the messages available based on the credit
it has issued.
2016-11-18 11:59:01 -05:00
105128a92d
[no jira] use the general wildcard for the drain test
2016-11-14 11:57:49 +00:00
7e648d512d
https://issues.apache.org/jira/browse/AMQ-6505
...
Fixing the auto transport protocol detection so that the byte buffer
that captures the initial bytes for detection is not shared across
threads. This was causing failed connections under high load and high cpu
usage under NIO
2016-11-12 10:02:32 -05:00
9d6bc3a5d8
[no jira] add replay policy to draining broker to allow drain to origin
2016-11-11 12:01:54 +00:00
7d0df2d01e
[no jira] static network wildcard drain test
2016-11-11 11:49:56 +00:00
dca066287e
https://issues.apache.org/jira/browse/AMQ-6494
...
Ignoring test that currently fails. The parent test is already ignored
in the build so I'm adding this one to be ignored as well. It
currently fails on exceptions that are expected and needs to be fixed.
2016-11-08 08:20:19 -05:00
dce2b61f87
AMQ-6494 Return ExceptionResponse during broker service shutdown
2016-11-04 09:30:09 -04:00
016ae05d0e
https://issues.apache.org/jira/browse/AMQ-6489
...
Adding a new ActiveMQXASslContextFactory and jndi support for it
in ActiveMQSslInitialContextFactory
2016-11-04 08:31:19 -04:00
be24a133ef
This closes #88 (merged as a65ac586). More file permissions fixes.
2016-11-03 14:26:34 -04:00
d5a929c0d2
This closes #205 . Won't fix. (fix even more file permissions)
2016-11-03 14:11:40 -04:00
f9bec8f99a
This closes #201 . Won't fix. (fix some file permissions though)
2016-11-03 11:48:16 -04:00
a6e35a6512
Test execution artifacts produced in ./target, so that clean runs cleanly
2016-11-01 14:48:12 -04:00
5c80eda321
https://issues.apache.org/jira/browse/AMQ-6477
...
Fixing potential concurrent modification exception
2016-11-01 10:31:20 -04:00
11541e8608
https://issues.apache.org/jira/browse/AMQ-6489
...
Add support for SSL configurations using JNDI.
2016-10-31 12:03:33 -04:00
7c3bb40100
https://issues.apache.org/jira/browse/AMQ-6477
...
ReduceMemoryFootprint now applies to non-persistent messages if they
have been marshalled and topics now clear memory after the recovery
policy check
2016-10-25 10:19:03 -04:00
d206621a73
https://issues.apache.org/jira/browse/AMQ-6472
...
Durable sync over a network bridge will now also sync non-durable
subscriptions proplrly if the consumer belongs to a destination that is
configured to force network durable subscriptions.
2016-10-20 13:47:38 -04:00
406a34294b
https://issues.apache.org/jira/browse/AMQ-6465
...
Properly decrementing the message reference count in
DemandForwardingBridgeSupport when messages supression is checked for
durable subscriptions
2016-10-14 12:16:07 -04:00
74a5381b9a
AMQ-6463 - provide connection to scheduler context in case of deferred send or error
2016-10-11 11:58:37 +01:00
8493f6b4d7
AMQ-6459 - store based % usage needs to poll the store for the current value on each access
2016-10-07 14:31:52 +01:00
e91f5c8062
AMQ-6454 - ensure message.acknowledge throws if consumer has closed and message has been released broker side
2016-10-07 09:57:28 +01:00
72650a0b8b
https://issues.apache.org/jira/browse/AMQ-6449
...
Disabling doclint now only activates for JDK 8
2016-10-03 07:37:53 -04:00
02082b1aec
NO-JIRA: More Java 8 JavaDoc fixes - also fixed findbugs for Java 8
2016-09-30 14:36:44 -04:00
5385fd1bb3
https://issues.apache.org/jira/browse/AMQ-6446 - use shared logger and pepend statements with connection counter. Old behaviour or per connection logger can be obtained with trace=true&jmxPort=0
2016-09-30 14:05:42 +01:00
634b42016a
https://issues.apache.org/jira/browse/AMQ-5486 - allow selector manager to reject tasks - org.apache.activemq.transport.nio.SelectorManager.rejectWork leaving the default to caller runs policy. This allows a broker to implement qos for existing connections by forcing others away
2016-09-28 12:15:50 +01:00
08695ab303
https://issues.apache.org/jira/browse/AMQ-6184 - add workQueueCapacity config property default to 0 where a value > 0 swaps out the dsynchQ for a capicity limited blocking queue. This allows the core pool to grow on demand as before but also allows work to be queued when necessary
2016-09-28 10:04:22 +01:00
18571ce09b
https://issues.apache.org/jira/browse/AMQ-6430
...
Modifying patch so that only stores that persist the noLocal flag will
check if this flag has changed to prevent a subscription from being
deleted by mistake
2016-09-23 10:59:32 -04:00
7c293b661f
https://issues.apache.org/jira/browse/AMQ-6430
...
When a nolocal durable consumer reconnects the new connectionId is properly captured for
the NoLocal expression so that nolocal works on reconnect. Also fixed
the detection of the nolocal value changing on consumer connect.
2016-09-21 09:34:46 -04:00
ffee8b442f
https://issues.apache.org/jira/browse/AMQ-6422 - match proton sender view credit to prefetchExtension - tracking credit to dispatch delta to track additional flow requests. Proton sender layer is distinct from the transport layer - they mirror each other
2016-09-21 10:33:20 +01:00
9f812a2103
NO-JIRA: Additional test on JobSchedulerStoreImpl
...
Pushes on the journal log GC logic to ensure that cleanup is occurring
when the redelivery plugin is scheduling more resends on TX rollback.
2016-09-19 10:53:50 -04:00
a038655605
https://issues.apache.org/jira/browse/AMQ-6423
...
Fixing durable sync over a network bridge so that network subscriptions
that are no longer permissible are also cleaned up
2016-09-08 08:28:26 -04:00
9ab94883a8
https://issues.apache.org/jira/browse/AMQ-6420
...
Properly copying wire format options map before applying to the
transport when using auto transports so that the options do not get
cleared and will be used for all future connections
2016-09-07 07:42:13 -04:00
98c5866c75
https://issues.apache.org/jira/browse/AMQ-6418
...
Properly setting the transport properties on the
AutoNIOSSLTransportServer and fixing the Stomp protocol to set the peer
certs when using auto+ssl
2016-09-06 10:17:05 -04:00
a3f1aa0bda
TrapMessageInJDBCStoreTest - intermittent ci failure. Avoid contention on datasource, use long lived connection for assertions
2016-09-02 11:27:12 +01:00
508df5359c
sanity check on provider url params for connection factory
2016-09-02 10:38:26 +01:00
bb8d32c04a
https://issues.apache.org/jira/browse/AMQ-6387
...
Fix up the Memory Store such that it removes the references it adds to
messages when they are placed into the memory durable topic subscription
store.
2016-09-01 16:26:03 -04:00
a0d05f8ea3
AMQ-2910 fix timing on test timeout - ensure consumer connection is started
2016-09-01 16:54:50 +01:00
a9c7f7122b
AMQ-6411 - tidy up latch between runs. Have not seen repeat of npe yet
2016-09-01 16:53:02 +01:00
f8bc19b96d
AMQ-6413 - ensure audit update on skipped store add for kahadb concurrentStoreAndDispatch. Fix and test
2016-09-01 16:46:21 +01:00
ed0e786b60
https://issues.apache.org/jira/browse/AMQ-6414
...
Changing the nio+ssl transports to trigger a serviceRead after start up
to prevent blocking. The prevents the channels from not reading in
certain cases, most notably with the auto+nio+ssl transport when used
for a network bridge. Also added a couple tests and changed a network
bridge test to test out auto+nio+ssl.
2016-09-01 11:39:46 -04:00
e57de54410
NO-JIRA: Fixing OpenWireConnectionTimeoutTest failure
2016-09-01 10:10:52 -04:00
bf5b1fcfce
address npe in intermittent failure in ci
2016-08-30 15:39:49 +01:00
de4f4e406f
Fix NPE case so a meaningful error is reported on failure.
2016-08-29 17:05:21 -04:00
b9fad53fc6
https://issues.apache.org/jira/browse/AMQ-6067
...
The JDBCMessageStore now checks hasSpace() when running a message
recovery listener to prevent going past the max configured page size
2016-08-26 13:46:42 -04:00
2b1cda1964
AMQ-6406 - ensure duplicates trapped by the cursor-add or queue-page-in are removed from the message store
2016-08-25 15:01:19 +01:00
e52a052761
add some diagnostics to track intermittent ci failure
2016-08-17 15:52:54 +01:00
4800a7a1a4
AMQ-6392 - allow mapping of host names via the publish address strategy
2016-08-09 15:22:28 +01:00
9249315688
AMQ-6389 - init the size attribute prior to logging a message send in the logging plugin
2016-08-08 16:46:49 +01:00
06a21dbbb3
[maven-release-plugin] prepare for next development iteration
2016-08-02 09:03:37 -04:00
71cbc65283
[maven-release-plugin] prepare release activemq-5.14.0
2016-08-02 09:02:54 -04:00
eb9c584fbd
https://issues.apache.org/jira/browse/AMQ-6373
...
More tests and cleanup
2016-08-01 12:27:34 -04:00
e73ab34837
https://issues.apache.org/jira/browse/AMQ-6383
...
https://issues.apache.org/jira/browse/AMQ-6373
Adding a new flag that can be specified on a network bridge to allow
forcing of subscriptions to be durable. Cleaned up some unit tests.
2016-08-01 10:02:56 -04:00
b1c4b1871f
https://issues.apache.org/jira/browse/AMQ-6373
...
Moving some test code into a shared support class
2016-07-30 08:35:24 -04:00
82295fd2c6
https://issues.apache.org/jira/browse/AMQ-6381
...
Fixing DurableTopicSubscription so that an ack will properly update the
forwards statistic on an ack
2016-07-29 15:56:52 -04:00
dd971a00f2
https://issues.apache.org/jira/browse/AMQ-6379
...
Removed unreliable check from unit test
2016-07-29 12:27:58 -04:00
7118247b65
https://issues.apache.org/jira/browse/AMQ-6379
...
Fixing unit test so that it uses a random port and changing the default
platform details to be "java" if there is an error
2016-07-28 13:10:44 -04:00
8d5e84bb67
AMQ-6379 - Add openwire properties for provider name, provider version,
...
and platform details
2016-07-28 12:25:13 -04:00
cf3d419528
https://issues.apache.org/jira/browse/AMQ-6375
...
Adding non-blocking metrics to KahaDB to track message counts and sizes
for subscriptions. Turned off by default but can be enabled on the
KahaDBPersistenceAdapter
2016-07-26 12:02:44 -04:00
2985651609
AMQ-6370 - speed up the test and wait a bit longer for sends in slow ci
2016-07-26 14:06:02 +01:00
01cfa7727d
AMQ-6361 - fix additional test regression on topic sub expiry AMQ4083Test,MessageEvictionTest
2016-07-26 13:45:41 +01:00
3953b9aaef
https://issues.apache.org/jira/browse/AMQ-6373
...
Adding a new OpenWire command called BrokerSubscriptionInfo in order to
help synchronize durable subs across a network bridge. Added OpenWire
version 12. For dynamicallyIncludedDestination durable subs will now be
synchronized on a bridge reconnect as long as the bridge supports
conduitSubscriptions and dynamicOnly=false
2016-07-25 11:56:13 -04:00
ad657cc202
AMQ-6370 - ensure derby instance is created
2016-07-25 13:41:05 +01:00
6cc2c1190d
AMQ-6361 - fix contention over expiry processing with expiry task and client expiry ack, unit test regression sorted.
2016-07-22 15:18:31 +01:00
2a815c2e08
AMQ-6370 - move cleanup lock to connection allocation to avoid contention with between store and connection pool. pool connection grant or block is now guarded by store lock which lasts till connection is closed
2016-07-21 10:54:40 +01:00
39184e2fb0
https://issues.apache.org/jira/browse/AMQ-6366
...
Fixing the duplex bridge case for restarting durable subscriptions when
dynamicOnly is false
2016-07-19 11:31:44 -04:00
f43c090809
https://issues.apache.org/jira/browse/AMQ-6362
...
Add option connectResponseTimeout to allow a stuck connection in
ensureConnectionInfoSent from stalling out a client. Timeout is
disabled by default.
2016-07-18 11:30:38 -04:00
a3a5a1affa
https://issues.apache.org/jira/browse/AMQ-6336
...
Ensure that when expired messages are handled client side that pull
consumers get a chance to see it and send a new pull request complete an
outstanding timed pull.
2016-07-15 16:45:35 -04:00
cd5ea6c27f
https://issues.apache.org/jira/browse/AMQ-6361
...
Honor the expired ack from the client as the authority on expiration
2016-07-15 15:08:26 -04:00
d635a36940
https://issues.apache.org/jira/browse/AMQ-6352
...
Fixing PList size tracking by moving the null assignment on removal to
after the onRemoval method is called to make sure that the decrement is
done properly.
2016-07-12 10:27:57 -04:00
c02bc64846
https://issues.apache.org/jira/browse/AMQ-5426
...
Fixing a race condition in ActiveMQMessageConsumer that could cause a
NPE when the consumer is closing by only modifing pendingAck inside of
the deliveredMessagesMutex
Thanks to Michael Wong for providing the test case for this issue.
2016-07-05 20:35:07 +00:00
3856c3999a
Revert " https://issues.apache.org/jira/browse/AMQ-5426 "
...
This reverts commit 6bfa13b6e7
2016-07-05 20:27:02 +00:00
6bfa13b6e7
https://issues.apache.org/jira/browse/AMQ-5426
...
Fixing a race condition in ActiveMQMessageConsumer that could cause a
NPE when the consumer is closing
Thanks to Michael Wong for providing the test case for this issue.
2016-07-05 20:05:29 +00:00
30ff378a35
increase service logging, seems npe in the mix on intermittent failure
2016-07-05 14:08:43 +01:00
31c55f7510
https://issues.apache.org/jira/browse/AMQ-6339
...
Add support for AMQP client to connect using WebSockets.
2016-06-30 14:52:40 -04:00
3dfda807f6
https://issues.apache.org/jira/browse/AMQ-6336 - queue browser delivers expired messages
2016-06-23 17:47:15 +02:00
1faa4afa90
https://issues.apache.org/jira/browse/AMQ-6331 - Honor excluded destinations in static routing on network connectors
2016-06-21 15:07:30 +02:00
9ac5f83473
Fix test failure in CI
...
Has race condition on the ArrayList it uses to track subs and
Fix the unreliable sleep used to track locked messages in subs
Ensure Broker is shut down on test completion.
2016-06-16 12:26:50 -04:00
c0713415f5
https://issues.apache.org/jira/browse/AMQ-6325
...
Fix test that fails now that the parser checks the full expression.
2016-06-16 10:59:08 -04:00
36237cb30f
https://issues.apache.org/jira/browse/AMQ-6322 - fix NetworkRouteTest failure
2016-06-15 12:59:52 +02:00
7b207567d9
https://issues.apache.org/jira/browse/AMQ-6325
...
Fix issue with selector parser.
2016-06-14 12:49:08 -04:00
a953f11d0e
https://issues.apache.org/jira/browse/AMQ-6323
...
Applying reduceMemoryFootprint for persistent Topic messages
2016-06-14 14:36:37 +00:00
cf750d5cee
Wait for bridge formation before attempting to receive otherwise the
...
timed receive might not work.
2016-06-10 11:22:45 -04:00
f548aafa81
move test utility to broker module to allow reuse from jdbc module tests
2016-06-10 10:20:33 +01:00
9f5fff795d
https://issues.apache.org/jira/browse/AMQ-5621
...
Ensure that connections using VM transport are closed.
2016-06-09 18:37:09 -04:00
5fd307cd9f
Ensure that connections get closed to allow the vm transport resources
...
to get cleaned up.
2016-06-07 09:29:41 -04:00
6bf5987921
A fix for AMQ-6310
...
Checking for leading wildcard in the prefix for a virtualtopic,
modifying the behavior of shouldDispatch in the VirtualTopicInterceptor.
2016-06-04 16:51:27 -07:00
857597ca9e
AMQ-4181 - browser 'may' have more than 1 so message 'may' remain
2016-06-03 15:15:11 +01:00
3c5c5779e2
Remove version definition for managed dependency
2016-05-26 18:00:50 -04:00
62ab55683f
increase the lease to allow kahadb recovery, ci intermittent failure
2016-05-26 11:30:32 +01:00
0757cdcd59
Cleanup the tearDown method to ensure we follow on to the super tearDown
...
where the broker is stopped.
2016-05-25 12:15:21 -04:00
e467f34cc1
longer receive timeout on first message, intermittent ci failure
2016-05-25 12:45:07 +01:00
281fbb1f9d
tidy up close for vm broker - seems ci failure of InMemeoryJmsSchedulerTest is related to overlap between tests of vm transport
2016-05-25 12:34:07 +01:00
fe9d99e7a0
AMQ-3166 - implement rollbackOnlyOnAsyncException such that async exceptions on transactional sends or acks result in the transaction being marked rollback only and commit failing with an exception. Test that shows current state of play using alwaySendSync or AsyncCallback. rollbackOnlyOnAsyncException enabled by default.
2016-05-25 11:24:43 +01:00
f46b2927a4
fix intermittent ci failure - ensure no expiry before first dispatch
2016-05-24 10:47:34 +01:00
b4e35fe8a3
AMQ-4181 - revert mod to testQueueBrowserWith2ConsumersInterleaved which cause intermittent ci failure - browse is a snapshot at time of creation. tidy up some gaps in pagein logic sync
2016-05-23 13:29:39 +01:00
7c04aa9909
reduce test message size and quantity for ci
2016-05-20 15:37:24 +01:00
c2230fda4b
https://issues.apache.org/jira/browse/AMQ-6286 - refine fix to distinguish multiple consumers in a transaction, verify insertion at head will preserve order
2016-05-18 10:09:39 +01:00
a2720c4653
https://issues.apache.org/jira/browse/AMQ-6293
...
Clean up the test, the times were causing CI failure. Turn off
persistence and fix a couple other things, reduced time to 2.5 secs
while still reproducing with fix removed.
2016-05-16 11:02:20 -04:00
1241e4120a
https://issues.apache.org/jira/browse/AMQ-6293
...
Fixing Queue destination statistics in dropMessage by adding sync in
between the check for dropped and actually dropping the message plus
fixing dequeue stats so messages aren't counted twice
2016-05-14 16:20:41 +00:00
d7b5a62bb0
https://issues.apache.org/jira/browse/AMQ-6286 - variant on test with n consumers sharing a session
2016-05-13 15:50:13 +01:00
3c0a4d960e
unit test to verify matching durable sub can statically forward topic
2016-05-12 22:11:25 +01:00
71893f1434
Allow the HTTP test to have extra time to wait for all messages to
...
arrive as the transmission rate is much slower.
2016-05-10 10:59:12 -04:00
3da9b0720e
https://issues.apache.org/jira/browse/AMQ-5621
...
Remove hard coded port as the bridge brokers method doesn't need the
port to be fixed. Turn off JMX since the test doesn't use it.
2016-05-10 10:05:05 -04:00
809d5b9bc8
https://issues.apache.org/jira/browse/AMQ-5621
...
Clean up, remove sleep and some unused code.
2016-05-10 09:56:19 -04:00
604f707d4d
https://issues.apache.org/jira/browse/AMQ-6286 - refactor insertAtHead from pendinglist to ordered variant
2016-05-10 11:45:27 +01:00
f47b370573
https://issues.apache.org/jira/browse/AMQ-6286 extend strictOrderDispatch to retain order of redispatched messages for a single consumer
2016-05-09 23:06:19 +01:00
1a8e17fbc3
tidy up test
2016-05-09 12:51:28 +01:00
9fc2661049
validate selector aware vt can give topic semantics by dropping messages when there is no consumer. Do selector cache plugin once to avoid adaptor check on each dispatch
2016-05-06 17:12:15 +01:00
1de7e7e8a3
tackle ci intermittent failure - think with prefetch extension it is not guarenteed that second consumer will get a dispatch
2016-05-06 13:54:12 +01:00
fc9ad9f023
tackle intermittent ci failure, think possibe all messages are dispatched before pause
2016-05-06 12:17:07 +01:00
9a35c3731b
fix ci failure when less than 4% disk space
2016-05-06 12:10:26 +01:00
1ccd17791b
AMQ-6274 - set originalDestination for composite destinations
...
This closes #184
2016-05-05 11:38:48 -04:00
65cef69130
https://issues.apache.org/jira/browse/AMQ-5603 - reverting default preallocatonScope to entire_journal b/c async only really works for ssd
2016-05-05 13:06:42 +01:00
a28a091c55
https://issues.apache.org/jira/browse/AMQ-6264
...
Fire advisory for slow consumer outside the pending lock.
2016-05-04 16:32:01 -04:00
d1e2b76809
https://issues.apache.org/jira/browse/AMQ-5621
...
Update tests to not use hard coded broker port.
2016-05-04 14:39:38 -04:00
231679d936
https://issues.apache.org/jira/browse/AMQ-5603 - don't async preallocate to keep match data file count
2016-05-04 16:15:55 +01:00
ba77b9f55a
https://issues.apache.org/jira/browse/AMQ-6277 - tidy up logic that determines recovery location so that we don't recovery from the end of the journal in error on normal restart. This avoids suprious recovery logging
2016-05-03 12:47:49 +01:00
4f43a21212
https://issues.apache.org/jira/browse/AMQ-5603 - one more journal in the mix for this test with async preallocation
2016-05-03 11:36:47 +01:00
62bdbb0db5
https://issues.apache.org/jira/browse/AMQ-5603 - add preallocationScope=full_journal_async that will preallocate a journal in advance or use to avoid latency jitter on journal rotation. Added none option to disable preallocation
2016-04-29 16:57:28 +01:00
3c342ffce4
Add some additional checks for valid state.
2016-04-27 14:50:43 -04:00
297eadf746
https://issues.apache.org/jira/browse/AMQ-6267
...
Added two new properties for configuration to a network bridge,
advisoryPrefetchSize and advisoryAckPercentage. By default
advisoryPrefetchSize is set to 0, which is disabled, and will use the
prefetchSize value unless otherwise set. Also added validation to
prefetchSize to make sure it is greater than 0 as 0 is not allowed.
2016-04-27 14:11:05 +00:00
765a010d04
https://issues.apache.org/jira/browse/AMQ-5621
...
Add sleep back which allows the producers to wait for the bridge
formation.
2016-04-25 18:41:00 -04:00
10478c313e
https://issues.apache.org/jira/browse/AMQ-5621
...
Update tests to not use hardcoded port for the transport connector and
remove the unneeded sleep calls with proper test setup
2016-04-20 15:16:36 -04:00
8a30026e82
Drop back to original iterations now and give some extra time on test
...
timeouts.
2016-04-19 12:54:18 -04:00
b027e65553
https://issues.apache.org/jira/browse/AMQ-5153
...
https://issues.apache.org/jira/browse/AMQ-6254
Store the original subscribed destination along with the target
destination in the subscription info object to ensure that wildcard
subscriptions remain linked.
2016-04-19 09:53:58 -04:00
6541bef52d
fix logger name
2016-04-18 15:05:31 +01:00
b9f9f03829
https://issues.apache.org/jira/browse/AMQ-6256
...
Calling beforeMarshall on messages when they async stored before the
store task is run and before consumer dispatch to prevent two threads
from trying to mutate the message state at the same time.
2016-04-15 13:01:21 +00:00
19fd084a83
https://issues.apache.org/jira/browse/AMQ-6252
...
Update for some added thread safety. Adds method healthStatus that will
regenrate the status from the healthList data which is more intuitive
than the getCurrentStatus which doesn't update state and requires
periodic calls to healthList to capture current metrics.
2016-04-14 16:53:17 -04:00
530c1a8193
https://issues.apache.org/jira/browse/AMQ-6240 - tidy up test and reduce duration. reuse closeTimeout on rollback during close which is the case here
2016-04-14 12:25:11 +01:00
82330793e9
https://issues.apache.org/jira/browse/AMQ-5621
...
Clean up the test, use timeouts and add a few more iterations to try and
reproduce recent CI failures from this test.
2016-04-13 15:17:14 -04:00
7a61718e02
https://issues.apache.org/jira/browse/AMQ-6244 - reset ActiveMQBytesMessage 'compressed' flag after restoring compressed content
2016-04-13 14:19:06 +00:00
7f86825337
NO-JIRA - Adding activemq-junit dependency to activemq-unit-tests
2016-04-13 13:21:48 +00:00
77d46dc139
https://issues.apache.org/jira/browse/AMQ-6240 use sendTimout on sync rollback on close such that a blocked connection won't block a close
2016-04-13 11:55:59 +01:00
5ec4513ffb
https://issues.apache.org/jira/browse/AMQ-5923
...
Adding missing assertion statements
2016-04-12 15:52:26 +00:00
c1b58d3373
https://issues.apache.org/jira/browse/AMQ-6239
...
Refactor the iterator implementation in the PrioritizedPendingList to
not copy elements and instead use the level iterators. Add some
additional tests.
2016-04-12 11:35:03 -04:00
485fcafcdf
https://issues.apache.org/jira/browse/AMQ-5923
...
Updating tests to check prioritized messages as well
2016-04-12 14:13:52 +00:00
2a8218a9a8
https://issues.apache.org/jira/browse/AMQ-6151 - retain list for redeliveries and combine for dispatch/iteration such that redeliveries retain per priority order after prefetch
2016-04-06 15:09:36 +01:00
a3a8c1c525
https://issues.apache.org/jira/browse/AMQ-6215 - support 0 maxBrowsePageSize and maxExpirePageSize such that lazyDispatch ensures highest priority messages is available to a pull consumer
2016-04-05 13:23:06 +01:00
0fb24cc4c1
Allow some extra time on the consumer wait to account for slow CI boxes
2016-03-30 14:23:33 -04:00
75990ef14a
https://issues.apache.org/jira/browse/AMQ-6222
...
Moving clearedMarshalledState execution to the async listener on an
async add to the message store. This is necessary to make sure this
logic doens't execute until after the message is marshalled for the
store.
2016-03-22 17:54:13 +00:00
a9521dcebf
https://issues.apache.org/jira/browse/AMQ-6203
...
Expose configuration on the persistence adapter level.
Double the test timeout and increase the compaction frequency to account
for very slow CI boxes.
2016-03-15 12:02:40 -04:00
946e62d702
https://issues.apache.org/jira/browse/AMQ-6203
...
Rewrite older acks that can be preventing GC of log files.
2016-03-14 11:04:57 -04:00
ae441cbc7d
https://issues.apache.org/jira/browse/AMQ-6208 - fix and test
2016-03-11 12:01:18 +00:00
521c4fd8c3
extend timeout - running too close to the limit for comfort
2016-03-09 22:13:46 +00:00
a2781e3966
https://issues.apache.org/jira/browse/AMQ-6204
...
Fixing the removal logic on virtual destination remove inside of
Advisory Broker to clean up virtual destination maps properly. Added a
test to verify. Also added new debug logging to help track down any
future issues.
2016-03-09 19:54:08 +00:00
078f39f589
https://issues.apache.org/jira/browse/AMQ-6199 - apply CursorMemoryHighWaterMark to topic subscriptions
2016-03-08 16:45:06 +00:00
e313f40989
https://issues.apache.org/jira/browse/AMQ-6175 - fix unit test regression SelectiveMBeanRegistrationTest
2016-03-08 11:55:46 +00:00
13ec994939
Revert " https://issues.apache.org/jira/browse/AMQ-4495 - revisit. Reinstate check for space on pagein, so that highWaterMark is respected and full state is not reached, hense pfc is not triggered in error"
...
This reverts commit d8cf54b0a9
2016-03-07 16:26:25 +00:00
903dec615c
https://issues.apache.org/jira/browse/AMQ-6194
...
Fixing an issue that caused statistics for a transactional temporary
queue to be updated twice by mistake. Moved the statistics update into
tryOrderedCursorAdd so that the update is called immediately only if
not inside a transaction.
2016-03-07 14:15:35 +00:00
d8cf54b0a9
https://issues.apache.org/jira/browse/AMQ-4495 - revisit. Reinstate check for space on pagein, so that highWaterMark is respected and full state is not reached, hense pfc is not triggered in error
2016-03-01 11:44:41 +00:00
552c0f0f7a
https://issues.apache.org/jira/browse/AMQ-6188 - reset BaseDestination.lastActiveTime each time a message is delivered to the broker.
2016-02-26 20:46:32 +00:00
c2ad0c3251
AMQ-6183 Add isDispatchSync to the subscription view and deprecate the
...
meaningless one in the producer view
2016-02-24 17:25:01 -05:00
fd76088814
https://issues.apache.org/jira/browse/AMQ-5875 - additional test that shows durable sub registration does not error out with this fix
2016-02-17 14:09:05 +00:00
b0c0441d09
https://issues.apache.org/jira/browse/AMQ-6171 - fix vm transport replacement of : from brokerName in error, fix networkConnector retry logic in the event of localTransport creation failure
2016-02-15 14:14:19 +00:00
386210fafe
https://issues.apache.org/jira/browse/AMQ-6159
...
Ensure proper repeat counts are scheduled.
2016-02-04 17:16:58 -05:00
25ff5699f1
https://issues.apache.org/jira/browse/AMQ-6158
...
Computing messageSize for a durable subscription in KahaDB now runs much
faster (n vs n^2) which is noticable when there are a large number of
pending messages for a durable subscription.
2016-02-04 15:17:49 +00:00
c17b7fdc7f
add trace level log to shared file locker keepAlive
2016-02-04 13:28:59 +00:00
8c4b5f485d
https://issues.apache.org/jira/browse/AMQ-6152
...
Ensure that when add / remove commands are colocated they don't prevent
the log from being GC'd once it is unreferenced.
2016-02-02 20:28:24 -05:00
5f7a81f928
https://issues.apache.org/jira/browse/AMQ-6142
...
Fixing a race condition that exists in the decompress method of
ActiveMQBytesMessage that can cause an invalid length to be read.
2016-02-01 17:27:19 +00:00
5af5b59d3b
https://issues.apache.org/jira/browse/AMQ-6151 - respect prioritizeMessages for pending and redelivered messages
2016-02-01 12:19:49 +00:00
acbe31fcb5
https://issues.apache.org/jira/browse/AMQ-6137 - deal with 'special' escape chars in like selector expression
2016-01-22 15:30:16 +00:00
4ecff14030
NO-JIRA Update master version to 5.14.0-SNAPSHOT to match the eventual
...
release version.
2016-01-20 12:40:20 -05:00
b4aa53d806
https://issues.apache.org/jira/browse/AMQ-6133
...
Fixing the processing of KahaUpdateMessageCommand to add the message to
the store if it doesn't exist, instead of ignoring it. This will
prevent message loss in certain cases when the KahaDB index has to be
rebuilt.
2016-01-20 16:59:07 +00:00
193f6be687
https://issues.apache.org/jira/browse/AMQ-6131
...
Fix check for durable sub with no pending messages during checkpoint
cleanup.
2016-01-18 17:43:18 -05:00
1ae29382e1
https://issues.apache.org/jira/browse/AMQ-6129
...
Fixing DynamicallyIncludedDestinationsDuplexNetworkTest
2016-01-18 15:27:11 +00:00
a3fa0da6ec
https://issues.apache.org/jira/browse/AMQ-6130 - java beans @Transient annotation
2016-01-18 09:38:09 +01:00
4ea435bf46
https://issues.apache.org/jira/browse/AMQ-5336
...
URI comparison needs to be done using the host / port comparison method
instead of string equality due to other features like nested options
which can alter the URIs and lead to continued attempts to reconnect to
the transport that's already connected when priority backup is used.
2016-01-15 18:07:56 -05:00
10c998b0bc
https://issues.apache.org/jira/browse/AMQ-6129
...
Adding NetworkBridgeStatistics and also a received count for bridges
when they are in duplex mode.
2016-01-15 14:54:04 +00:00
2b84cd60ba
https://issues.apache.org/jira/browse/AMQ-6128 - fix and test - fix values on priority ordered pending - messages assigned to browsers need to be ordered
2016-01-15 14:31:09 +00:00
5b73ffad6b
https://issues.apache.org/jira/browse/AMQ-6117
...
Test to try and reproduce the issue.
2016-01-14 18:28:08 -05:00
9287055338
https://issues.apache.org/jira/browse/AMQ-6125
...
Ensure that the redelivery policy is never null in the consumer.
2016-01-13 18:08:18 -05:00
b9805f7ac0
NO-JIRA Update test to ACK in transacted batches to group Ack values to
...
avoid the test failure based on the even spread of acks across journal
files preventing file GC which causes the test to fail.
2016-01-12 13:51:56 -05:00
505a76a8bb
https://issues.apache.org/jira/browse/AMQ-6059
...
Ensure that a message sent to the store for the DLQ is rewritten so that
its updated values are written to prevent exirpation loops and loss of
reollback cause etc.
2016-01-12 11:51:48 -05:00
db1506a592
https://issues.apache.org/jira/browse/AMQ-6124 - fix and test - propagate broker info from prestarted backup transport
2016-01-12 14:00:13 +00:00
66cfc7bab3
AMQ-6121
...
AMQ-6122
Prevent messages on DLQ for looping back onto the same DLQ. Prevents
expired messages from bouncing back and duplicate messages from the
store from causing a deadlock.
2016-01-11 10:57:38 -05:00
3bb7e4a5c8
Network of brokers on duplex mode reports InstanceAlreadyExistsException on already existing destinations
...
https://issues.apache.org/jira/browse/AMQ-6052
closes #164
2016-01-11 12:59:33 +00:00
6b1e87410d
Network of brokers on duplex mode reports InstanceAlreadyExistsException on already existing destinations
2016-01-11 12:59:33 +00:00
b7db97d8e2
https://issues.apache.org/jira/browse/AMQ-6100
...
Adding missing LICENSE header
2016-01-06 15:49:50 +00:00
16bc0f0d75
https://issues.apache.org/jira/browse/AMQ-6089 - support TMNOFLAGS as a scan end to allow looping calls to recover to terminate
2016-01-06 12:54:20 +00:00
e3df09b9db
https://issues.apache.org/jira/browse/AMQ-6094 - regression via https://issues.apache.org/jira/browse/AMQ-6014 - incorrect ref count on message expiry event during cursor move for dispatch. Fix and test - thanks for the test
2016-01-05 14:09:16 +00:00
fc4c697d44
NO JIRA - cleanup imports
2015-12-22 13:11:28 +00:00
564d55023e
https://issues.apache.org/jira/browse/AMQ-6102
...
Call to the statistics instance of the subscription to reset the
counters.
2015-12-21 17:03:24 -05:00
4e63ee7cc7
https://issues.apache.org/jira/browse/AMQ-6100 - Virtual topic message destination should be the target queue
2015-12-21 15:19:22 +01:00
370b181099
https://issues.apache.org/jira/browse/AMQ-6097
...
remove un-needed import statements
2015-12-18 19:47:46 +00:00
246ccb8e04
https://issues.apache.org/jira/browse/AMQ-6097
...
Fixing KahaDB so that the correct marshaller is used for the message
keys inside of the message order index. This will ensure that message
size metrics are accurate.
2015-12-18 19:26:24 +00:00
b7787bf6fb
https://issues.apache.org/jira/browse/AMQ-6086 - test cannot validate all start failures scenarios at this time, suffice that start and stop complete ok
2015-12-14 16:46:22 +00:00
455a628305
https://issues.apache.org/jira/browse/AMQ-6086 - avoid logging npe on attempted start of persistence adapter post stop
2015-12-14 16:32:10 +00:00
35df815fb8
https://issues.apache.org/jira/browse/AMQ-6086 - start exception can prevent stop from exiting fully, need to be more selective in creation on stop.
2015-12-14 15:40:05 +00:00
da076f4a63
https://issues.apache.org/jira/browse/AMQ-6086 - add some determinism to interleaved stop and start calls on broker service
2015-12-11 16:22:31 +00:00
8609f74db3
https://issues.apache.org/jira/browse/AMQ-6083 - ignore test scenario on leveldb store
2015-12-11 11:21:06 +00:00
768fa17085
https://issues.apache.org/jira/browse/AMQ-6005 - have plist whack it existing state on start. Start the temp store after the primary persistence adapter which does the locking
2015-12-10 14:24:03 +00:00
d7febddb67
https://issues.apache.org/jira/browse/AMQ-6084 - add broker.adjustUsageLimits to disable the adjustment of limits to what is available. In this way, a broker will fail to start if constrained, ensuring it won't accept connections and block pending resources if it has earlier exited for that reason
2015-12-10 11:23:56 +00:00
5db5f3e39a
https://issues.apache.org/jira/browse/AMQ-6083 - ignoreMissingJournalfiles false - check for missing acks and corruption anywhere and error out so that corruption does not go unnoticed - fix and test
2015-12-09 12:30:29 +00:00
179dc3acb2
https://issues.apache.org/jira/browse/AMQ-6070 - rework for virtual topic case, use the destination from the transient region destination rather than the message, such that consumer queue advisories work for delivered etc
2015-12-08 11:05:25 +00:00
315147c5ef
https://issues.apache.org/jira/browse/AMQ-6074
...
Make the transportConnector configs consistent across all four variants
by removing the enableCipherSuites option on openwire NIO+SSL. RC4 was
enabled on the broker side but in later JDK releases that suite is
disbaled as it is insecure so the client side couldn't find a supported
suite.
2015-12-07 12:27:34 -05:00
75ff17af41
https://issues.apache.org/jira/browse/AMQ-6070 - set correct originalDestination property value in advisories
2015-12-03 12:14:18 +00:00
8363c99b51
https://issues.apache.org/jira/browse/AMQ-6069
...
Fixed contains method in PrioritizedPendinList which was not returning
correctly. This was causing messages to not be removed from the
dispatchPendingList when purge was called inside a Queue leading to an
eventual OOM error if enough messages were purged. This fix also
improves performance of the contains method.
2015-12-02 13:24:32 +00:00
144b711a9a
add some additional trace debug to investigate linear store usage, this test has been failing in ci for the past 7 builds but work ok locally. This additional trace will help diagnose
2015-11-30 14:04:27 +00:00
cfb4ca9f54
[maven-release-plugin] prepare for next development iteration
2015-11-30 13:48:58 +00:00
abfe038ddf
[maven-release-plugin] prepare release activemq-5.13.0
2015-11-30 13:48:11 +00:00
f09000d1e6
https://issues.apache.org/jira/browse/AMQ-6065 - ensure no call to exit. fix mock test to account for extra call
2015-11-30 13:24:19 +00:00
0a12bcb928
https://issues.apache.org/jira/browse/AMQ-2191 https://issues.apache.org/jira/browse/AMQ-3529 - rework fixes to remove uncertanty from dealing with intettuptedexception. Sync requests will trap interrupts that ocurr while waiting for responses and fail the connection with an interruptedioexception. Interrupts pending before requests will be suppressed, allowing possible clean shutdown. It is not safe to replay openwire ops b/c they are not idempotent, the only safe option is to have a teardown of the broker side state from a close
2015-11-27 12:21:56 +00:00
95f58fa7c4
https://issues.apache.org/jira/browse/AMQ-6027
...
Adding back in test case now that AMQ-5898 is resolved
2015-11-25 19:13:24 +00:00
35b7ac250b
https://issues.apache.org/jira/browse/AMQ-5898
...
Removing assertion in VirtualDestinationInterceptor to allow
multiple composite destinations to forward to a physical destination
2015-11-25 13:33:32 +00:00
9acee62877
https://issues.apache.org/jira/browse/AMQ-5963
...
Making unit test more robust
2015-11-24 20:40:10 +00:00
ef129c21cd
NO-JIRA ensure each test has a store with its own directory.
2015-11-24 11:17:25 -05:00
dca6e4506e
AMQ-6058 added a check to make sure the destination starts with the virtual topic prefix.
2015-11-23 20:10:26 +00:00
8be1486508
NO-JIRA: Add a delay to fail in case an async operation has not fully
...
created the DLQ yet.
2015-11-23 14:24:06 -05:00
de5d0d9430
https://issues.apache.org/jira/browse/AMQ-5854
...
Fix intermittent test failure caused by the test reconnecting before
the failure assertion had a chance to assert the expected failure
2015-11-22 18:36:38 +00:00
4a27b72377
https://issues.apache.org/jira/browse/AMQ-6042
...
Apply fix and test from Martin Lichtin to preserve the rollback cause in
all ack modes.
2015-11-20 16:18:27 -05:00
cc6213ebf2
https://issues.apache.org/jira/browse/AMQ-5712
...
Switching addMessageLast to tryAddMessageLast when messages are added
to a Queue pending cursor to allow a potential deadlock to be
avoided. There is more work to be done here but this will at least
prevent a deadlock from occurring.
Fix and test based off of a patch created by Timothy Bish.
2015-11-20 20:58:27 +00:00
64aac4ce73
org.apache.activemq.network.VirtualConsumerDemandTest can take more than 10mins - increasing the fork limit
2015-11-18 16:08:29 +00:00
15412bae64
AMQ4221Test - remove system exit as it breaks surefire fork, https://issues.apache.org/jira/browse/AMQ-6004 interrupt causes errors on shutdown. Two are sorted but the check for errors in the logs may still cause intermittent failures
2015-11-18 16:08:29 +00:00
09054fc4a8
https://issues.apache.org/jira/browse/AMQ-6050
...
Clearing the subscription from the local map in
DemandForwardingBridgeSupport to make sure that demand can be properly
recreated again.
2015-11-18 15:06:33 +00:00
86ead7e9d2
fixing unit test to dynamically use a free port
2015-11-12 15:55:29 +00:00
d328864410
tweaking PeriodicDiskUsageLimitTest
...
Increasing the size of the files written during testing to try
and reduce the change of a test failure
2015-11-11 13:12:02 +00:00
078a101cf7
https://issues.apache.org/jira/browse/AMQ-6000
...
Fix and test, wakeup queue dispatch when resume is called.
2015-11-10 15:39:51 -05:00
3ef6a9f769
https://issues.apache.org/jira/browse/AMQ-6027
...
Fixing unit test to pass assertion
2015-11-10 18:42:03 +00:00
0c846cf8f6
https://issues.apache.org/jira/browse/AMQ-6027
...
Tweaking test case to apply virtual destination updates immediately
2015-11-10 14:45:37 +00:00
cc81680e10
https://issues.apache.org/jira/browse/AMQ-6027
...
Adding support for consumers on virtual destinations to create network
demand. This behavior is turned off by default but can be enabled.
For example, if a consumer comes online for a queue that is part of a
VirtualTopic, this will cause a network of brokers to forward messages
because a demand subscription will be created. Same for if a consumer
comes online for a forwarded destination from a composite
destination.
There is also an option to enable flow based on the existence of a
virtual destination if the virtual destination is forwarding to a
Queue.
Full configuration instructions for this feature will be on the wiki page.
2015-11-09 20:07:43 +00:00
fd0f71a4c8
https://issues.apache.org/jira/browse/AMQ-6033 - fix shadowing error, additional test
2015-11-02 15:08:22 +00:00
014d5594d6
AMQ-6032 Repack message prior to scheduler dispatch to store updated
...
properties in marshaled form.
2015-10-30 14:11:06 -04:00
f09b9203a0
https://issues.apache.org/jira/browse/AMQ-6021 - mqtt+nio+ssl certificate authentication
2015-10-23 15:25:33 +02:00
92d5efc32c
https://issues.apache.org/jira/browse/AMQ-6014 - test needs more time in ci. need to figure why it is sooo slow
2015-10-21 13:06:13 +01:00
a01578ad4c
fix stop/stop or stop no start NPE on sharedfilelocker
2015-10-20 13:02:57 +01:00
1ad0117932
https://issues.apache.org/jira/browse/AMQ-6014 - fix up reference counting for durable subs such that ack on one sub does not decrement usage for offline subs. Fix and test
2015-10-19 16:22:57 +01:00
dc06c8dc75
https://issues.apache.org/jira/browse/AMQ-5994 https://issues.apache.org/jira/browse/AMQ-4000 - proper fix for duplicate sub info from the store on recovery failure from AMQ2149Test. Additional test from Christopher L
2015-10-06 12:01:24 +01:00
81b4b9ae3d
https://issues.apache.org/jira/browse/AMQ-5996
...
When possible check for noLocl changes on durable subscription
reactivation and recreate the durable sub if it changes. For both
selector change and noLocal change also update the AbstractSubscription
selectorExpression so it matches with what was requested.
2015-10-01 19:23:58 -04:00
fc25535748
https://issues.apache.org/jira/browse/AMQ-5854 - fix intermittent test failure
2015-09-30 11:41:08 +01:00
8514e38135
https://issues.apache.org/jira/browse/AMQ-5951 - scenario wheere transaction command can block, additional test and further fix
2015-09-30 11:41:08 +01:00
92e1f60d98
https://issues.apache.org/jira/browse/AMQ-5854 - tidy up test
2015-09-29 13:11:29 +01:00
8d982479e9
https://issues.apache.org/jira/browse/AMQ-5854 - fix and test. Ensure transaction rollback if there are pending acks during a failover reconnect. Reliably tracking pending acks to eusure possible redelivery is too complex in the context of acks getting dropped by failover or ignored by the subscription, in addition to being sent async. Couple that with multiple consumers on the same connection and the locking of message delivery; only safe course is to ensure rollback outcome.
2015-09-28 14:29:57 +01:00
gtully
Christopher L. Shannon (cshannon)
Łukasz Dywicki
Carlo Dapor
Timothy Bish
Erik Wramner
Dejan Bosanac
Krzysztof Sobkowiak
Vasco Veloso
William Crowell
Claus Ibsen
Hadrian Zbarcea
Michael L. Bloom
Jonathan Malek
Quinn Stevenson
Brian D. Johnson
Altaflux
Chad Zobrisky