Commit Graph

224 Commits

Author SHA1 Message Date
Justin Bertram 01465035c0 ARTEMIS-970 handle indeterminate JMS destination 2017-02-23 12:55:27 -05:00
Jiri Danek a7a0535afa NO-JIRA Fixing typos in log messages, test names and comments
Related to ARTEMIS-387 (fowardingAddress)
2017-02-20 20:54:45 -05:00
Clebert Suconic 29af4a982a NO-JIRA: removing dead code on AMQPSessionContext 2017-02-20 19:34:38 -05:00
Clebert Suconic b788acd834 ARTEMIS-982 Fixing possible deadlock on AMQP.close & delivery
https://issues.apache.org/jira/browse/ARTEMIS-982

This is fixing a possible deadlock on delivering messages while AMQP close is called for any reason.
2017-02-20 12:35:49 -06:00
Ulf Lilleengen 5f6a390b60 ARTEMIS-908: Ensure that connection lock is held when flushing 2017-02-15 14:09:27 +01:00
Justin Bertram ff3e75d148 NO-JIRA move RoutingType to different package 2017-02-13 09:50:41 -06:00
Andy Taylor 318778954d ENTMQBR-522 - dont ack on separately settled deliveries
https://issues.jboss.org/browse/ENTMQBR-522
2017-02-10 09:50:51 -05:00
Timothy Bish b9bf5d54f2 ARTEMIS-794 Add tests for handling of various outcomes for deliveries
Adds tests for handling of Rejected, Released and Modified outcomes for
a delivery sent to a receiver.  Tests show that for the Modified outcome
the broker is redelivering the message to the same receiver when the
undeliverable here value is set which violates the AMQP 1.0 specified
handling of that field.  Also for Rejected outcome the broker should
be sending the rejected message to the DLQ as Rejected is supposed to
be a terminal outcome.

Small fix included to not adjust the delivery count if the Modified
outcome does not indicate that the delivery failed.
2017-02-07 13:45:11 +00:00
Will Reichert 3347a4fd27 ARTEMIS-928 Changing Netty and InVM to copy buffers, and retain them on the Netty Polls. 2017-01-18 16:59:32 -05:00
Andy Taylor f52cb5c610 ARTEMIS-918 - use requested routing type when client defined with amqp and address doesnt exist
https://issues.apache.org/jira/browse/ARTEMIS-918
2017-01-12 12:07:16 +00:00
Howard Gao 4e309d842e ARTEMIS-562 Use 'to' field if sender target is null 2017-01-11 14:20:39 -05:00
Andy Taylor 355d33ea4f fix log trace message throwing exception 2017-01-09 14:58:25 -05:00
Ulf Lilleengen f2f3552067 ARTEMIS-908: Hold connection lock when issuing credits 2017-01-04 10:59:33 -06:00
Timothy Bish 51c95babfe ARTEMIS-901 Account for the presence of authzid in sasl plan auth
If the SASL plain mechanism arrives with the authzid value set the
mechanism needs to account for its presence and use the correct fields
of the exchange to get the username and password values.  Adds some
tests to validate this fix.
2016-12-21 18:18:54 -05:00
Andy Taylor 63f723fe8d ARTEMIS-888 - default to false if header durable not set
https://issues.apache.org/jira/browse/ARTEMIS-888
2016-12-20 09:32:33 +00:00
Andy Taylor 198143edd0 ARTEMIS-892 - add lock to tick method
https://issues.apache.org/jira/browse/ARTEMIS-892
2016-12-16 12:11:54 +00:00
Clebert Suconic 0c18c343e9 NO-JIRA: fixing checkstyle 2016-12-15 17:00:10 -05:00
Martyn Taylor 55fbcfebf8 Do not autoDelete address if it was not autoCreated 2016-12-15 17:13:09 +00:00
Andy Taylor a9b32bdf0b adding missing check for closed on proton receiver 2016-12-15 13:40:47 +00:00
Andy Taylor 3b75c95413 ARTEMIS-888 - AMQP headers arent always set
https://issues.apache.org/jira/browse/ARTEMIS-888
2016-12-15 07:07:04 +00:00
jbertram 10a32481fd ARTEMIS-789 fix ArtemisTest 2016-12-14 19:46:53 -06:00
Andy Taylor 881615e646 ARTEMIS-891 - upgrade proton to 0.16
https://issues.apache.org/jira/browse/ARTEMIS-891
2016-12-14 18:25:26 +00:00
Clebert Suconic 08e0c5e4f1 Revert "ARTEMIS-888 - AMQP headers arent always set"
This reverts commit d471f6b15f.
2016-12-14 10:20:18 -05:00
Andy Taylor d471f6b15f ARTEMIS-888 - AMQP headers arent always set
https://issues.apache.org/jira/browse/ARTEMIS-888
2016-12-14 09:25:10 -05:00
Martyn Taylor 6682072da6 Major Version Bump 2.0.0 After Major Arch Change 2016-12-09 18:43:15 +00:00
jbertram fa67d40b9d ARTEMIS-789 Fixed a number of failing tests 2016-12-09 18:43:15 +00:00
jbertram fe52ca6d75 ARTEMIS-881 Support new address-settings for auto-create queue 2016-12-09 18:43:15 +00:00
Martyn Taylor 8f532cc25d ARTEMIS-880 Add support for address prefixing 2016-12-09 18:43:15 +00:00
Andy Taylor 224f62b295 ARTEMIS-877 Add Consumer support for AMQP for new addressing schema 2016-12-09 18:43:15 +00:00
Martyn Taylor 1339c930de ARTEMIS-780 Fixes a number of broken tests 2016-12-09 18:43:15 +00:00
jbertram 84e8a87325 ARTEMIS-876 Remove all reliances on JMS prefixing 2016-12-09 18:43:15 +00:00
Clebert Suconic ebbc91c728 [maven-release-plugin] prepare for next development iteration 2016-12-06 16:59:52 -05:00
Clebert Suconic 5bcbea2517 [maven-release-plugin] prepare release 1.5.1 2016-12-06 09:47:43 -05:00
Dmitrii Tikhomirov 3995319dca ARTEMIS-865 Remove e.printStackTrace() from code 2016-11-23 11:15:54 -05:00
Andy Taylor 6628db4892 ARTEMIS-825 - Invalid selector not handled correctly in AMQP
this changes propogates the error to the client and closes the sender correctly

https://issues.apache.org/jira/browse/ARTEMIS-825
2016-11-21 11:24:51 -05:00
Andy Taylor 329c533d21 ARTEMIS-823 = broker doesn't settle rejected messages
Currently we don't settle rejected messages at the broker, we should always settle when rejected

https://issues.apache.org/jira/browse/ARTEMIS-823
2016-11-21 11:24:51 -05:00
Howard Gao 4691cbe882 ARTEMIS-842 JMSMessageID doesn't appear to work in selector 2016-11-08 09:52:12 +08:00
Ulf Lilleengen 00340c86e0 ARTEMIS-814: Support specifying connection properties 2016-11-07 15:12:14 +01:00
Clebert Suconic f2db1c4337 [maven-release-plugin] prepare for next development iteration 2016-11-03 15:35:05 -04:00
Clebert Suconic 13a8a2bd40 [maven-release-plugin] prepare release 1.5.0 2016-11-03 15:34:54 -04:00
Clebert Suconic ab7adbbd7a ARTEMIS-814 Moving ProtonClientSenderContext towards the client package
I have done it this way to be consistent to what's being documented on the package-info.java for the client package
2016-11-02 14:24:51 -04:00
Ulf Lilleengen 52a462d155 ARTEMIS-814: Refactor client connection and allow adding custom event handlers 2016-11-02 14:24:44 -04:00
Clebert Suconic 5e5ac0f057 ARTEMIS-832 Openwire was ignoring data syncs.
I'm also adding the possibility of sync on libaio, and not only relay on write-cache
2016-11-02 13:17:12 -05:00
Timothy Bish b07d6a9e75 ARTEMIS-268 Adds tests that shows issue with presettled receivers
Tests added that show that a receiver attached to a queue as presettled
are not removing the messages that are dispatched to them.
2016-11-02 14:14:35 -04:00
Clebert Suconic 2d1bdcd5bd ARTEMIS-814: Moving classes around and adding docs 2016-10-24 09:42:22 -04:00
Ulf Lilleengen e65fd5d674 ARTEMIS-814: Add support for outgoing AMQP connections 2016-10-24 09:42:22 -04:00
Ulf Lilleengen 6e5b917cc5 ARTEMIS-814: Fix a bug where context could be null in case a connection was closed before the flow arrived 2016-10-24 09:42:22 -04:00
Timothy Bish 226f28abf5 ARTEMIS-799 Fix issues with the AMQP Durable Topic Subscription model
Fixes several issues found in the handling of durable topic
subscriptions (test cases added).
2016-10-14 03:54:35 +02:00
Clebert Suconic bed3f47c85 NO-JIRA: removing non used class 2016-10-10 15:31:46 +02:00
Ville Skyttä ddd1559fbe javadoc: Fix doclint empty <p> warnings 2016-10-10 10:02:49 +02:00
Ville Skyttä 9a439b4791 javadoc: Fix doclint reference errors 2016-10-10 10:02:49 +02:00
Ville Skyttä 693e745b9c Remove redundant type arguments
Missed by sevntu-checkstyle, but not the Eclipse compiler.

https://github.com/sevntu-checkstyle/sevntu.checkstyle/issues/458
2016-10-08 10:01:45 +03:00
Timothy Bish 398da40f7d ARTEMIS-776 Attach response should only list supported filters
The broker needs to return only the filters that are supported on a
receiver attach otherwise the remote is not aware that the broker is not
able to honor the requested configuration of the receiver.
2016-10-07 17:35:27 -04:00
Timothy Bish 62627bf2ee ARTEMIS-770 AMQP Message Transformer refactor
Refactor the AMQP Message transformers both for better performance and
also to fix a number of issues with the transformers creating inbound
and outbound messages with incorrectly mapped values or extra data
appended where it should not be.
2016-10-07 10:42:52 -04:00
Martyn Taylor 95c4fdd408 ARTEMIS-762 Reflect management changes in AMQP protocol 2016-10-07 10:38:01 -04:00
Ville Skyttä 082b75bb3d More use of try-with-resources 2016-09-30 13:17:26 -04:00
Clebert Suconic ec48f9ed00 ARTEMIS-765 Improve Checkstyle 2016-09-30 11:12:09 -04:00
Andy Taylor bd9b2057fa ARTEMIS-758 - List/Object message sent by OpenWire JMS client can't be consumed with other clients
https://issues.apache.org/jira/browse/ARTEMIS-758
2016-09-29 20:28:31 -04:00
Timothy Bish 67fc49014e ARTEMIS-763 Remove the legacy Qpid JMS client annotations
Removes the append of the destination annotations from the outbound JMS
transformer as the legacy client has be unsupported at Qpid for quite
some time now.
2016-09-29 15:37:47 -04:00
Clebert Suconic a838bf0479 ARTEMIS-751 Simplification of the AMQP implementation
Since we don't need client implementations any longer, given the maturity level of
qpid jms, these classes can go, as a result a lot of the interfaces can be removed.

As part of this I am removing proton-plug, and reorganizing the packages in a way I think it
makes more sense and easier to other developers to understand and maintain it.

https://issues.apache.org/jira/browse/ARTEMIS-751
2016-09-27 09:29:40 -04:00
Clebert Suconic 113c0c9360 ARTEMIS-738 Improving TX support on AMQP
https://issues.apache.org/jira/browse/ARTEMIS-738
2016-09-21 18:14:38 -04:00
Martyn Taylor 74742dcb66 Add Unique ClientID on Server 2016-09-16 16:05:20 +01:00
Martyn Taylor dd32d6bb3e Add back autoCreate for bindingsQuery in AMQP protocol 2016-09-15 11:17:26 -04:00
Howard Gao 406d09d986 ARTEMIS-728 Broker doesn't support unique jms client-id (qpid-jms client) 2016-09-15 11:17:02 -04:00
Ville Skyttä 7bff07d5b1 Add missing @Overrides 2016-09-14 13:22:20 +03:00
Martyn Taylor afd6bb7aa6 ARTEMIS-731 properly handle AMQP recreate durable subscription queue 2016-09-13 14:10:26 -04:00
Andy Taylor cdb0391c1c ARTEMIS-723 - AMQP subscriptions aren't deleted properly
https://issues.apache.org/jira/browse/ARTEMIS-723
2016-09-12 10:27:49 +01:00
Martyn Taylor 8c7599d5e4 ARTEMIS-725 Strip internal headers on AMQP Out 2016-09-09 09:49:38 -04:00
Martyn Taylor 553f2df745 ARTEMIS-724 Implement no-local consumer filter AMQP 2016-09-09 11:07:53 +01:00
Andy Taylor 519bf674bc ARTEMIS-718 - AMQP type message bodies are being lost
https://issues.apache.org/jira/browse/ARTEMIS-718
2016-09-08 15:39:27 -04:00
Martyn Taylor db7dfba607 ARTEMIS-720 Add JMSX properties in AMQP<->JMS converter 2016-09-08 09:31:43 -04:00
Clebert Suconic 505b732843 [maven-release-plugin] prepare for next development iteration 2016-09-06 12:17:31 -04:00
Clebert Suconic b305e231ec [maven-release-plugin] prepare release 1.4.0 2016-09-06 12:17:08 -04:00
jbertram 1cf96f4fcf ARTEMIS-711 Fix handling of 'bare' header 2016-09-01 15:23:48 -04:00
Clebert Suconic 03b938468a ARTEMIS-657 Fixing JORAM AMQP Tests 2016-08-31 14:26:10 -04:00
Howard Gao 8fccd5df42 ARTEMIS-696 Broker fails when client sends messages in multiple transfer frames 2016-08-30 17:24:31 -04:00
Gordon Sim 8f188ef236 ARTEMIS-657: ensure management response bodies are encoded into amqp 2016-08-30 17:12:19 -04:00
Ville Skyttä e1728f0797 Spelling fixes 2016-08-25 14:22:32 -04:00
Ville Skyttä 30c617da3c Unnecessary @SuppressWarnings fixes 2016-08-25 14:22:32 -04:00
Clebert Suconic a3840c23c3 [maven-release-plugin] prepare for next development iteration 2016-08-16 11:59:55 -04:00
Clebert Suconic d38ef19bf6 [maven-release-plugin] prepare release 1.4.0 2016-08-16 11:59:36 -04:00
Martyn Taylor 7afd0fb028 ARTEMIS-677 Support websocket subprotocol handshakes 2016-08-10 11:07:47 -04:00
Ville Skyttä 330c65ba35 Remove unnecessary @SuppressWarnings("unchecked") 2016-08-09 11:24:22 +01:00
Howard Gao 2fb8341f8d ARTEMIS-604 - Add checks for object messages in REST and AMQP
- Rest interface fix
  - Doc fixes (Rest->REST)
  - JSON management and AMQP outbound
2016-08-09 11:22:48 +01:00
Martyn Taylor 0af13e0d03 ARTEMIS-669 Do binding query on sender link attach
QueueQuery was previously used instead of checking for bindings on a
particular address name.  This meant sending and receiving only worked
for those queues that happened to have the same queueName to address.
This patch replaces this with binding check.

There's also some minor ProtonTest fixes included.
2016-08-09 08:21:41 +01:00
Martyn Taylor 2f721866ab ARTEMIS-636 Add AMQP Hard Soft Limit for BLOCK 2016-08-05 15:29:01 +01:00
bayern39 a741642a48 [ARTEMIS-642] Disable slow client reconnecting with KILL slow client policy 2016-08-03 18:39:57 -04:00
Gordon Sim bac991215d ARTEMIS-446: use name from broker.xml as container id in AMQP open frame 2016-08-03 12:03:25 +01:00
Ville Skyttä 1bc42be7ff Access static fields and methods directly 2016-07-29 15:38:08 -04:00
Andy Taylor 85ede22c3c ARTEMIS-655 - [AMQP] On transacted session.commit() of receiver client, messages are read, but queue is not cleared out
Making sure that when a transaction state of accepted is returned we actually ack the message

https://issues.apache.org/jira/browse/ARTEMIS-655
2016-07-26 14:30:11 -04:00
Martyn Taylor 64e95b9b91 This closes #665 2016-07-26 15:14:40 +01:00
Ville Skyttä aed49b3894 Spelling fixes 2016-07-26 14:24:45 +03:00
Martyn Taylor b549bb243c Add default AMQP flow behaviour and fix proton test 2016-07-26 11:14:25 +01:00
Martyn Taylor 4d60ced581 ARTEMIS-636 Implement AMQP AddressFull BLOCK 2016-07-20 10:33:44 +01:00
Timothy Bish 688eac50ea ARTEMIS-629 Preserve the correlation ID type during conversions
When converted to a core message type the original type of the
CorrelationId in the AMQP message is lost, we must encode the type to
prevent the loss of the original type as this value is meant to be
immutable.
2016-07-14 10:08:55 +01:00
Ville Skyttä 149216e8ec Remove unnecessary null checks and assignments 2016-07-05 14:18:01 -04:00
Ville Skyttä 33a51223b0 Remove redundant type arguments 2016-06-14 20:50:21 -04:00
Martyn Taylor 9ae39f663f [maven-release-plugin] prepare for next development iteration 2016-06-09 12:52:56 +01:00
Martyn Taylor 221039e353 [maven-release-plugin] prepare release 1.3.0 2016-06-09 12:49:13 +01:00
Martyn Taylor 319439ab27 [maven-release-plugin] prepare for next development iteration 2016-06-09 12:25:19 +01:00