Justin Bertram
2efa44daf5
ARTEMIS-2692 refactor queue creation
...
This commit does the following:
- Deprecates existing overloaded createQueue, createSharedQueue,
createTemporaryQueue, & updateQueue methods for ClientSession,
ServerSession, ActiveMQServer, & ActiveMQServerControl where
applicable.
- Deprecates QueueAttributes, QueueConfig, & CoreQueueConfiguration.
- Deprecates existing overloaded constructors for QueueImpl.
- Implements QueueConfiguration with JavaDoc to be the single,
centralized configuration object for both client-side and broker-side
queue creation including methods to convert to & from JSON for use in
the management API.
- Implements new createQueue, createSharedQueue & updateQueue methods
with JavaDoc for ClientSession, ServerSession, ActiveMQServer, &
ActiveMQServerControl as well as a new constructor for QueueImpl all
using the new QueueConfiguration object.
- Changes all internal broker code to use the new methods.
2020-04-13 14:25:30 -05:00
Clebert Suconic
0dfbfaa833
NO-JIRA Adding Serialization compatiblity for a recent 2.x release
2020-04-13 12:25:51 -04:00
Robbie Gemmell
17b5b09b46
ARTEMIS-2659: address some more sporadic test failures due to races in tests
2020-04-13 16:13:31 +01:00
Clebert Suconic
e5b8237d2b
NO-JIRA Increasing timeout on test and avoiding intermittent failure
2020-04-08 22:41:06 -04:00
Clebert Suconic
4d7c4ea51c
NO-JIRA Improving logging on CoreClientOverOneWaySSLKerb5Test
...
in case of a failure, it should throw the complete exception instead of just showing Assert.fail
2020-04-08 22:33:56 -04:00
Clebert Suconic
a084e5b37f
NO-JIRA Avoiding intermittent failures on BridgeTest
2020-04-08 22:27:37 -04:00
Clebert Suconic
bbac2937ee
NO-JIRA Avoiding intermittent failure on OpenWireLargeMessageTest
2020-04-08 22:17:49 -04:00
Clebert Suconic
fa67499509
NO-JIRA Avoiding Intermittent failures on FederatedQueueTest
2020-04-08 16:49:57 -04:00
brusdev
c36170477d
ARTEMIS-2686 Fix MQTT connect message rejection
...
Initialize the session state with a default value to fix a NPE, when an incoming
MQTT interceptor rejects a MqttConnectMessage.
2020-04-08 15:45:19 -04:00
brusdev
24c0601519
ARTEMIS-2684 NullPointer exception when slave tries to scale down
...
Check the parentServer before to access to its configuration and storageManager.
2020-04-08 15:42:26 -04:00
Clebert Suconic
7ff71a97af
ARTEMIS-2699 Avoid some journal exceptions on test
2020-04-08 14:56:06 -04:00
brusdev
0f200a4798
ARTEMIS-2698 Expose queue group attributes
2020-04-08 12:53:56 -04:00
Francesco Nigro
124ed872a6
ARTEMIS-2702 QuorumVoteServerConnect with requestToStayLive is voting order sensitive
2020-04-08 12:53:03 -04:00
Clebert Suconic
ee29b4be10
ARTEMIS-2659 Fixing auto created queues leading to journal errors
...
This was causing the queue to be removed right before the server being stopped, leading to exceptions about the journal being stopped.
2020-04-08 12:42:38 -04:00
Clebert Suconic
1932cfc818
ARTEMIS-2659 Fixing intermittent failures
2020-04-08 11:34:05 -04:00
Clebert Suconic
858a8240f9
ARTEMIS-2659 / ARTEMIS-2673 Fix AmqpSendReceiveTest.testAcceptWithoutSettling
2020-04-07 23:06:40 -04:00
Clebert Suconic
af796d5ce4
ARTEMIS-2701 Improving DLQ/check over previously removed records
2020-04-06 12:25:35 -04:00
Clebert Suconic
ae17fd6552
NO-JIRA Fixing intermittent failure on AutoDeleteJmsDestinationTest
2020-04-05 00:58:57 -04:00
brusdev
38a79be314
ARTEMIS-2691 Improve critical analyzer LOG policy
...
Reset the critical component timer after the expiration to allow further LOG
actions after the first expiration.
2020-04-04 18:19:46 -04:00
Clebert Suconic
1320ad9367
NO-JIRA more fixes into NotificationTest
...
this test was failing intermittently.
Some small speedup on the test as well.
2020-04-03 10:24:24 -04:00
Clebert Suconic
b0cfbe0a34
NO-JIRA Fixing NotificationTest
2020-04-02 11:15:16 -04:00
Atri Sharma
505b3b0fdc
ARTEMIS-2636: Add Disk Store Usage Metrics
...
ARTEMIS-2688: Check Arguments In FileStoreMonitor.calculateUsage
2020-04-02 11:04:42 -04:00
Clebert Suconic
bd77a536c6
ARTEMIS-2685 Not Block Netty Thread in any way for OpenWire
2020-04-01 18:02:48 -04:00
Francesco Nigro
493ce497c7
ARTEMIS-1975 Fix AMQP paged large message usage counter
2020-04-01 17:46:26 -04:00
Francesco Nigro
891f2817ff
NO-JIRA Improve AMQP paging test coverage and determinism
2020-03-31 15:55:04 -04:00
Atri Sharma
405eb969c1
ARTEMIS-2636: Introduce Disk Usage Metrics
...
ARTEMIS-2636: This commit introduces metrics to publish the amount of disk used currently
2020-03-30 22:27:58 -04:00
Justin Bertram
59e07c9780
ARTEMIS-2681 timestamp not set on notif msgs
2020-03-27 15:42:26 -04:00
Federico Valeri
8cf35385a4
ARTEMIS-2608 Fix ClassCastException on binary properties conversion
2020-03-27 13:12:57 -04:00
Clebert Suconic
6d2b17d23a
NO-JIRA Improving SoakPagingTest
2020-03-26 14:38:57 -04:00
Clebert Suconic
ca50b3449e
ARTEMIS-1975 Removing ThreadLocal for StorageManager
2020-03-25 21:54:46 -04:00
Justin Bertram
fdfe3ba3fa
ARTEMIS-2679 deprecate message-expiry-thread-priority
...
Due to the changes in 6b5fff40cb
the
config parameter message-expiry-thread-priority is no longer needed. The
code now uses a ScheduledExecutorService and a thread pool rather than
dedicating a thread 100% to the expiry scanner. The pool's size can be
controlled via scheduled-thread-pool-max-size.
2020-03-25 16:43:38 -04:00
Clebert Suconic
03fb630f73
ARTEMIS-1975 Fixing LargeMessage encoding for replication
2020-03-25 16:16:05 -04:00
Clebert Suconic
31e72c6cbb
NO-JIRA Adding timeout into AmqpReplicatedLargeMessageTest
2020-03-24 23:05:23 -04:00
Clebert Suconic
a4489a322e
ARTEMIS-1975 Moving encode cache towards AMQPLargeMessage
...
Using a property on AMQPLargeMessage instead of a ThreadLocal
This was causing issues on the journal as the message may transverse different threads on the journal.
2020-03-24 18:22:59 -04:00
Clebert Suconic
31c945f8b0
ARTEMIS-1975 Fixing encodesize cached on AMQP Large Message
...
Encoding ahead is broken with AMQP Large Message
This is still part of ARTEMIS-1975
2020-03-24 15:51:46 -04:00
Benjamin Graf
4b49b3f371
ARTEMIS-975: Add transactional records to deletedRecords to check for committed transactions that also hold references to
2020-03-24 09:32:47 -05:00
Clebert Suconic
f874a02d17
ARTEMIS-2673 PageStore should only be removed when Address is removed
...
& ARTEMIS-2674 AMQP should use a separate executor for IO
2020-03-23 20:02:17 -04:00
Justin Bertram
3107535a32
ARTEMIS-2671 NPE in LDAP security plugin listener
...
To get the name of the destination use the relative Rdn position rather than a
strict match of "uid". Also, improve logging.
2020-03-23 17:02:38 -04:00
Justin Bertram
402dda2161
ARTEMIS-2667 NPE w/clearing non-durable dupl ID cache
2020-03-23 16:55:42 -04:00
Francesco Nigro
085a74cf06
ARTEMIS-2669 not durable AMQP messages cannot became durable on depaging
2020-03-22 17:46:37 -04:00
Clebert Suconic
559fa2008d
ARTEMIS-2672 multi-thread isue with Shared Subscriptions
...
Some of them may throw queue already existed exception
2020-03-20 21:26:45 -04:00
Michael Pearce
f1fdfc6857
ARTEMIS-2665 AMQP use createSharedQueue like Core
2020-03-18 11:51:58 -04:00
brusdev
974a80002a
NO-JIRA Fixing GeneralInteropTest stability
2020-03-17 16:23:05 -04:00
brusdev
43639bdeae
ARTEMIS-2664 The prefetch size is exceeded after delivered acks
...
Decrement delivered acks before acquiring credits.
2020-03-17 14:08:10 -04:00
Francesco Nigro
5f0b7dd7cd
ARTEMIS-2661 AMQP Journal loading is triggering reencode
2020-03-17 14:02:28 -04:00
Clebert Suconic
395eb1a2bb
NO-JIRA Fixing GeneralInteropTest
2020-03-17 12:42:55 -04:00
Clebert Suconic
4723405214
ARTEMIS-2658 Enabling thread check at end of test
2020-03-17 09:53:07 -04: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
Clebert Suconic
ff58e6e306
ARTEMIS-2658 Smoke tests for Paging on AMQP and Core
2020-03-16 16:43:31 -04:00
Justin Bertram
31f00fda36
NO-JIRA some tests for auto-create & FQQN w/JMS
2020-03-16 09:25:55 -05:00
Justin Bertram
91eeacca31
ARTEMIS-2659 fix race in AMQP test
2020-03-16 09:02:51 -05:00
Clebert Suconic
c3128aa144
ARTEMIS-2642 Fixing Drain Timeout Issue on AMQP
...
The drain control has to immediately flush
otherwise a next flow control event may remove the previous status from Proton.
So, this really cannot wait the next executor, and it has to be done immediately.
2020-03-11 11:44:42 -04:00
brusdev
aa8d598a35
ARTEMIS-2650 The delivering count is wrong after reconnecting an openwire client
...
Fix the conversion of the message id from the CORE messages.
Fix the credits acquired for acknowledges related to undelivered messages.
2020-03-11 11:14:29 -04:00
Justin Bertram
0cb3c96b3e
ARTEMIS-1194 fix test
2020-03-10 10:32:30 -04:00
Justin Bertram
ec958d7d27
NO-JIRA fix errant test directory
2020-03-09 21:08:30 -05:00
Andrius Dagys
f1474ce7c8
ARTEMIS-1194 Add SOCKS support
...
Add a Netty socks proxy handler during channel initialisation to allow
Artemis to communicate via a SOCKS proxy. Supports SOCKS version 4a & 5.
Even if enabled in configuration, the proxy will not be used when the
target host is a loopback address.
2020-03-07 21:35:38 +00:00
brusdev
45fe604859
Revert "ARTEMIS-2644 Include client id into non durable subscriber queue name"
...
This reverts commit be0fa47d63
.
2020-03-07 20:11:40 +00:00
Justin Bertram
e9ee9956bd
ARTEMIS-2639 lost notif props with OpenWire+divert
...
Historically speaking, all message properties starting with AMQ HDR
would not be passed to OpenWire messages. However, that blocked the
properties from management notifications so ARTEMIS-1209 was raised and
the solution there was to pass properties that started with _AMQ *if*
the consumer was connected to the management notification address.
However, in this case messages are diverted to a different address so
this check fails and the properties are removed. My solution will be to
check the message itself to see if it has the _AMQ_NotifType property
(which all notification messages do) rather than checking where the
consumer is connected.
2020-03-05 21:38:51 -05:00
Justin Bertram
ed7fee6d9c
ARTEMIS-2643 allow masked password when resetting via mgmnt
2020-03-05 21:38:09 -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
brusdev
be0fa47d63
ARTEMIS-2644 Include client id into non durable subscriber queue name
2020-03-05 19:09:03 +01:00
Bartosz Spyrko-Smietanko
eb41be78f3
[ARTEMIS-2176] RA connection properties are not propagated to XARecoveryConfig
2020-03-03 08:56:18 +00:00
Clebert Suconic
0cac669840
ARTEMIS-2637 Making UDP client discovery resilient
...
In case there is a hardware, firewal or any other thing making the UDP connection to go deaf
we will now reopen the connection in an attempt to go over possible issues.
This is also improving locking around DiscoveryGroup initial connection.
2020-02-28 11:54:27 -05:00
brusdev
de113e47ae
ARTEMIS-2625 testListConsumers failing on IBM JDK 8
...
Fix JmxServerControlTest.testListConsumers.
2020-02-25 12:19:05 -06: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
Justin Bertram
72429e1e49
ARTEMIS-2325 ack handler being invoked twice
2020-02-14 13:12:49 -05:00
Justin Bertram
b76700c18f
NO-JIRA fix JMSMessageConsumerTest.testTimedOutWaitingForWriteLogOnConsumer
2020-02-14 13:12:49 -05:00
Justin Bertram
daae7e750a
ARTEMIS-2619 allow disabling STOMP 'server' header
2020-02-12 19:38:38 -06:00
Francesco Nigro
5897909dc9
ARTEMIS-2617 use core pools to reduce GC on journal loading
2020-02-12 13:29:51 -05:00
Clebert Suconic
0487e712e2
NO-JIRA some Wait.assertEquals
2020-02-10 09:25:06 -05:00
brusdev
b71178b4fb
ARTEMIS-2600 Update mqtt-client version to 1.16 for tests
2020-02-06 12:21:54 -06:00
Wei Yang
1d1f0625db
ARTEMIS-2544 Remove rolledback PageTransactionInfo to free up memory
2020-01-23 11:23:14 +08: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
brusdev
caa19ab144
ARTEMIS-2598 Update netty version to 4.1.43.Final
...
Update netty version to 4.1.43.Final and netty-tcnative version to 2.0.26.Final.
Change restricted-security-client.policy because Netty 4.1.43.Final requires
access to two more files: /etc/os-release and /usr/lib/os-release.
2020-01-17 14:28:31 -05:00
brusdev
1716655214
ARTEMIS-2597 Memory Leak when closing AMQP Consumers in the context
...
Remove server senders on remote link close.
2020-01-15 09:56:21 +01:00
Clebert Suconic
3fff744de4
NO-JIRA Adding Queue Delete Delay on openWireTestsuite
...
Some open wire tests will close a consumer and open it right away.
The removal of the queue is asynchronous, having this kind of behaviour may lead to issues
after we moved the QueueManager to be asynchronous.
2020-01-10 11:31:53 -05:00
Justin Bertram
29554acc56
NO-JIRA Bumping extra-tests pom
2020-01-10 09:07:13 -06: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
757d38f53c
NO-JIRA Fixing Stomp Tests after QueueManager change
2020-01-10 00:08:11 -05: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
Francesco Nigro
6cc5749c7b
ARTEMIS-2569 LinkedListImpl tests should not rely on the GC mechanism
2020-01-09 13:40:43 -05:00
Clebert Suconic
534d8b4719
NO-JIRA Happy new year!
2020-01-08 20:44:05 -05:00
Justin Bertram
0513393091
NO-JIRA fix tests after SSL resource regen
2020-01-08 13:04:17 -05:00
Keith Wall
39cd9d56f6
ARTEMIS-2497: [AMQP] Allow handling of the reject disposition to be configured.
2020-01-08 11:56:23 -05:00
Justin Bertram
81c83e05fa
NO-JIRA regenerate expired SSL test resources
2020-01-08 14:09:33 +08:00
Justin Bertram
3e343db736
ARTEMIS-2580 fix tests
2020-01-08 14:00:04 +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
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 2dd0671698
),
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
Clebert Suconic
7efebc97c6
NO-JIRA moving OpenWire test under ./integration
2019-12-18 09:59:34 -05:00
Justin Bertram
2a452bd7a3
ARTEMIS-2578 clarify storage capacity messages
...
This is a surprisingly large change just to fix some log messages, but
the changes were necessary in order to get the relevant data to where it
was being logged. The fact that the data wasn't readily available is
probably why it wasn't logged in the first place.
2019-12-17 20:27:10 -05:00