Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-06 18:18:43 +00:00
Code Issues Packages Projects Releases Wiki Activity
4,912 Commits 10 Branches 64 Tags
Commit Graph

4912 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Michael Pearce
8666cb61d8 This closes #1811 2018-01-23 17:07:34 +00:00
Justin Bertram
439761d6b8 ARTEMIS-1408 document synchronization 2018-01-23 17:07:33 +00:00
Clebert Suconic
6ad29e4039 This closes #1801 2018-01-23 11:51:42 -05:00
Francesco Nigro
56d68f0b72 ARTEMIS-1607 OpenWire is sending responses too early with durable messages 
AMQSession is sending response back without waiting past I/O tasks on StorageManager to be finished
 2018-01-23 11:51:41 -05:00
Michael Pearce
f0d2fae4b3 This closes #1808 2018-01-23 16:23:25 +00:00
Justin Bertram
0b9f2cb452 ARTEMIS-836 log JDBC details when starting 2018-01-23 16:23:24 +00:00
Clebert Suconic
8e058d2a76 ARTEMIS-1626 Thread check will not throw leaks failures for previously failed tests 
This closes #1800
 2018-01-23 10:17:53 -05:00
Howard Gao
974bdd622e This closes #1803 2018-01-23 10:52:05 +08:00
Clebert Suconic
35222485e8 ARTEMIS-1628 Limit pool size on artemis journal 2018-01-23 10:48:31 +08:00
Clebert Suconic
42049bf96a This closes #1799 2018-01-22 18:07:44 -05:00
Stanislav Knot
156372ab40 ARTEMIS-1625 fix moving messages 2018-01-22 18:07:44 -05:00
Clebert Suconic
b740181929 This closes #1786 2018-01-22 18:02:04 -05:00
Francesco Nigro
0387b1a842 ARTEMIS-1616 OpenWire improvements 
Refactored OpenWireMessageConverter::inbound into a private static method
 2018-01-22 18:02:03 -05:00
Francesco Nigro
c6b6dd95d1 ARTEMIS-1616 OpenWire improvements 
Refactored OpenWireMessageConverter::toAMQMessage into smaller methods
 2018-01-22 18:02:03 -05:00
Francesco Nigro
e7a1dca7b5 ARTEMIS-1616 OpenWire improvements 
Used SimpleString on AMQSession with HDR_DUPLICATE_DETECTION_ID and CONNECTION_ID_PROPERTY_NAME
 2018-01-22 18:02:03 -05:00
Francesco Nigro
9650c80ba7 ARTEMIS-1616 OpenWire improvements 
Cached Notification Destination check on AMQConsumer to avoid expensive ActiveMQDestination::toString
 2018-01-22 18:02:03 -05:00
Francesco Nigro
64724c3520 ARTEMIS-1616 OpenWire improvements 
Used SimpleString on OpenWireMessageConverter to avoid translations on CoreMessage
 2018-01-22 18:02:03 -05:00
Francesco Nigro
17c0a331ac ARTEMIS-1616 OpenWire improvements 
Added existing queues cache to avoid multiple expensive AMQSession::checkAutoCreateQueue calls
 2018-01-22 18:02:03 -05:00
Francesco Nigro
051a3cae49 ARTEMIS-1616 OpenWire improvements 
Optimized SimpleString::split because heavily used into AddressImpl::new
 2018-01-22 18:02:03 -05:00
Francesco Nigro
54d0161850 ARTEMIS-1616 OpenWire improvements 
Refactored OpenWireMessageConverter::inbound into smaller methods
 2018-01-22 18:02:03 -05:00
Francesco Nigro
2db4eafc4d ARTEMIS-1616 OpenWire improvements 
Avoided copy of CoreMessage when not needed and cached lambda on hot path
 2018-01-22 18:02:03 -05:00
Clebert Suconic
04a9884d30 This closes #1805 2018-01-22 17:44:50 -05:00
Justin Bertram
04298136b7 ARTEMIS-609 fix interceptor XML docs 2018-01-22 17:44:50 -05:00
Clebert Suconic
d3e81ca882 This closes #1802 2018-01-22 17:44:14 -05:00
Timothy Bish
5e6967c809 ARTEMIS-1504 Update Qpid JMS to 0.29.0 and proton-j to 0.25.0 
Updates to latest Qpid JMS and the latest Proton-J release
 2018-01-22 17:44:14 -05:00
Clebert Suconic
1a56efd3a5 This closes #1804 2018-01-22 16:19:01 -05:00
Justin Bertram
557224795b ARTEMIS-608 document adding runtime deps 2018-01-22 16:19:00 -05:00
Michael Pearce
72a267c466 This closes #1791 2018-01-22 17:30:46 +00:00
Francesco Nigro
3f646474c2 ARTEMIS-1622 Reduce memory footprint of QueueImpl 
LinkedListImpl is turned into an optionally intrusive linked list by allowing message references to extend Node.
 2018-01-22 17:30:45 +00:00
Justin Bertram
71a49c4614 This closes #1792 2018-01-22 11:27:59 -06:00
Howard Gao
98ce31bf58 ARTEMIS-1621 Make producerWindowSize configurable on clusterconnection bridges 
The cluster connection bridge hard codes its producerWindowSize to -1
(meaning no producer flow control) even if you configure it otherwise.
 2018-01-22 11:27:59 -06:00
Justin Bertram
31ce365334 This closes #1798 2018-01-22 11:23:28 -06:00
David Shunfenthal
fcc6bbdebe ARTEMIS-1624 Adding in configuration condition for turning on the console when using maven plugin 2018-01-22 11:23:28 -06:00
Michael Pearce
56d4f816a4 This closes #1795 2018-01-22 17:14:15 +00:00
Jeff Mesnil
2af7b3bdcb [ARTEMIS-1609] Add distinct name/address for JMS destinations 
Fix internalCreateTopic method: the topics are keyed by their core
addresses, not their JMS names.
 2018-01-22 17:14:14 +00:00
Howard Gao
701ab1feba This closes #1785 2018-01-22 20:32:06 +08:00
gtully
82e4f465ee [ARTEMIS-1030] add support for auto mapping openwire virtual topic consumer destinations to FQQN 2018-01-22 11:10:46 +00:00
Andy Taylor
6428a897c3 This closes #1794 [ARTEMIS-1552] differenciate empty frame from no frame 2018-01-22 10:11:58 +00:00
gtully
b6612c9505 [ARTEMIS-1552] differenciate empty frame from no frame such that a null response is accepted when valid 2018-01-19 14:19:54 +00:00
Justin Bertram
4977042cd9 This closes #1789 2018-01-18 21:01:41 -06:00
Christopher L. Shannon (cshannon)
bc38d7ce32 ARTEMIS-1619 - Add plugin support for address lifecyle 
Adding callbacks to the plugin API for address creation, update and
removals
 2018-01-18 21:01:41 -06:00
Justin Bertram
10f1e1223b This closes #1781 2018-01-18 20:55:00 -06:00
Clebert Suconic
61a1123ee1 ARTEMIS-1613 Integrating JDBC into CLI (create print-data and exp) 2018-01-18 20:55:00 -06:00
Michael Pearce
64424f2873 This closes #1790 2018-01-18 23:12:01 +01:00
Francesco Nigro
cdc98c2a66 ARTEMIS-1606 - Change AddressInfo RoutingType Set to use EnumSet 
This is fixing the broken testUnsupportedRoutingType test
 2018-01-18 23:12:01 +01:00
Clebert Suconic
60a8b49b1d This closes #1742 2018-01-18 13:17:05 -05:00
shoukun
7c6530eb79 ARTEMIS-1570 Test replication consistency 
Test consistency between live and backup, espacially on
a slow live.
The test use MessagePersister::encode to simulate slow IO condition.
After live started, we send 5 message with a delay(default 500ms),
then start backup, wait until replicated, then send more message
without delay. If all message sent successfully, the backup should
has the same messages as live. We assert the message number only.
 2018-01-18 13:16:35 -05:00
shoukun
c4bfb9521f ARTEMIS-1570 Flush appendExecutor before take journal snapshot 
When live start replication, it must make sure there is
no pending write in message & bindings journal, or we may
lost journal records during initial replication.

So we need flush append executor after acquire StorageManager's
write lock, before Journal's write lock.
Also we set a 10 seconds timeout when flush, the same as
Journal::flushExecutor. If we failed to flush in 10 seconds,
we abort replication, backup will try again later.

Use OrderedExecutorFactory::flushExecutor to flush executor
 2018-01-18 13:16:27 -05:00
Clebert Suconic
9f77514225 This closes #1787 2018-01-18 10:18:40 -05:00
Clebert Suconic
9dbc5dc409 ARTEMIS-1577 Address-settings policies not working with older clients 
This closes #1744
 2018-01-18 10:18:39 -05:00