174 Commits

Author SHA1 Message Date
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
Ville Skyttä
16ee65309c Add missing @Override annotations 2016-04-04 11:03:48 -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
Ville Skyttä
7c275cdb1a Use generics more 2016-02-28 01:06:59 +02:00
Ville Skyttä
aa3f3bd6a7 Use try-with-resources more 2016-02-21 12:09:43 +02:00
Clebert Suconic
02afdbbb12 Upgrade proton to 0.12 2016-02-18 10:14:26 -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
gautric
3986f0a517 Add Name tag for several POM files 2016-02-16 11:56:01 -05:00
Andy Taylor
7702a0a1f9 ARTEMIS-398 - AMQP protocol idle timeout issue
added functionality to tick every n seconds where n is 1/2 the idle timeout

https://issues.apache.org/jira/browse/ARTEMIS-398
2016-02-16 11:24:09 +00:00
Clebert Suconic
e62a820414 Fixing ServerMessage's copy and MQTT delivery 2016-01-27 17:12:56 -05:00
Ville Skyttä
51f125387b Add "persistent" header to outbound STOMP messages 2016-01-27 13:20:55 -05:00
Ville Skyttä
bdea213e88 Rename Stomp.Headers.Message.PRORITY to .PRIORITY 2016-01-27 13:20:55 -05:00
Ville Skyttä
2c4312d4f2 Disconnect on STOMP 1.2 errors
https://stomp.github.io/stomp-specification-1.2.html#ERROR
2016-01-25 21:33:28 -05:00
jbertram
ddc95a0f28 ARTEMIS-358 topic mistakenly removed with sub
The problem here is that the management notification listener was mistakenly
removing the topic itself instead of just the non-durable subscription. In
general I can't see why StompProtocolManager even needs to keep track of the
destinations when the broker already does that. As far as I can tell it is
redundant and it's clearly error-prone. Therefore I'm removing the destination
tracking from StompProtocolManager altogether.
2016-01-25 21:04:00 -05:00
Martyn Taylor
4922a7618a Bump to next version to 1.3.0-SNAPSHOT 2016-01-20 17:25:07 +00:00