3ae31bb4ec
Enable confirms on the channel if receipt header is set in SEND
2011-02-15 15:01:50 +00:00
3bb4ee7cf0
Removed the enforced flush
2011-02-09 16:35:03 +00:00
3bace9cbc3
Removed stray Makefile target
2011-02-02 11:40:39 +00:00
9d59c01042
Flush sometimes takes slightly longer than the default 5 seconds
2011-02-01 11:30:50 +00:00
2b1673d447
Rough approximation for periodic flushing
2011-01-31 19:15:06 +00:00
0ba9de756b
Switched to using the hibernate capability of gen_server2
2011-01-31 13:56:52 +00:00
20a2128427
Removed stray handle_info callback
2011-01-31 13:01:34 +00:00
b2120d0db5
Moved to gen_server2
2011-01-31 13:00:15 +00:00
25f0279997
Reworked TCP send to use rabbit_net:port_command
2011-01-26 17:46:27 +00:00
c7dba8206c
Changed how bytes are read from the socket - better performance for large messages
2011-01-25 15:21:35 +00:00
29699ea26a
Merge with default
2011-01-24 23:50:22 +00:00
3c656db0b6
Added optimisation when reading bodies with Content-Length set
2011-01-20 14:22:25 +00:00
928d5fde40
Whitespace
2011-01-20 09:37:57 +00:00
ea455d47d2
Some parser tweaks
2011-01-19 21:40:42 +00:00
73350fe6af
Reworked parser to use binaries
2011-01-19 20:50:10 +00:00
8a3694859b
UN/SUBSCRIBE error messages contain the subscription as passed in by the user.
2011-01-18 16:24:42 +00:00
cb15502118
Merged default (with 1.1 support) and got tests working again.
2011-01-18 15:23:07 +00:00
ce8b3b7894
Merge with default
2011-01-18 14:25:55 +00:00
a2d1eea7d1
ensure_subchannel_closed now used; merged fixes from 23651
2011-01-18 14:04:18 +00:00
55f2e7eb95
Added receipted unsubscribe tests and check for send after unsubscribe properly.
2011-01-18 12:46:28 +00:00
ed5928679e
Remove code duplication.
2011-01-18 12:35:53 +00:00
9d1721e94b
SX, SY have meanings in the spec that are not the same as the meanings here. Rename.
2011-01-18 12:21:57 +00:00
6b76e29da1
Cosmetic
2011-01-18 12:19:47 +00:00
e83b25e547
Merge with bug23447
2011-01-18 11:54:09 +00:00
e8c86bd131
Merge with default
2011-01-18 11:03:35 +00:00
c611891abd
Merge with default
2011-01-18 10:23:36 +00:00
6f8e904f9b
Merge in bug23601 fixes
2011-01-17 18:04:21 +00:00
e09807c6c4
Refactored lifecyclke tests
2011-01-17 17:55:27 +00:00
cc81bca7b9
Fixed error during merge
2011-01-17 12:02:10 +00:00
35a9f337f2
Merge bug23685 into default
2011-01-17 11:18:29 +00:00
4bd25e4063
Factored out common function format_detail/2
2011-01-17 10:50:24 +00:00
f478c4ef7a
Removed unused ack_mode slot in session state
2011-01-17 10:43:22 +00:00
7cbb8a95ab
Renamed explain_amqp_death to amqp_death
2011-01-17 10:38:43 +00:00
8c5759a3d4
Added receipted unsubscribes to lifecycle test
...
Augnmented handle_info to allow basic.cancel_ok records;
tweaked base.py Latch class not to underflow count;
receipted tests in lifecycle check for receipts.
2011-01-14 17:09:50 +00:00
fe92cae607
Merged bug23601 into this branch
2011-01-14 12:23:19 +00:00
fa5f530a18
Added tests to check queue subscriptipn UNSUBSCRIBE
...
Augmented listener class (python) to allow debugging;
patch Latch, natch.
2011-01-14 10:49:38 +00:00
65221a020b
Reworked handling of AMQP errors so that the STOMP session is terminated too
2011-01-13 15:38:12 +00:00
b2f87b62c9
Added tests for unsubscribe from queue by destination and id
2011-01-13 15:24:25 +00:00
2e5d05e692
Missing subscription tag does not terminate channel process.
...
error frame delivered instead of message frame;
test (lifecycle.py) updated to check for no errors at crucial points.
2011-01-13 14:18:25 +00:00
5c85681064
Added STOMP as an alias for CONNECT
2011-01-11 14:12:58 +00:00
162fd62b6d
Added support for NACK
2011-01-11 13:57:59 +00:00
c265a60a5b
restructured ACK code to extract the common parts for NACK
2011-01-11 11:25:44 +00:00
48b77578a9
Fixed issue with merge that broke version negotiation tests
2011-01-10 20:27:32 +00:00
8dd2b3e720
Merge with default
2011-01-10 18:43:41 +00:00
6dea470e1d
Close subscription channels on UNSUBSCRIBE
...
Only do so if the channel is not the main channel;
only do so if the subscription cancel succeeds;
no check of failure of close is made;
no extra error message introduced.
2011-01-10 13:35:43 +00:00
7e654f306a
Update UNSUBSCRIBE to wait on cancel.
...
Added amqp_channel:call directly in cancel_subscription_channel.
Included error() with no change of State if cancel response not ok.
Removed send_method/3.
2011-01-06 18:17:38 +00:00
0dfe5cc640
bug23601: changed UNSUBSCRIBE to cancel subscription from correct channel
...
Channel is created for each subscription (SUBSCRIBE) but main channel was used to cancel one (UNSUBSCRIBE).
This always fails unless the subscription is associated with the main channel (not likely).
Added cancel_subscription_channel/2 to rabbit_stomp_processor.erl called by handle_frame("UNSUBSCRIBE",...)
and added send_method/3 call to explicitly specify the channel on the amqp.call method.
2011-01-06 15:54:05 +00:00
0f1bc20cae
Reworked error identification and receipt handling. Receipts are now sent only on success
2010-11-26 11:10:43 +00:00
7cff94a519
Cleaned up stray heartbeat stuff and set backlog tcpopt to 128 to handle more incoming connections
2010-11-18 10:10:16 +00:00
76759ac444
Merge with remote
2010-11-12 07:25:12 +00:00
Rob Harrop
Steve Powell
Simon MacMullen