Commit Graph

288 Commits

Author SHA1 Message Date
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
Martyn Taylor 64e95b9b91 This closes #665 2016-07-26 15:14:40 +01:00
Martyn Taylor 69294e83e1 Add management filter to Queue not Consumer MQTT 2016-07-26 12:32:38 +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
jbertram 778bd8361a ARTEMIS-650 clarify doc, use TTL default for 0 heartbeat 2016-07-25 16:27:30 +01:00
jbertram c4a7ddf9d6 ARTEMIS-548 Stomp durable sub unsubscrbe
Implement ability for Stomp clients to unsubscribe durable
subscriptions.
2016-07-25 16:23:06 +01:00
Martyn Taylor e341b54c49 ARTEMIS-641 filter out management notifications in MQTT 2016-07-21 14:47:20 -05:00
Martyn Taylor fe0cb648d6 ARTEMIS-335 Remove dead code from MQTTPublishManager 2016-07-21 14:47:20 -05:00
jbertram 7d8f9dcec6 ARTEMIS-611 send ERROR in case of TTL violation
I changed the message for TTL timeouts because the existing message was
a bit verbose and a bit speculative. Also, now that the broker supports
more protocols the bit about connection-ttl and
client-failure-check-period is less relevant.
2016-07-20 15:54:29 -05:00
jbertram 4232ed70d4 ARTEMIS-611 adjust ttlMin to fix Stomp tests 2016-07-20 15:54:29 -05:00
jbertram 707b51796a ARTEMIS-611 fix logging 2016-07-20 15:54:28 -05:00
jbertram b466cce593 ARTEMIS-234 fix content-length for Stomp 1.0 2016-07-20 13:40:57 +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
jbertram 89e0c461e5 ARTEMIS-611 refactor STOMP cxn TTL + heart-beat
Adds 3 new URI properties for STOMP acceptors to allow finer grained
configuration of heart-beat / connection-TTL behavior.
2016-07-18 17:10:05 -05: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
jbertram 6881c1ddc3 ARTEMIS-578 cert authn/z for STOMP 2016-07-06 10:54:19 -05:00
jbertram 765b225924 ARTEMIS-584 add validated user to msg
Implements a new feature to aid in security auditing by adding the name
of the validated user to the messages it sends.
2016-07-06 09:37:29 -05:00
John D. Ament 7c746c719e ARTEMIS-607 Added interceptor support for MQTT protocol.
Also updated the maintainer's guide to clarify what is run in the PR builder.
2016-07-05 19:43:00 -04:00
Ville Skyttä 149216e8ec Remove unnecessary null checks and assignments 2016-07-05 14:18:01 -04: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
jbertram eb785b4194 ARTEMIS-409 clarify STOMP login failure response 2016-06-17 17:16:51 -05: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
Howard Gao 109ce6ded9 ARTEMIS-571 Fix issues in openwire testsuite
* Redelivery count fix
* Regression in BrokerTest
2016-06-17 14:58:54 -04:00
Ville Skyttä 33a51223b0 Remove redundant type arguments 2016-06-14 20:50:21 -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
jbertram e53649a6b9 ARTEMIS-322 auto-create/delete JMS topic
Implements a new feature for the broker whereby it may automatically create and
delete JMS topics which are not explicitly defined through the management API
or file-based configuration. A JMS topic is created in response to a sent
message or connected subscriber. The topic may subsequently be deleted when it
no longer has any subscribers. Auto-creation and auto-deletion can both be
turned on/off via address-setting.
2016-06-06 16:00:57 -04:00
Martyn Taylor e453aae5c9 ARTEMIS-233 Convert TextMessage to UTF8 in MQTT 2016-05-25 15:37:20 -04:00
Martyn Taylor 0d8a565836 Artemis-233 Support JMS BytesMessage -> MQTT 2016-05-25 17:59:00 +01:00
Martyn Taylor 3c7c2ed5d3 ARTEMIS-233 Remove MQTT Address PreFix for cross protocol support 2016-05-25 17:59:00 +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
jbertram e8d0639d05 ARTEMIS-536 fix checkstyle 2016-05-24 15:37:53 -05:00
Martyn Taylor d4038ec59a ARTEMIS-536 Fix AMQP List/Sequence decoding 2016-05-24 12:07:07 -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
jbertram 2c923cec97 ARTEMIS-523 re-order SASL mechs 2016-05-18 13:49:12 -04:00
jbertram b9b4107020 ARTEMIS-522 fix AMQP ANON advert 2016-05-17 12:34:10 -04:00
Ville Skyttä 81956e1716 Use StandardCharsets more 2016-05-16 12:09:46 -04: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
Andy Taylor c161ab46a6 ARTEMIS-503 - replace proton-jms with proton-jms from ActiveMQ
Ive copied over the source itself

https://issues.apache.org/jira/browse/ARTEMIS-503
2016-05-03 10:40:56 -04:00
Diego Bes 75a4e78948 Change keep alive ratio to 1.5 from 0.75
Fixes: ARTEMIS-397

From mqtt specs:

“If the Keep Alive value is non-zero and the Server does not receive a
Control Packet from the Client within one and a half times the Keep
Alive time period, it MUST disconnect the Network Connection to the
Client as if the network had failed [MQTT-3.1.2-24]. “
2016-05-03 14:14:34 +01:00
Howard Gao ada6600ee3 ARTEMIS-505 Fix OptimizedAckTest and testCloseConsumer
OptimizedAckTest: Using core api to replace old activemq
broker API to checking message count.
JmsQueueTransactionTest#testCloseConsumer: a bug in
delivery when prefetchSize is 0.
(InitalReconnectDelayTest)close connection after test.
2016-04-27 10:06:14 -04:00
Andy Taylor 1530ea3032 re-adding code accidently removed 2016-04-27 07:26:55 +01:00
Howard Gao fcda12f92c ARTEMIS-214 exception when sending 10k message 2016-04-26 10:04:24 -04:00
Andy Taylor 60df3dc05f ARTEMIS-503 - replace proton-jms with proton-jms from ActiveMQ
some extra fixes needed

https://issues.apache.org/jira/browse/ARTEMIS-503
2016-04-26 14:02:53 +01:00
Andy Taylor 9a17681f83 ARTEMIS-503 - replace proton-jms with proton-jms from ActiveMQ
https://issues.apache.org/jira/browse/ARTEMIS-503
2016-04-25 14:13:30 +01: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
Clebert Suconic 172de47ce0 Created queue should be durable on openwire 2016-04-21 10:44:50 -04:00
Clebert Suconic 31055b6f0a Removing Marshalled property from Openwire 2016-04-20 23:00:57 -04:00
Howard Gao 3012447404 ARTEMIS-488 Fix OpenWire Test (Temp Queue removal and others)
Temp Queue not deleted when connection is closed.
Enable Stomp in openwire test because some test uses it.
Remove unused code in opwnwire
Wrong XA error code returned when xid is missing
(ActiveMQXAConnectionFactory.testRollbackXaErrorCode)
regression in ActiveMQSslConnectionFactoryTest (SSL related)
2016-04-20 12:33:01 -04: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
Andy Taylor 8a72f8906a ARTEMIS-453 - AMQP reply-to property is stripped off message as it goes through broker
TheJMSVendor protocol convertor class was not creating the destinations so any destination calls, setTo and setJMSReplyTo, were ignored. Ive added a server side destination class to bypass the naming checks we have on the client and this now sets everything correctly

https://issues.apache.org/jira/browse/ARTEMIS-453
2016-04-12 10:24:13 +01:00
Ville Skyttä 3dc3e8520d Remove redundant toString calls 2016-04-11 16:54:30 -04:00
Ville Skyttä e6e1311f8d Add missing @Overrides 2016-04-11 16:51:01 -04: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
Clebert Suconic 91bdeb3728 ARTEMIS-464 Sending null textMessage shouldn't break the wire 2016-04-04 11:08:43 -05:00
Clebert Suconic 3560415bcb ARTEMIS-463 Using OperationContext for async support 2016-04-04 11:08:43 -05: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