Commit Graph

239 Commits

Author SHA1 Message Date
Jeff Mesnil ed5533ecb6 [ARTEMIS-472] add cause to AMQ222137 warning
JIRA: https://issues.apache.org/jira/browse/ARTEMIS-472
2016-04-08 13:16:15 +01:00
Clebert Suconic 50eac7c824 ARTEMIS-468 Amendments to how redelivery count is handled on openwire 2016-04-07 13:56:31 -04:00
Howard Gao 8a998ad805 ARTEMIS-468 Fix openwire redelivery related regressions under integration-tests 2016-04-07 12:12:28 -04:00
Martyn Taylor e2c6d0b7f7 ARTEMIS-465 Create LM on write packet in ReplicationEndpoint
If a LM write packet is received from the live assume that the large
message exists and create a local reference.

Old behavour would reject the packet which could lead to loss of data on
failover see JIRA.
2016-04-04 23:15:54 -04:00
Dominik Pospisil 078d38bc37 [ARTEMIS-444] Extend AIOSequentialFileFactory to check underlying FS 2016-04-04 12:23:36 -04:00
Clebert Suconic 3aedf27386 ARTEMIS-463 More simplifications on the openwire head
https://issues.apache.org/jira/browse/ARTEMIS-463

This will have some extra refactoring on the protocol head, transferring responsibility to the broker classes in a lot of cases
and removing some duplicated code

This was a team effort from Clebert Suconic and Howard Gao
2016-04-04 11:08:43 -05:00
Clebert Suconic 6ddf486f8f ARTEMIS-463 Refactoring on Openwire
https://issues.apache.org/jira/browse/ARTEMIS-463

This was a team effort from Clebert Suconic and Howard Gao
2016-04-04 11:08:43 -05:00
Ville Skyttä 3a2d5de49e Remove unnecessary code 2016-04-04 11:04:49 -05:00
Ville Skyttä 16ee65309c Add missing @Override annotations 2016-04-04 11:03:48 -05:00
Martyn Taylor afdb78dd5c ARTEMIS-456 Synchronize sendReplicatePacket method
There is a potential deadlock scenario if 2 threads try
sendReplicatePacket.  Thread 1 registers Netty callback which will
invoke readyForWrites() method, which locks the callback list and waits
on the replicationLock.  Thread 2 enters sendReplicatePacket and gets
the replicationLock and is blocked on the callback list lock.  This fix
ensures the sendReplicatePacket blocks on the ReplicationManager meaning
no interleaving of the Netty callback thread and the wait on lock can
happen.
2016-03-23 10:52:56 -05:00
jbertram e2b799d003 ARTEMIS-451 JAAS user/role props reload 2016-03-22 10:48:38 -05:00
Clebert Suconic ee6a03295f ARTEMIS-437 Improving lock over certain protocols
Avoiding deadlocks between acks and other factors
2016-03-16 08:23:58 -04:00
jbertram 196f0ca8d6 ARTEMIS-432 client gets msg after session stop 2016-03-11 15:33:28 -05:00
Ville Skyttä 31404f8a38 Remove redundant null checks 2016-03-07 15:49:50 -05:00
Andy Taylor a3962d6d26 ARTEMIS-426 - java.lang.IllegalStateException: AMQ119116: Netty Acceptor unavailable
also related to https://issues.apache.org/jira/browse/ARTEMIS-416

https://issues.apache.org/jira/browse/ARTEMIS-426
2016-03-01 14:17:41 +00:00
Martyn Taylor 964b145733 ARTEMIS-423 Do not set backup node as self 2016-02-29 16:11:58 +00:00
Ville Skyttä 7c275cdb1a Use generics more 2016-02-28 01:06:59 +02:00
Clebert Suconic 6bdfe95f66 ARTEMIS-350 small improvement on the writable logic 2016-02-23 15:04:49 -05:00
Clebert Suconic c4760488e3 fixing regression caused by #397 2016-02-23 14:22:51 -05:00
jbertram 2fcd474bb3 ARTEMIS-350 fix for potential race
It's possible for the latch used for flow control here to get out of sync. In
other words, multiple count-downs can occur between count-ups so that the latch
always has a count > 0. When this situation arises then every single packet
sent to the replica is delayed by 5 seconds.

The solution here essentially is to eliminate the latch completely and use a
condition/wait/notify pattern.
2016-02-23 12:56:45 -06:00
Andy Taylor f6ea511b8a ARTEMIS-416 - Netty Acceptor allows transfer of connections when paused
Throw an exception if the acceptor is paused or not started

https://issues.apache.org/jira/browse/ARTEMIS-416
2016-02-22 10:47:13 -05:00
Ville Skyttä aa3f3bd6a7 Use try-with-resources more 2016-02-21 12:09:43 +02:00
jbertram e762f823d1 ARTEMIS-391 log WARN on cxn limit 2016-02-18 10:19:59 -06:00
Clebert Suconic 9ebc6786b6 ARTEMIS-401 Refactoring Acceptors and ProtocolManager to support parameters
https://issues.apache.org/jira/browse/ARTEMIS-401
2016-02-18 10:14:26 -06:00
jbertram dffe93152b ARTEMIS-395 auto-delete only if setting is true 2016-02-09 14:24:51 -05:00
jbertram 94dc2976ef ARTEMIS-388 listen for activation failures 2016-02-09 14:24:07 -05:00
kurobako b8dd0219a3 eliminated NPE possibility in QueueImpl class 2016-02-09 11:08:35 -05:00
Clebert Suconic e9ce4ce40b ARTEMIS-392 Fixing Allocator after socket upgrade
https://issues.apache.org/jira/browse/ARTEMIS-392
2016-02-08 10:34:16 -06:00
Martyn Taylor 32a9d60a3d Allow users to configure jdbc driver class name
This patch allows users to configure the Driver class that the JDBC
store and journal uses and removes Derby as a default.
2016-02-08 11:23:38 -05:00
Dmitrii Tikhomirov 2953e46aec ARTEMIS-393 Server logs message with queue deploy even when topic is being deployed. 2016-02-08 10:12:56 -05:00
jbertram 8dcea17f11 ARTEMIS-387 grammar fix 2016-02-05 12:13:11 -06:00
jbertram 5a483f922a ARTEMIS-376 NPE during fail-back 2016-02-04 14:20:02 -06:00
jbertram 1eb631e2b8 ARTEMIS-374 support schedule messages on LVQ 2016-02-01 11:58:56 -06:00
Clebert Suconic e62a820414 Fixing ServerMessage's copy and MQTT delivery 2016-01-27 17:12:56 -05:00
Martyn Taylor 5383a0c409 Handful of JDBC Journal Fixes
This patch fixes a number of bugs with the JDBC Journal implementation.
Mainly around how it was handling transactions.  The XA transactions
tests are now enabled to test both the File and Database store.
2016-01-27 12:17:55 -05:00
Lachezar Dobrev cc4d24cfbb ARTEMIS-362 Broadcast only filled buffer content.
When publishing server connectors to other cluster members the whole buffer is sent.
This fixes ARTEMIS-362 by extracting the filled part of the buffer for broadcasting.

Added test case that checks that packet size does not exceed 1500 bytes with one connector.
2016-01-26 16:30:44 -05:00
Ville Skyttä 4e5b5b393a Access static methods and fields directly 2016-01-25 12:12:54 -05:00
Ville Skyttä 13cb6ddfd1 Add missing @Override annotations 2016-01-25 12:10:25 -05:00
Ville Skyttä 3f20e0d19a Remove redundant type parameters 2016-01-25 12:10:25 -05:00
Martin Styk 812affffbe ARTEMIS-360 - PagingTest.testSpreadMessagesWithFilterWithDeadConsumer fails on timeout waiting for stop paging
extended waiting time
2016-01-25 14:37:43 +01:00
Clebert Suconic 7957f574f6 ARTEMIS-357 No need to check copy any longer 2016-01-23 10:45:35 -05:00
Andy Taylor a24dc5b61a ARTEMIS-350 - add timeout to avoid deadlock
https://issues.apache.org/jira/browse/ARTEMIS-350
2016-01-21 10:02:24 +00:00
Martyn Taylor 4922a7618a Bump to next version to 1.3.0-SNAPSHOT 2016-01-20 17:25:07 +00:00
Andy Taylor c1de710eb3 ARTEMIS-346 - Add Management send text message functionality similar to ActiveMQ
https://issues.apache.org/jira/browse/ARTEMIS-346
2016-01-20 10:35:36 -05:00
Clebert Suconic 0a9a6c92f4 ARTEMIS-347 Fixing NPE 2016-01-19 23:15:10 -05:00
Clebert Suconic 3f23c9916e ARTEMIS-347 - supporting URIs on the cluster connection 2016-01-19 17:35:12 -05:00
Clebert Suconic 17a443b1f0 adding timeout verification
Some VMs (IBM) can eventually ignore the System.gc call.
Adding some mitigation when that happens here
2016-01-19 17:20:49 -05:00
Clebert Suconic 68faa1d252 ARTEMIS-350 Small improvement on the replication stop 2016-01-19 11:20:47 -05:00
Andy Taylor b7f0d14b18 ARTEMIS-350 - possible OOM in replication manager
https://issues.apache.org/jira/browse/ARTEMIS-350
2016-01-19 11:18:01 -05:00
jbertram d94c044e90 ARTEMIS-349 LDAP plugin listener
This feature required a bit of refactoring to the plugin interface itself as
well as a restriction on the configuration so that either only one plugin could
be specified or an ulimited number of security-setting matches. This was done
to prevent messy situations where a plugin could update settings from the XML
or even another plugin if there were overlapping matches.
2016-01-19 09:45:52 -05:00