Timothy Bish
d2731fa0e1
ARTEMIS-1110 Cleanup Transaction Coordinator buffer handling
...
Resuse a single small buffer for all txn commands (declare / dischare) to
avoid creating lots of small arrays and ByteBuffer wrappers for txn operations.
2017-04-11 11:33:58 -04:00
Timothy Bish
3b45261f19
ARTEMIS-1101 Read the correct values for timestamp and user-id
...
Fix the getUserID and getTimestamp methods in AMQPMessage to read and
return the correct values. Adds some tests to cover these cases and
cleans up some others.
2017-04-07 16:12:58 -04:00
Clebert Suconic
01362bbb1d
ARTEMIS-1100 Store Header on AMQP message
2017-04-07 09:11:11 -05:00
Timothy Bish
45c59f05dc
ARTEMIS-1097 Respect the message priority value in the AMQP message
...
Ensure that the header value for priority is read and returned in a form
that is scaled such that it won't cause an IndexOutOfBoundsException
from the QueueImpl priority array. Adds some additional testing for
message priority support.
2017-04-06 16:18:53 -04:00
Justin Bertram
073a280629
ARTEMIS-1092 Validated user + AMQP fix
...
When populate-validated-user = true AMQP messages can cause exceptions.
This feature isn't particularly applicable to AMQP so this commit
eliminates the exception and leaves the AMQP messages untouched
even if populate-validated-user = true. In other words,
populate-validated-user + AMQP is not supported.
2017-04-04 14:46:22 -05:00
Andy Taylor
5529bf150a
ARTEMIS-1090 - Message not expired if absolute expiry time is 0 and ttl is set
...
https://issues.apache.org/jira/browse/ARTEMIS-1090
2017-04-03 14:28:02 +01:00
Clebert Suconic
d779afe874
NO-JIRA: Fixing test hunging on OpenWire
2017-03-30 21:56:46 -04:00
Timothy Bish
62cb9b22de
ARTEMIS-1086 Proper conversion of SimpleString to String
...
When adding boolean value keyed by SimpleString the key needs to be
converted to a String type to be valid AMQP.
2017-03-30 21:19:43 -04:00
Clebert Suconic
86779195fa
NO-JIRA: Removing duplciate code
2017-03-30 11:15:09 -04:00
Clebert Suconic
9bef242b74
ARTEMIS-1056 Adjusting Acceptor values
...
I have been doing tests with quiver at large message sizes
the tests would work really slowly without these fixes
2017-03-30 09:54:26 +01:00
Martyn Taylor
955af96fe9
ARTEMIS-1082 Catch Create Queue race in OpenWire
2017-03-29 13:49:01 +01:00
Clebert Suconic
1f4473e8d7
ARTEMIS-1081 Implementing AMQP UndeliverableHere
2017-03-28 20:32:28 -05:00
Clebert Suconic
746220e11e
ARTEMIS-1080 Implementing AMQP::reject
2017-03-28 20:32:28 -05:00
Clebert Suconic
13a272b37b
ARTEMIS-1056 fixing tests
...
When I added flow control, some tests that were using reflection started to fail.
Also as a precaution I'm using <= on the flow control low credit check
2017-03-28 20:32:28 -05:00
Clebert Suconic
7f91d29564
ARTEMIS-1056 Improving Proton usage
2017-03-28 14:48:25 -04:00
Clebert Suconic
b395504e15
ARTEMIS-1077 Fixing Pool usage on InVM and RemotingConnection
2017-03-28 09:19:57 -05:00
Clebert Suconic
dce59d5436
ARTEMIS-1056 Better event processing
2017-03-27 22:01:36 -05:00
Clebert Suconic
dc25ff0e42
ARTEMIS-1073 Adding configuration for Producer's credits on AMQP
2017-03-27 16:27:24 -04:00
Justin Bertram
c792b8e274
ARTEMIS-1068 JMS + AMQP routing
2017-03-27 15:14:43 -04:00
Clebert Suconic
af0be518e1
ARTEMIS-1069 Artemis unsafe usage on Eventls polling
2017-03-27 11:41:20 -04:00
Timothy Bish
40b9ac0a20
ARTEMIS-1069 Fix some thread unsafe usages of proton
...
Unsafe modification of proton resources outside the connection lock
could lead to corruption in the transport work list and other internal
state data.
2017-03-24 17:46:00 -04:00
Justin Bertram
427039ef38
ARTEMIS-1068 routingType + AMQP fixes
2017-03-24 15:15:10 -05:00
Martyn Taylor
e33b7af5ac
ARTEMIS-1061 Ack MQTT PubRel management messages
2017-03-22 23:26:32 -04:00
Clebert Suconic
0bfb39bfb5
ARTEMIS-1056 Performance improvements on AMQP
2017-03-22 09:55:02 -05:00
Francesco Nigro
ed3de61587
ARTEMIS-1055 Broker generates warning when a client tries to connect it
2017-03-22 11:39:11 +00:00
Clebert Suconic
64b4553284
ARTEMIS-1052 Fixing MessageJournalTest::testStoreAMQP
2017-03-20 21:50:57 -04:00
Clebert Suconic
65ac7f700b
ARTEMIS-1052 Proper Expiry over AMQP
2017-03-20 18:33:31 -04:00
Timothy Bish
29796151c3
ARTEMIS-59 Accept transacted message using AMQP TransactionState
...
When a message is sent to the broker with a TransactionState indicating
that the message should be included in a transaction the disposition from
the broker indicating acceptance of the message should be done using a
TransactionState value that contained the TX ID and the Accepted
disposition.
2017-03-20 12:42:56 -04:00
Martyn Taylor
7cf06cd285
ARTEMIS-1050 Register AMQP failure/close listeners
2017-03-19 14:15:30 +00:00
Clebert Suconic
4b50d6c431
ARTEMIS-1048 Fixing Unsigned types and Selectors
2017-03-17 18:05:21 -04:00
Clebert Suconic
1ef4dcf7d9
ARTEMIS-1046 Fixing TX eventually stalling with AMQP
...
I have also reviewed the model in which we used transactions
2017-03-17 16:50:56 -04:00
Clebert Suconic
291a4719b6
ARTEMIS-1045 Performance improvements on AMQP
2017-03-17 16:11:14 -04:00
Andy Taylor
c6f73b0c0a
ARTEMIS-1042 - support amqp failover list
...
https://issues.apache.org/jira/browse/ARTEMIS-1042
2017-03-17 15:08:58 -04:00
Andy Taylor
8ab7588910
ARTEMIS-1023 - fixx Openwire auto creation of queues
...
https://issues.apache.org/jira/browse/ARTEMIS-1023
2017-03-17 12:28:10 +00:00
Clebert Suconic
a4beb18a6e
ARTEMIS-1044 Avoiding StackOverflow on AMQP under load
2017-03-16 18:11:57 -04:00
Clebert Suconic
31639782f0
ARTEMIS-1041 Adjusting when hearders are being parsed
2017-03-15 19:27:59 -04:00
Timothy Bish
938c4ec558
ARTEMIS-1041 Apply absolute expiration time to message
...
Use the Absolute Expiration Time from the message properties and
override any value set in TTL if anything set there.
2017-03-15 19:25:08 -04:00
Clebert Suconic
ae34b01065
ARTEMIS-1038 Make usage of Delivery.available and upgrade proton
2017-03-15 14:37:41 -04:00
Timothy Bish
7282b6890a
ARTEMIS-1039 Transaction Coordinator credit refill
...
The coordinator needs to refill credit on the receiver once it has been
exhausted, otherwise the remote cannot send additional declare or
discharge commands to the broker.
2017-03-14 17:13:05 -04:00
Andy Taylor
b5b6e4bea6
ARTEMIS-1034 - non-durable subscription queue not ended on link close
...
https://issues.apache.org/jira/browse/ARTEMIS-1034
2017-03-13 10:33:13 -05:00
Martyn Taylor
c40823e5ec
[maven-release-plugin] prepare for next development iteration
2017-03-10 14:54:33 +00:00
Martyn Taylor
70e319d6e3
[maven-release-plugin] prepare release 2.0.0
2017-03-10 14:52:26 +00:00
Martyn Taylor
f1a5f1caf9
Revert "[maven-release-plugin] prepare release 2.0.0"
...
This reverts commit 057047499b
.
2017-03-10 14:45:29 +00:00
Martyn Taylor
1964abe567
Revert "[maven-release-plugin] prepare for next development iteration"
...
This reverts commit 9a52f51c9f
.
2017-03-10 14:44:58 +00:00
Martyn Taylor
9a52f51c9f
[maven-release-plugin] prepare for next development iteration
2017-03-10 11:36:36 +00:00
Martyn Taylor
057047499b
[maven-release-plugin] prepare release 2.0.0
2017-03-10 11:25:47 +00:00
Martyn Taylor
b33fea0d7f
ARTEMIS-990 Dont require Perms on MQTT mngment Q
2017-03-10 11:06:05 +00:00
Clebert Suconic
a41a1930ef
ARTEMIS-1009 AMQP shouldn't use application properties
...
As part of my refactoring on AMQP, the broker shouldn't rely on Application properties
for any broker semantic changes on delivery.
I am removing any access to those now, so we can properly deal with this post 2.0.0.
2017-03-09 12:27:39 -05:00
Clebert Suconic
c369084381
ARTEMIS-1009 Tight up on AMQP
...
avoiding application properties even further
fixing nolocal
2017-03-09 08:12:42 -06:00
Clebert Suconic
ce77d12b87
ARTEMIS-1009 fixing ProtonTest::testFilterJMSMessageID
2017-03-07 09:29:04 -05:00
Martyn Taylor
456e2a65e2
ARTEMIS-1012 Fix AMQP Transaction Retirement
2017-03-06 11:55:29 -05:00
Martyn Taylor
543dd4c9e3
ARTEMIS-1013 Queue deliver after AMQP msg release
2017-03-06 11:55:29 -05:00
Clebert Suconic
fe0ca4d84f
ARTEMIS-1009 Pure Message Encoding.
...
with this we could send and receive message in their raw format,
without requiring conversions to Core.
- MessageImpl and ServerMessage are removed as part of this
- AMQPMessage and CoreMessage will have the specialized message format for each protocol
- The protocol manager is now responsible to send the message
- The message will provide an encoder for journal and paging
2017-03-05 23:08:53 -05:00
Howard Gao
216f31765f
ARTEMIS-1000 Openwire exception response no correlation-id
...
When openwire sends back an exception response, it doesn't set
the correct correlation id. This causes the client to miss the
response and the exception won't get caught.
To fix it we need to add the correlation id before sending.
2017-02-26 22:25:10 -05:00
Justin Bertram
01465035c0
ARTEMIS-970 handle indeterminate JMS destination
2017-02-23 12:55:27 -05:00
Howard Gao
2fabd059d8
ARTEMIS-981 OpenWire can't receive empty ObjectMessage
...
When sending an empty ObjectMessage, broker doesn't
write a 'length' field to the message buffer. In delivery
the broker tries to read the length from the buffer, which
causes "IndexOutOfBoundsException".
To fix it, we need to check if the buffer is empty or not,
and only read it if the buffer is not empty.
2017-02-22 12:59:52 +08:00
Justin Bertram
b7d7d134eb
NO-JIRA fix possible STOMP NPE
2017-02-21 22:22:12 -05:00
Howard Gao
b84a7f3e25
ARTEMIS-980 Openwire can't send message to temp destination
...
When a producer sends a messages to a temp destination created from
another connection, it fails. The reason behind it is that the
producer's connection didn't receive the advisory message (notification)
from broker about this temp destination, and it will throw an exception
if it doesn't know this temp destination.
The fix is send the advisory to the client so that it knows this destination.
2017-02-21 14:46:47 +08:00
Jiri Danek
a7a0535afa
NO-JIRA Fixing typos in log messages, test names and comments
...
Related to ARTEMIS-387 (fowardingAddress)
2017-02-20 20:54:45 -05:00
Clebert Suconic
29af4a982a
NO-JIRA: removing dead code on AMQPSessionContext
2017-02-20 19:34:38 -05:00
Clebert Suconic
b788acd834
ARTEMIS-982 Fixing possible deadlock on AMQP.close & delivery
...
https://issues.apache.org/jira/browse/ARTEMIS-982
This is fixing a possible deadlock on delivering messages while AMQP close is called for any reason.
2017-02-20 12:35:49 -06:00
Howard Gao
e7a4d42a64
ARTEMIS-979 OpenWire "no-Local" consumer not working
...
When creating a 'no-local' openwire consumer, it doesn't work,
meaning it can still receive messages from the same connection.
The fix is similar to what Artemis client does, which is adding
a 'filter' to the consumer/subscription.
The difference is that with OpenWire we have to do it on the
broker side.
2017-02-20 08:17:43 -05:00
Martyn Taylor
8b51ec27db
NO-JIRA Send MQTT WILL outside of Server Session
2017-02-18 13:31:57 +00:00
Martyn Taylor
5a235d98b6
ARTEMIS-974 ensure will messages are retained
2017-02-16 18:22:10 +00:00
Dejan Bosanac
21b64b3e4f
https://issues.apache.org/jira/browse/ARTEMIS-815 - support wildcard address configuration in mqtt layer
...
https://issues.apache.org/jira/browse/ARTEMIS-815 - support wildcard address configuration in mqtt layer - remove old swap method
https://issues.apache.org/jira/browse/ARTEMIS-815 - added tests for mqtt-openwire integration and fixed openwire layer
https://issues.apache.org/jira/browse/ARTEMIS-815 - remove unused imports
2017-02-16 17:37:50 +00:00
Ulf Lilleengen
5f6a390b60
ARTEMIS-908: Ensure that connection lock is held when flushing
2017-02-15 14:09:27 +01:00
Martyn Taylor
bd1f244dfc
NO-JIRA Clean up around MQTTConnectionManager
2017-02-14 11:26:54 -06:00
Martyn Taylor
3bd5c9df6a
ARTMEIS-958 Route Will message outside server session
2017-02-14 11:26:54 -06:00
Martyn Taylor
59773c2849
ARTEMIS-960 Do not encode Will messages
2017-02-14 11:26:54 -06:00
Justin Bertram
ff3e75d148
NO-JIRA move RoutingType to different package
2017-02-13 09:50:41 -06:00
Andy Taylor
318778954d
ENTMQBR-522 - dont ack on separately settled deliveries
...
https://issues.jboss.org/browse/ENTMQBR-522
2017-02-10 09:50:51 -05:00
Martyn Taylor
cd28d76554
ARTEMIS-951 Auto Commit MQTT Acks
2017-02-09 10:43:03 +00:00
Martyn Taylor
b2e250d425
ARTEMIS-952 Remove MQTT Queues on Clean Session
2017-02-09 10:43:03 +00:00
Howard Gao
1a3fdd0916
ARTEMIS-949 Prevent Openwire from closing consumer twice
2017-02-08 15:57:43 +08:00
Andy Taylor
f268c101af
ARTEMIS-944 - Broker can't convert AMQP python message to Openwire format
...
https://issues.apache.org/jira/browse/ARTEMIS-944
2017-02-07 14:02:20 +00:00
Timothy Bish
b9bf5d54f2
ARTEMIS-794 Add tests for handling of various outcomes for deliveries
...
Adds tests for handling of Rejected, Released and Modified outcomes for
a delivery sent to a receiver. Tests show that for the Modified outcome
the broker is redelivering the message to the same receiver when the
undeliverable here value is set which violates the AMQP 1.0 specified
handling of that field. Also for Rejected outcome the broker should
be sending the rejected message to the DLQ as Rejected is supposed to
be a terminal outcome.
Small fix included to not adjust the delivery count if the Modified
outcome does not indicate that the delivery failed.
2017-02-07 13:45:11 +00:00
Martyn Taylor
3900cb0ec7
ARTEMIS-917 Only return body of retained message after reboot
2017-02-06 13:33:26 -06:00
Clebert Suconic
f79b21e866
ARTEMIS-934 Stomp Heart beat not being stopped in some cases
2017-01-25 12:17:47 -05:00
Will Reichert
3347a4fd27
ARTEMIS-928 Changing Netty and InVM to copy buffers, and retain them on the Netty Polls.
2017-01-18 16:59:32 -05:00
Justin Bertram
8cf94623a4
ARTEMIS-922 Rename deleteOnNoConsumers throughout
...
The name "deleteOnNoConsumers" isn't a good match for the semantics underneath.
The name "purgeOnNoConsumers" (and variants) is a better fit.
2017-01-17 11:40:56 -06:00
Andy Taylor
f52cb5c610
ARTEMIS-918 - use requested routing type when client defined with amqp and address doesnt exist
...
https://issues.apache.org/jira/browse/ARTEMIS-918
2017-01-12 12:07:16 +00:00
Howard Gao
4e309d842e
ARTEMIS-562 Use 'to' field if sender target is null
2017-01-11 14:20:39 -05:00
Andy Taylor
355d33ea4f
fix log trace message throwing exception
2017-01-09 14:58:25 -05:00
Ulf Lilleengen
f2f3552067
ARTEMIS-908: Hold connection lock when issuing credits
2017-01-04 10:59:33 -06:00
Howard Gao
eecbbb18db
ARTEMIS-902 OpenWire Compression Issue
2016-12-23 21:29:28 +08:00
Timothy Bish
51c95babfe
ARTEMIS-901 Account for the presence of authzid in sasl plan auth
...
If the SASL plain mechanism arrives with the authzid value set the
mechanism needs to account for its presence and use the correct fields
of the exchange to get the username and password values. Adds some
tests to validate this fix.
2016-12-21 18:18:54 -05:00
Clebert Suconic
81df93ebcf
ARTEMIS-883 improving exceptions sending
2016-12-21 12:04:06 -05:00
Howard Gao
ae90edfdb6
ARTEMIS-883 Fix OpenWire ProducerFlowControlTest
2016-12-21 12:04:06 -05:00
Andy Taylor
63f723fe8d
ARTEMIS-888 - default to false if header durable not set
...
https://issues.apache.org/jira/browse/ARTEMIS-888
2016-12-20 09:32:33 +00:00
Andy Taylor
198143edd0
ARTEMIS-892 - add lock to tick method
...
https://issues.apache.org/jira/browse/ARTEMIS-892
2016-12-16 12:11:54 +00:00
Clebert Suconic
0c18c343e9
NO-JIRA: fixing checkstyle
2016-12-15 17:00:10 -05:00
Martyn Taylor
55fbcfebf8
Do not autoDelete address if it was not autoCreated
2016-12-15 17:13:09 +00:00
Andy Taylor
a9b32bdf0b
adding missing check for closed on proton receiver
2016-12-15 13:40:47 +00:00
Andy Taylor
3b75c95413
ARTEMIS-888 - AMQP headers arent always set
...
https://issues.apache.org/jira/browse/ARTEMIS-888
2016-12-15 07:07:04 +00:00
jbertram
10a32481fd
ARTEMIS-789 fix ArtemisTest
2016-12-14 19:46:53 -06:00
Andy Taylor
881615e646
ARTEMIS-891 - upgrade proton to 0.16
...
https://issues.apache.org/jira/browse/ARTEMIS-891
2016-12-14 18:25:26 +00:00
Clebert Suconic
08e0c5e4f1
Revert "ARTEMIS-888 - AMQP headers arent always set"
...
This reverts commit d471f6b15f
.
2016-12-14 10:20:18 -05:00
Andy Taylor
d471f6b15f
ARTEMIS-888 - AMQP headers arent always set
...
https://issues.apache.org/jira/browse/ARTEMIS-888
2016-12-14 09:25:10 -05:00
jbertram
30b1335614
ARTEMIS-877 STOMP tests + routing header
2016-12-13 17:59:09 -06:00
jbertram
3150759806
ARTEMIS-880 use built-in prefixing for STOMP
2016-12-13 15:05:43 -06:00
Howard Gao
d67ea071a3
ARTEMIS-885 Fix OpenWire wildcard conversion issue
2016-12-13 15:58:35 -05:00
Martyn Taylor
7f658cad21
ARTEMIS-788 Enable auto create and Prefix in MQTT
2016-12-13 15:54:50 -05:00
Martyn Taylor
6682072da6
Major Version Bump 2.0.0 After Major Arch Change
2016-12-09 18:43:15 +00:00
jbertram
fa67d40b9d
ARTEMIS-789 Fixed a number of failing tests
2016-12-09 18:43:15 +00:00
jbertram
fe52ca6d75
ARTEMIS-881 Support new address-settings for auto-create queue
2016-12-09 18:43:15 +00:00
Martyn Taylor
8f532cc25d
ARTEMIS-880 Add support for address prefixing
2016-12-09 18:43:15 +00:00
Andy Taylor
224f62b295
ARTEMIS-877 Add Consumer support for AMQP for new addressing schema
2016-12-09 18:43:15 +00:00
Howard Gao
a182a135e9
ARTEMIS-789 Add OpenWire Tests for MULTICAST,ANYCAST
2016-12-09 18:43:15 +00:00
jbertram
683ae68989
ARTEMIS-789 Fix Failing Tests
2016-12-09 18:43:15 +00:00
Howard Gao
2dc6482c91
ARTEMIS-789 Fix OpenWire tests due to missing RoutingType
2016-12-09 18:43:15 +00:00
Martyn Taylor
1339c930de
ARTEMIS-780 Fixes a number of broken tests
2016-12-09 18:43:15 +00:00
Martyn Taylor
7a51491c32
ARTEMIS-780 Added ability to define 2 Routing Types on a single addres
2016-12-09 18:43:15 +00:00
jbertram
0861be14c1
ARTEMIS-789 Fix various failing tests due to addressing changes
2016-12-09 18:43:15 +00:00
Howard Gao
796550d16b
ARTEMIS-789 OpenWire queue auto-creation failure
2016-12-09 18:43:15 +00:00
jbertram
a88853fe53
ARTEMIS-788 Stomp refactor + track autocreation for addresses
2016-12-09 18:43:15 +00:00
jbertram
84e8a87325
ARTEMIS-876 Remove all reliances on JMS prefixing
2016-12-09 18:43:15 +00:00
Martyn Taylor
887b8c8532
ARTEMIS-788 Update MQTT Protocol
2016-12-09 18:43:15 +00:00
Clebert Suconic
ebbc91c728
[maven-release-plugin] prepare for next development iteration
2016-12-06 16:59:52 -05:00
Clebert Suconic
5bcbea2517
[maven-release-plugin] prepare release 1.5.1
2016-12-06 09:47:43 -05:00
Howard Gao
c4339d809b
Fix JMSDurableTopicRedeliverTest.testRedeliverNewSession test failure
2016-12-06 11:02:27 +08:00
Ville Skyttä
a99617ae6b
Treat STOMP 1.1+ undefined header escape sequences as errors
...
https://stomp.github.io/stomp-specification-1.2.html#Value_Encoding
2016-11-30 17:56:49 -05:00
Dmitrii Tikhomirov
3995319dca
ARTEMIS-865 Remove e.printStackTrace() from code
2016-11-23 11:15:54 -05:00
Howard Gao
1487fe6bdd
ARTEMIS-864 Sending to a destroyed temp queue didn't get exception
2016-11-22 19:42:38 +08:00
Andy Taylor
6628db4892
ARTEMIS-825 - Invalid selector not handled correctly in AMQP
...
this changes propogates the error to the client and closes the sender correctly
https://issues.apache.org/jira/browse/ARTEMIS-825
2016-11-21 11:24:51 -05:00
Andy Taylor
329c533d21
ARTEMIS-823 = broker doesn't settle rejected messages
...
Currently we don't settle rejected messages at the broker, we should always settle when rejected
https://issues.apache.org/jira/browse/ARTEMIS-823
2016-11-21 11:24:51 -05:00
Ryan Yeats
fd12266449
ARTEMIS-860 add artemis-openwire protocol to osgi feature and fix bundle issues
2016-11-19 08:55:58 -07:00
Howard Gao
4691cbe882
ARTEMIS-842 JMSMessageID doesn't appear to work in selector
2016-11-08 09:52:12 +08:00
Ulf Lilleengen
00340c86e0
ARTEMIS-814: Support specifying connection properties
2016-11-07 15:12:14 +01:00
Clebert Suconic
f2db1c4337
[maven-release-plugin] prepare for next development iteration
2016-11-03 15:35:05 -04:00
Clebert Suconic
13a8a2bd40
[maven-release-plugin] prepare release 1.5.0
2016-11-03 15:34:54 -04:00
Clebert Suconic
ab7adbbd7a
ARTEMIS-814 Moving ProtonClientSenderContext towards the client package
...
I have done it this way to be consistent to what's being documented on the package-info.java for the client package
2016-11-02 14:24:51 -04:00
Ulf Lilleengen
52a462d155
ARTEMIS-814: Refactor client connection and allow adding custom event handlers
2016-11-02 14:24:44 -04:00
Clebert Suconic
5e5ac0f057
ARTEMIS-832 Openwire was ignoring data syncs.
...
I'm also adding the possibility of sync on libaio, and not only relay on write-cache
2016-11-02 13:17:12 -05:00
Timothy Bish
b07d6a9e75
ARTEMIS-268 Adds tests that shows issue with presettled receivers
...
Tests added that show that a receiver attached to a queue as presettled
are not removing the messages that are dispatched to them.
2016-11-02 14:14:35 -04:00
Clebert Suconic
e0021252ee
ARTEMIS-829 Removing messages re-encoding
...
https://issues.apache.org/jira/browse/ARTEMIS-829
2016-10-28 16:54:58 -04:00
Andy Taylor
1a4a148ba9
ARTEMIS-817 and ARTEMIS-818 openwire fixes
...
https://issues.apache.org/jira/browse/ARTEMIS-817
https://issues.apache.org/jira/browse/ARTEMIS-818
issues around Openwire protocol, sending a null stream maessage via openwire causes a null pointer and if a topic is auto created with openwire then it cant be destroyed as it checks for the management queue.
2016-10-25 12:00:37 -04:00
Clebert Suconic
2d1bdcd5bd
ARTEMIS-814: Moving classes around and adding docs
2016-10-24 09:42:22 -04:00
Ulf Lilleengen
e65fd5d674
ARTEMIS-814: Add support for outgoing AMQP connections
2016-10-24 09:42:22 -04:00
Ulf Lilleengen
6e5b917cc5
ARTEMIS-814: Fix a bug where context could be null in case a connection was closed before the flow arrived
2016-10-24 09:42:22 -04:00
Timothy Bish
226f28abf5
ARTEMIS-799 Fix issues with the AMQP Durable Topic Subscription model
...
Fixes several issues found in the handling of durable topic
subscriptions (test cases added).
2016-10-14 03:54:35 +02:00
Paul Gallagher
fcb70f3f60
ARTEMIS-779 upgrade to netty 4.1.5.Final
2016-10-10 23:24:56 +02:00
Martyn Taylor
a09348695c
ARTEMIS-778 Fix MQTT tests, refactor session state
2016-10-10 23:24:14 +02:00
Clebert Suconic
bed3f47c85
NO-JIRA: removing non used class
2016-10-10 15:31:46 +02:00
Ville Skyttä
ddd1559fbe
javadoc: Fix doclint empty <p> warnings
2016-10-10 10:02:49 +02:00
Ville Skyttä
9a439b4791
javadoc: Fix doclint reference errors
2016-10-10 10:02:49 +02:00
Ville Skyttä
693e745b9c
Remove redundant type arguments
...
Missed by sevntu-checkstyle, but not the Eclipse compiler.
https://github.com/sevntu-checkstyle/sevntu.checkstyle/issues/458
2016-10-08 10:01:45 +03:00
Timothy Bish
398da40f7d
ARTEMIS-776 Attach response should only list supported filters
...
The broker needs to return only the filters that are supported on a
receiver attach otherwise the remote is not aware that the broker is not
able to honor the requested configuration of the receiver.
2016-10-07 17:35:27 -04:00
Timothy Bish
62627bf2ee
ARTEMIS-770 AMQP Message Transformer refactor
...
Refactor the AMQP Message transformers both for better performance and
also to fix a number of issues with the transformers creating inbound
and outbound messages with incorrectly mapped values or extra data
appended where it should not be.
2016-10-07 10:42:52 -04:00
Martyn Taylor
95c4fdd408
ARTEMIS-762 Reflect management changes in AMQP protocol
2016-10-07 10:38:01 -04:00
Ville Skyttä
082b75bb3d
More use of try-with-resources
2016-09-30 13:17:26 -04:00