101 Commits

Author SHA1 Message Date
Martyn Taylor
74742dcb66 Add Unique ClientID on Server 2016-09-16 16:05:20 +01: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
553f2df745 ARTEMIS-724 Implement no-local consumer filter AMQP 2016-09-09 11:07:53 +01:00
Timothy Bish
42ff4a6048 ARTEMIS-722 Add DELAYED_DELIVERY capability to server connection open
The server should indicate to clients that it supports the message
annotation that allows message delivery to be delayed
'x-opt-delivery-time'
2016-09-08 19:01:40 -04:00
Martyn Taylor
b788ffac22 ARTEMIS-719 Send ampq:not-found properly on remote open 2016-09-08 09:27:36 -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
Martyn Taylor
930d814daf ARTEMIS-701 Set Accepted on AMQP discharge 2016-09-06 09:36:50 -04:00
Clebert Suconic
739ce8a53a ARTEMIS-711 fixing tests 2016-09-02 10:00:00 -04:00
jbertram
1cf96f4fcf ARTEMIS-711 Fix handling of 'bare' header 2016-09-01 15:23:48 -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
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
Gordon Sim
7a012008b7 ARTEMIS-447: add name and version to properties in amqp open frame 2016-08-10 08:56:44 -04: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
Martyn Taylor
06fb4a1234 ARTEMIS-667 Make AMQP Exceptions extend ActiveMQException 2016-08-05 15:29:01 +01:00
Martyn Taylor
ab39e70dc9 ARTEMIS-666 Fix AMQP error message on address not found 2016-08-03 13:28:34 +01: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
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
Martyn Taylor
5dfa1c59fb ARTEMIS-638 Only allocate credits once Link Attach 2016-07-20 10:33:44 +01:00
Timothy Bish
75f18d1e10 ARTEMIS-585 support send on dynamic sender link
The sender abstraction must be able to update its sender address in the
case of dynamic senders whose target address is not set until the code
initializes the link and creates a destination for it.
2016-06-21 09:33:33 -04:00
Martyn Taylor
432e2ce178 ARTEMIS-570 Fix buffer size overflow ProtonHandler
There is a race condition in the ProtonHandlerImpl.outputBuffer()
method.  The method checks to see how many bytes (n) are pending in the
underlying ProtonJ buffer, then creates a Netty buffer of size n.  It
then writes the contents of the pending ProtonJ head.  However, ProtonJ
can still write to it's internal buffer, meaning that it's buffer.size >
n causing an illegalArgumentException.  This patch fixes it by only
writing 'n' bytes to the Netty buffer.
2016-06-17 15:04:32 -04:00
Ville Skyttä
3923ae45f4 Fix checkstyle redundant modifier violations 2016-06-13 20:03:54 +03:00
Clebert Suconic
feaea9fb91 proton logging and tracing (first part) 2016-06-10 13:33:26 -05: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
Martyn Taylor
2c5ab446be [maven-release-plugin] prepare release 1.3.0 2016-06-09 12:24:48 +01:00
Martyn Taylor
4a07091718 [maven-release-plugin] prepare for next development iteration 2016-06-09 11:25:03 +01:00
Martyn Taylor
93cf7b4b9b [maven-release-plugin] prepare release 1.3.0 2016-06-09 11:23:03 +01:00
Martyn Taylor
4574b3ee13 [maven-release-plugin] prepare for next development iteration 2016-06-08 11:03:35 +01:00
Martyn Taylor
2b3d22c5cc [maven-release-plugin] prepare release 1.3.0 2016-06-08 11:02:14 +01:00
Clebert Suconic
10dfe97ec0 Adding JORAM Tests for AMQP with a few fixes around the protocol manager for JMS 2016-05-25 09:41:40 -04:00
Andy Taylor
73f908b8b4 ARTEMIS-535 - Improve amqp protocol to support topics
https://issues.apache.org/jira/browse/ARTEMIS-535
2016-05-24 13:26:24 +01:00
Martyn Taylor
54752a9ced ARTEMIS-46 Adds AMQP Drain Support 2016-05-11 12:04:58 +01:00
Erich Duda
a622fa7443 ARTEMIS-518 - Improvement of default thread factory 2016-05-09 14:33:41 -04:00
Howard Gao
fcda12f92c ARTEMIS-214 exception when sending 10k message 2016-04-26 10:04:24 -04:00
Andy Taylor
76d937fab3 ARTEMIS-500 - possible index out of bounds after amqp sasl handshake
https://issues.apache.org/jira/browse/ARTEMIS-500
2016-04-25 14:13:30 +01:00
Andy Taylor
f47bb6cc4b ARTEMIS-494 - implement filters correctly
took this code from ActiveMQ which was over hawled in this area

https://issues.apache.org/jira/browse/ARTEMIS-494
2016-04-20 12:14:04 +01:00
Andy Taylor
97f3fb241c ARTEMIS-493 - NullPointerException when trying a null connection remote properties are passed by client
adde a check and fixed a couple of other potential NPE's

https://issues.apache.org/jira/browse/ARTEMIS-493
2016-04-19 11:21:33 +01:00
Ville Skyttä
3dc3e8520d Remove redundant toString calls 2016-04-11 16:54:30 -04:00
Ville Skyttä
16ee65309c Add missing @Override annotations 2016-04-04 11:03:48 -05:00