1594 Commits

Author SHA1 Message Date
Clebert Suconic
7bf8bcc7fe ARTEMIS-2662 Make Page to be resilient to invalid position
in case of an invalid position on getMessage, it should instead of runtimeException
be more resilient and fix itself.
2020-03-18 12:04:50 -04:00
Justin Bertram
2eae280a9f ARTEMIS-2576 fix possible NPE for auth failure 2020-03-17 14:26:34 -05:00
Clebert Suconic
c801c00e33 ARTEMIS-2662 Using previously stored encodeSize on page record offset
There is no guarantee that the encodeSize size is the same in AMQP right after read.
As the protocol may add additional bytes right after decoded such as header, extra properties.. etc.
2020-03-17 05:55:25 -04:00
Francesco Nigro
2105479304 ARTEMIS-2658 AMQP message read from page has wrong encode size 2020-03-16 18:20:39 +01:00
Francesco Nigro
2025cbbfd0 ARTEMIS-2656 NPE with read-whole-page == true 2020-03-13 13:51:37 +01:00
brusdev
951b5d5ded ARTEMIS-2652 Fix PageCursorProviderImplTest on IBM JVM
Replace the page mock to fix an incompatibility between IBM JDK and Mockito.
2020-03-11 11:32:47 -04:00
Justin Bertram
ed7fee6d9c ARTEMIS-2643 allow masked password when resetting via mgmnt 2020-03-05 21:38:09 -05:00
Justin Bertram
b2417d33b1 ARTEMIS-2640 mgmnt ops reporting wrong audit details 2020-03-05 21:37:37 -05:00
Justin Bertram
339ccccbd7 ARTEMIS-2631 address orphaned from JMS temp queue 2020-03-05 21:36:35 -05:00
Justin Bertram
766f88c22a ARTEMIS-2629 ensure queue auto-delete after expiration 2020-03-05 21:35:35 -05:00
Justin Bertram
8c259116a8 NO-JIRA clarify & verify web socket support for MQTT 2020-03-05 21:34:53 -05:00
Clebert Suconic
ddd8ed4402 ARTEMIS-1975 Real Large Message support into AMQP
This is a Large commit where I am refactoring largeMessage Body out of CoreMessage
which is now reused with AMQP.

I had also to fix Reference Counting to fix how Large Messages are Acked

And I also had to make sure Large Messages are transversing correctly when in cluster.
2020-02-25 15:25:01 +01:00
Justin Bertram
d0758f34f6 ARTEMIS-2624 auto-create expiry resources 2020-02-20 17:44:56 -05:00
Justin Bertram
b76f3b3a0d ARTEMIS-2587 auto-create dead-letter resources
This is a reimplementation of the IndividualDeadLetterQueueStrategy
from 5.x in a way that makes sense with the Artemis addressing model.
2020-02-20 17:44:56 -05:00
Christopher L. Shannon (cshannon)
3966e47338 ARTEMIS-2613: Add support for DivertBindings for federated addresses
This will allow federated addresses to create remote consumers based on
the existing of divert bindings and matching queue bindings
2020-02-17 12:15:18 -05:00
Clebert Suconic
990890d228 ARTEMIS-2622 Making replica resilient to closed pages 2020-02-14 14:01:52 -05:00
Justin Bertram
a8cf6b04b4 ARTEMIS-2607 interceptor returns false but processing continues 2020-02-14 13:23:05 -05:00
Francesco Nigro
5897909dc9 ARTEMIS-2617 use core pools to reduce GC on journal loading 2020-02-12 13:29:51 -05:00
Francesco Nigro
3282f105bb ARTEMIS-2604 Optimize journal loading
- Avoid some Properties Decoding, checking if we need certain properties like scheduled delivery
- Avoid creating some unnecessary SimpleString instances
- Removed some intermediate ActiveMQBuffer allocation
- Removed some intermediate UnreleasableByteBuf allocation
2020-02-05 11:13:53 -05:00
sebthom
4bc5c6f2a8 NO-JIRA Add serialVersionUID and remove redundant casts
Adding serialVersionUID to WildcardConfiguration since it is
serializable. Without serialVersionUID  being specified a new one is
generated on each compilation which prevents object deserialization
between releases.
2020-02-03 09:54:43 -06:00
Sebastian Thomschke
85a1c753d7 NO-JIRA Wrong autoDeleteDelay value passed to createSharedQueue 2020-02-03 09:53:13 -06:00
Sebastian Thomschke
3797b62420 NO-JIRA Remove unnecessary null-check in ExpiryScanner 2020-02-03 09:51:49 -06:00
sebthom
cfa11bbadc ARTEMIS-2610 Improve ActiveMQServer.getConnectionCount() 2020-02-03 09:44:17 -06:00
Christopher L. Shannon
d1558f172b
This closes #2958 2020-01-30 15:54:13 -05:00
Christopher L. Shannon
7ad2d0f71a
This closes #2959 2020-01-30 15:53:12 -05:00
Sebastian Thomschke
0250f84921
NO-JIRA Fix Javadoc warning in ActiveMQTestBase
Fixes Javadoc warnings "Javadoc: Exception Exception is not declared" and "Javadoc: Exception InterruptedException is not declared"
2020-01-29 17:34:08 +01:00
Sebastian Thomschke
c117976e3a
NO-JIRA Fix Javadoc @link syntax in ActiveMQServerConsumerPlugin
Fixes Javadoc warning "Javadoc: Missing closing brace for inline tag"
2020-01-29 17:21:53 +01:00
Sebastian Thomschke
a3aa669827
NO-JIRA Fix compiler warning in FileConfigurationParserTest
Fixes compiler warning "Unnecessary cast from String to String".
2020-01-29 17:15:53 +01:00
Wei Yang
1d1f0625db ARTEMIS-2544 Remove rolledback PageTransactionInfo to free up memory 2020-01-23 11:23:14 +08:00
Sebastian Thomschke
cf26103bb2 ARTEMIS-2571 Remove synchronization of ActiveMQServerImpl#getSessions() 2020-01-22 15:32:55 -06:00
Francesco Nigro
c3e74e055c ARTEMIS-2599 DescribeJournal isn't correctly counting surviving msg 2020-01-21 12:14:02 -05:00
Francesco Nigro
fa0c187ae6 ARTEMIS-2602 Reduce number of copies for non JDBC Journal 2020-01-18 18:45:12 +01:00
Francesco Nigro
b10d765139 ARTEMIS-2602 load surviving records into SparseArrayLinkedList 2020-01-17 14:31:52 -05:00
Clebert Suconic
1a6c4e5c62 ARTEMIS-2603 Deadlock between pageStore.getCurrentID and page.cleanup
This happened when JournalStorageManager.startReplication and PageStore.cleanup were called between multiple threads.
2020-01-17 11:39:30 -05:00
Clebert Suconic
bbe9f9adce NO-JIRA Adding test name into temporary folder name directory
This is to make it possible to identify what test is leaking files whenever that is happening.
That is because future tests will report the leaks, and it's difficult to identify where it happened.

Also i'm changing NoProcessFilesBehind to show the getOpenFD propertly
2020-01-13 09:39:51 -05:00
Justin Bertram
97735ca72c [maven-release-plugin] prepare for next development iteration 2020-01-10 09:00:58 -06:00
Justin Bertram
25a947f6cb [maven-release-plugin] prepare release 2.11.0 2020-01-10 08:57:46 -06:00
Clebert Suconic
e397a17796 ARTEMIS-2592 Fixing DeadLock between deleteMessages and depage
This was happening through purge
2020-01-09 19:41:14 -06:00
yang wei
3e20906a49 NO-JIRA typo on logger 2020-01-09 15:21:29 -06:00
Justin Bertram
9e9c0778b1 ARTEMIS-2516 support sys props in xinclude href 2020-01-09 14:04:09 -05:00
Clebert Suconic
534d8b4719 NO-JIRA Happy new year! 2020-01-08 20:44:05 -05:00
Justin Bertram
0293d80574 NO-JIRA support 0 in human readable byte calculation 2020-01-08 12:37:30 -06:00
Wei Yang
0e6a1dee47 ARTEMIS-2584 Optimize PageTransactionInfoImpl in-memory size 2020-01-08 12:39:14 -05:00
Justin Bertram
1ad8b3c059 ARTEMIS-2590 support com.sun.jndi.ldap.read.timeout in LDAPLoginModule 2020-01-08 12:38:27 -05:00
Justin Bertram
6a290cf2b2 ARTEMIS-2591 add details to consumer lock timeout log 2020-01-08 12:31:15 -05:00
Justin Bertram
59e7db8925 ARTEMIS-2567 redundant lock on server.lock file 2020-01-08 14:04:43 +08:00
Christopher L. Shannon (cshannon)
fe66506139 ARTEMIS-2565 - Add plugin support for Federated Queues/Addresses
Add a new interface called ActiveMQServerFederationPlugin to allow
customization of the federated queue/address feature of the broker
2020-01-06 06:38:35 -05:00
Dewald Pretorius
9fac4b866c ARTEMIS-2550 Support Websocket Continuation Frames
Large messages can be split up using Websocket Continuation Frames.
This allows for much smaller buffer sizes to send or receive
potentially very large messages.
2020-01-02 20:36:35 -06:00
Clebert Suconic
13278cc45f ARTEMIS-2581 Duplicate Detection on AMQP should be configurable
There is an optimization in AMQP, that properties are only parsed over demand.

It happens that after ARTEMIS-2294 (commit 2dd06716989820eeecad7f39faabfbb8f025f7f1),
every send would request for the property on the message, resulting the properties to always be parsed upon send.
Even when there's no use of application properties.
2019-12-19 17:54:21 -05:00
Justin Bertram
8d8eaebb65 ARTEMIS-2580 support pluggable SSL TrustManagerFactory 2019-12-19 17:53:52 -05:00