259 Commits

Author SHA1 Message Date
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ä
2c7c81ca9e STOMP frame encode: Use fixed buffers 2016-09-14 20:54:28 +03:00
Ville Skyttä
8e59cf4d5f STOMP frame encode: Avoid StringBuilder resizing 2016-09-14 20:54:23 +03: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
Clebert Suconic
46d3f4abcc Version upgrades 2016-09-09 14:49:33 -04: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
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
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
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
Clebert Suconic
4472aa0e36 ARTEMIS-581 Implement max disk usage, and global-max-size
max-disk-usage = how much of a disk we can use before the system blocks
global-max-size = how much bytes we can take from memory for messages before we start enter into the configured page mode

This will also change the default created configuration into page-mode as that's more reliable for systems.
2016-09-06 15:07:49 +01:00
Martyn Taylor
930d814daf ARTEMIS-701 Set Accepted on AMQP discharge 2016-09-06 09:36:50 -04:00
Howard Gao
61747acfd1 ARTEMIS-706 No Keep Alives from Broker 2016-09-02 21:39:44 -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
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ä
d5242978d5 for and while loop to foreach conversions 2016-08-25 14:22:32 -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
Gordon Sim
7a012008b7 ARTEMIS-447: add name and version to properties in amqp open frame 2016-08-10 08:56:44 -04:00
Ville Skyttä
330c65ba35 Remove unnecessary @SuppressWarnings("unchecked") 2016-08-09 11:24:22 +01:00
Clebert Suconic
579d6226aa ARTEMIS-671 Returning messages after connection killed, and validating usage of reconnect 2016-08-09 11:23:46 +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
Martyn Taylor
06fb4a1234 ARTEMIS-667 Make AMQP Exceptions extend ActiveMQException 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
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
jbertram
df193060e6 Fix ExtraStompTest 2016-08-02 21:01:14 -04:00
Ville Skyttä
1bc42be7ff Access static fields and methods directly 2016-07-29 15:38:08 -04:00
Ville Skyttä
9022a311f3 Fix removing ended transaction id in OpenWireConnection.CommandProcessor 2016-07-29 15:35:25 -04:00
Ville Skyttä
7ce2d7c199 Fix adding duplicate detection id in Openwire AMQSession.send 2016-07-29 15:35:25 -04:00
Ville Skyttä
c890164fda Use try-with-resources some more 2016-07-29 15:32:57 -04:00
Ville Skyttä
616c038dae Fix connection list cleanup in OpenWireProtocolManager.removeConnection 2016-07-29 15:27:55 -04:00
Ville Skyttä
9963f96033 Fix NPE with null session in MQTTConnectionManager.disconnect() 2016-07-28 23:30:02 +03:00
Ville Skyttä
72bf5b7a0a ARTEMIS-611 Remove redundant null check 2016-07-28 15:25:45 -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