Martyn Taylor
fec6546480
[maven-release-plugin] prepare for next development iteration
2015-09-08 16:39:59 +01:00
Martyn Taylor
4d0b15b043
[maven-release-plugin] prepare release 1.1.0
2015-09-08 16:29:09 +01:00
Martyn Taylor
82f6a88d59
[maven-release-plugin] prepare for next development iteration
2015-09-07 10:02:01 +01:00
Martyn Taylor
8c1e0e15fc
[maven-release-plugin] prepare release 1.1.0
2015-09-07 10:01:10 +01:00
Howard Gao
e3a1e8abd6
Fix ReconnectWithSameClientIDTest
2015-09-07 15:05:33 +08:00
Martyn Taylor
a2aa18c123
[maven-release-plugin] prepare for next development iteration
2015-09-04 20:20:13 +01:00
Martyn Taylor
a5decb659e
[maven-release-plugin] prepare release 1.1.0
2015-09-04 20:19:11 +01:00
Martyn Taylor
4576ccea08
[maven-release-plugin] prepare for next development iteration
2015-09-04 19:48:52 +01:00
Clebert Suconic
cc9cacef14
fixing openwire tests
...
I removed some valid code while removing dead code.
2015-08-31 08:14:25 -04:00
Howard Gao
638674bce0
Minor refactor of OpenWireProtocolManager
...
In addDestination() put the security check right before
actual queue creation. That'll also fix BasicSecurityTest
regression.
2015-08-31 10:37:28 +08:00
Clebert Suconic
9cf4c18ea5
removing more dead code on openwire
...
(classes without any implementation detail, no code usage or duplicate meaning)
2015-08-28 19:33:35 -04:00
Clebert Suconic
343ed61e14
removing more dead code on openwire
2015-08-28 17:10:24 -04:00
Clebert Suconic
e850e1351d
Removing dead code - AMQSEcurityContext
2015-08-28 15:05:44 -04:00
Clebert Suconic
738b15d0ae
Removing deadcode on openwire AMQSubscription
2015-08-28 15:05:44 -04:00
Clebert Suconic
ebb91edd42
Removing dead code on openwire - DestinationStatistics & AuthorizationPolicy
2015-08-28 15:05:43 -04:00
Clebert Suconic
5f16adde43
removing dead code on openwire - AMQPersistenceAdapter & AMQMessageStore
2015-08-28 15:05:43 -04:00
Clebert Suconic
8927456d21
removing dead code - NotenoughBytesException
2015-08-28 15:05:42 -04:00
Clebert Suconic
12de35892a
Removing dead code - AMQPBrokerStoppedException
2015-08-28 15:05:42 -04:00
Clebert Suconic
04ca86c3dd
removing more dead code on openwire implementation
2015-08-28 15:05:41 -04:00
Clebert Suconic
3fbf75b2ff
removing dead code on openwire implementation
2015-08-28 15:05:41 -04:00
Clebert Suconic
8d98fc395f
Refactoring Auth
...
this is doing some refactoring, making the SecurityStore mechnism possible to be reused on other protocols,
without forcing them to implement ServerSession on checks that won't fit the Server Model from Artemis
2015-08-28 15:04:59 -04:00
Howard Gao
be9959e0bc
ARTEMIS-191 Refactor RemoveDestinationTest
...
-Using core api to inspect queue status
-Catch command visit() exceptions in order to
pass it back to client.
-Correct destination add/remove handlings
2015-08-28 20:33:38 +08:00
Andy Taylor
2f18b4cbfc
ARTEMIS-193 - OpenWire protocol only works with messages received over openwire
...
Fix the address conversion between protocols so its consistent
https://issues.apache.org/jira/browse/ARTEMIS-193
2015-08-27 10:23:38 +01:00
Clebert Suconic
4b79ddb0bd
ARTEMIS-209 fix keepAlive
...
- Received should be set to true on any package
2015-08-25 18:56:14 -04:00
Clebert Suconic
8935483cdd
ARTEMIS-208 fixing BrokerInfo, using OpenWire connection instead of static property on the protocolManager
2015-08-24 22:54:59 -04:00
Howard Gao
34e127cc0c
ARTEMIS-208 BrokerInfo issue, also:
...
enlarged the default max size for tests to avoid send blocking.
2015-08-24 22:54:12 -04:00
jbertram
976174305e
ARTEMIS-209 fix keepAlive
2015-08-14 16:20:10 -05:00
Clebert Suconic
27b98a2514
performance tests on openwire
2015-08-14 15:39:27 -04:00
Clebert Suconic
1dae99746b
ARTEMIS-204 Improvements on OpenWire
...
https://issues.apache.org/jira/browse/ARTEMIS-204
by consequence this will also fix any possible issues with AMQP
2015-08-13 20:39:01 -04:00
Clebert Suconic
5ac2c2444b
manual checkstyle changes
2015-08-10 10:08:23 -04:00
Clebert Suconic
bac96047f5
automatic checkstyle change
...
this is just calling Idea format on all the files using the new style
I am separating manual changes from automatic changes in case I have to repeat the manual changes again
2015-08-10 09:26:42 -04:00
Andy Taylor
81756739bb
ARTEMIS-186, ARTEMIS-188 and some refactoring
...
refactoring and simplifying some of the connection state code and removing stuff we dont need. Also removed some of maps used and removed the need for lots of lookups
https://issues.apache.org/jira/browse/ARTEMIS-186
Added message pull support for zero prefetch consumers
https://issues.apache.org/jira/browse/ARTEMIS-188
Added consumer flow control
2015-08-06 09:49:46 +01:00
Howard Gao
65e9ec01b8
Fix openwire unit tests
...
Fix JmsRedeliveredTest and add processing of RemoveSubscriptionInfo command
2015-08-03 08:56:27 -04:00
Clebert Suconic
6fe9e0ebd6
ARTEMIS-163 First pass on the native AIO refactoring
...
https://issues.apache.org/jira/browse/ARTEMIS-163
On this pass I'm just converting the native layer to a simpler one.
It wasn't very easy to change the alignment at the current framework,
so I did some refactoring simplifying the native layer
The volume of the nubmer of changes here is because:
- The API is changed, we now don't close the libaio queue between files
- The native layer won't use malloc as much as it used to, saving some CPU and memory defragmentation
- I organized the code around nio and libaio
2015-07-29 22:12:03 -04:00
Andy Taylor
abcde1c1f3
added Openwire XA end call
2015-07-28 09:50:29 -04:00
Clebert Suconic
d002da8506
mqtt improvement over retained queue
2015-07-27 10:32:20 -04:00
Ville Skyttä
2a647c176f
Declare ConcurrentMaps instead of ConcurrentHashMaps
...
See PR #88 for discussion.
2015-07-22 16:16:57 +03:00
Ville Skyttä
45d1601334
Make some STOMP fields final
2015-07-22 11:48:42 +01:00
Clebert Suconic
5c4511b59f
Using ConcurrentMap instead on MQTTSessionState"
2015-07-22 11:44:03 +01:00
Ville Skyttä
0dcad8fc59
Fix MQTT build
...
putIfAbsent() is a ConcurrentHashMap method.
2015-07-21 22:18:49 +01:00
Ville Skyttä
214a1dc1eb
Use StringBuilder instead of StringBuffer on STOMP encode
2015-07-21 19:11:07 +03:00
Ville Skyttä
615a9881b5
Use base implementation for STOMP 1.1+ toActiveMQBuffer
2015-07-21 19:06:40 +03:00
Ville Skyttä
0b3a64c5e8
Auto-set content-length to STOMP 1.0 frames
...
As recommended by the 1.0 spec.
2015-07-21 19:04:08 +03:00
Clebert Suconic
8353bd1f77
reapplying Don't auto-send STOMP content-length header if one was explicitly set
...
I reverted this change by accident
2015-07-21 13:59:38 +01:00
Clebert Suconic
dcd6033e02
fixing Stomp::testSendWithHeartBeats
2015-07-21 02:46:45 +01:00
Ville Skyttä
642838c712
Don't auto-send STOMP content-length header if one was explicitly set
2015-07-20 15:09:07 +01:00
Ville Skyttä
8a90de6fbc
Avoid some array copies on STOMP decode
2015-07-20 14:57:17 +01:00
Ville Skyttä
b38236df82
Set content-type to STOMP ERROR frames
...
Not setting it to directly instantiated 1.0 frames though, as
content-type is not in the 1.0 spec. However the 1.0 spec does not
actually forbid headers outside of the spec so it shouldn't hurt if we
end up setting it for some frames sent over a 1.0 connection.
2015-07-14 09:54:40 -04:00
Ville Skyttä
6ee22e7c5e
Set frame handlers to ActiveMQStompExceptions
2015-07-14 09:53:36 -04:00
Ville Skyttä
3deb20f049
Create versioned instead of generic frames from STOMP decoder
2015-07-14 09:53:35 -04:00