Added tag rabbitmq_v2_3_0 for changeset 73804b18fc64

Hook into the new rabbitmq-public-umbrella testing support

Merge default into bug23568

Merge bug23777 into default

Flush sometimes takes slightly longer than the default 5 seconds

rename

Rough approximation for periodic flushing

Switched to using the hibernate capability of gen_server2

Removed stray handle_info callback

Moved to gen_server2

Experimental move back to prim_inet to facilitate extremely experimental TCP backpressure

Merge default into bug23568

Reworked TCP send to use rabbit_net:port_command

cosmetic

Reworked header conversion - slightly faster and quite a bit nicer

Back out the use of prim_inet - explicit gen_tcp:recv is faster in the benchmarks

Switched to using prim_inet:async_recv

Changed how bytes are read from the socket - better performance for large messages

simplifying refactor and cosmetics

Merge with default

bug23154 (ipv6) merged into default

This is no longer needed.

Tweak to how we match binaries when using Content-Length

Added optimisation when reading bodies with Content-Length set

Merge bug23652 into default

Whitespace

Some parser tweaks

Whitespace

Reworked parser to use binaries

Merged default again.

Merged bug23651 into default

Reworked body content parsing

Put short delay into destinations test

Merged in default

UN/SUBSCRIBE error messages contain the subscription as passed in by the user.

Merged default (with 1.1 support) and got tests working again.

Fixed up bugs in new parser

Merge with default

ensure_subchannel_closed now used; merged fixes from 23651

Merge from default.

Merge bug 23447.

Remove unused patched-in function.

Added receipted unsubscribe tests and check for send after unsubscribe properly.

Remove code duplication.

SX, SY have meanings in the spec that are not the same as the meanings here. Rename.

Cosmetic

Merge with bug23447

Merge with default

Merge bug23601 into default

Merge with default

Merge in bug23601 fixes

Refactored lifecyclke tests

Added support for multi NACK

Fixed error during merge

Merge bug23685 into default

Merge bug23686 to default after QA

Cleaned up the stomppy patch, including whitespace fixes

Removed unnecessary refactoring to rabbit_stomp_reader:process_received_bytes/2

Removed unused ack_mode slot in session state

Factored out common function format_detail/2

Renamed explain_amqp_death to amqp_death

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.

Tests and improvements for header value stripping, escaping and duplication

Exploratory rework of frame parser

Merged bug23601 into this branch

Added tests to check queue subscriptipn UNSUBSCRIBE

Augmented listener class (python) to allow debugging;
patch Latch, natch.

Added tests for unsubscribe from queue by destination and id

Reworked handling of AMQP errors so that the STOMP session is terminated too

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.

Added STOMP as an alias for CONNECT

Added support for NACK

restructured ACK code to extract the common parts for NACK

Removed stray debug line

Fixed issue with merge that broke version negotiation tests

Merge with default

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.

Update documentation for tcp_listeners.

Merged default

Bind to all ports by default, and rename "listeners" to "tcp_listeners" for consistency with other protocols.

Merge default into bug23568

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.

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.

Merge bug23477 into default.

Editorial from Steve

So I'm not sure how that worked, maybe there's some weird ::1 to 127.0.0.1 munging somewhere.

Updates for check_tcp_listener_address changes. IPv6 now works.

Removed DESIGN.md - it is not needed now

Rolled the important details from DESIGN.md into README.md

README updated, removing old instructions and reflecting new Ruby sample updates

Merge with default and updates to README

Reworked Ruby examples to allow more flexibility in the topic examples. Still need to document this

Merge bug23341 into default.

Make rabbit_stomp explicitly an application, remove start/0 and stop/0 that don't seem to be used anywhere.

Overhaul for bug23568

Merge from default

Added tag rabbitmq_v2_2_0 for changeset 328ce5ce874a

Reworked error identification and receipt handling. Receipts are now sent only on success

Backed out changeset 8f9ce5c24979 (reinstate FQ function names)

Cleaned up stray heartbeat stuff and set backlog tcpopt to 128 to handle more incoming connections

Fixed issue with arbitrary headers not being included in MESSAGE frames

Remove ?MODULE in front of directly-applied local functions

Port across the fix for bug23440, which was in rabbit_stomp_server.erl

Factor out the transport, so we can use an indirection for e.g., websockets.

Fixed whitespace error

Merge with remote

Fixed missing version header in CONNECTED frames

Reworked heartbeating to use the rabbit_heartbeat module

More patches against stomppy for the tests

Basic heartbeating for both server and client

tweaked test case to better exercise negotiation

test for prefetch with topics

Reworked ack handling to be inline with the 1.1 spec. Re-introduced the prefetch-count header to make ACK more useful

Version negotiation

Merge bug23341

Merged tiny bug fix that I missed earlier

Partially complete version negotiation

Utility for calculating the maximum version shared by the client and the server

Switched to using the host header as defined in the 1.1 spec

Removed stray io:format line

Updated the readme

Fixed the persistent sender example

fixed the perl RPC example

Fixed most of the samples. Other fixes require some consideration

Merged bug23440 into default

cosmetic: README is in markdown

cosmetic: avoid long lines

Fixed the .app file

Removed the old STOMP server code

Moved STOMP Headers -> AMQP Properties into util

Moved the AMQP Properties -> STOMP headers conversion over to util

cosmetic

Decided to move consumer tag processing in the end

Removed TODO. Decided against moving ConsumerTag parsing out to util because of all the useful context present when it is called

Removed TODO for completed task

Tests for longstr_field. Moved ack_mode calculation to util and added unit tests

Make stomp appear in rabbit_networking:active_listeners/0.

Fixed another formatting problem

Fixed bad formatting and removed TODO that had already been TODONE

Switched to supervisor2 to get nice clean up of client supervisors

First cut of splitting the stomp adapter apart. Frame processing is now wrapped up in a gen_server

Merge default heads

Added tag rabbitmq_v2_1_1 for changeset f98bb088d0cd

Ops, one of these Queues is not like the other ..

Merge bug23122 (idiomatic default behaviour)

Account for /exchange//something, which would previously have referred to exchange something
with no routing key (due to the removal of all leading blanks. We choose to interpret it as
referring to the default exchange, and reject it on the basis that you cannot bind to the
default exchange so it cannot follow our /exchange semantics.

Remove a clause and some duplication of parse_routing_information from ensure_queue_binding

Make topic and exchange subscription queues both exclusive (cannot be used from elsewhere) and auto_delete (will be deleted when unsubscribed)

Cosmetic, and replace instance of re:split with regexp:split (the former is in 12B3 and the latter isn't

support for escaping / in destination names

reworked channel handling to have one channel per /queue subscription now

renamed bind_queue_if_needed and create_queue_if_needed. removed stray io:format call

tweaked use of parse_content with regexp

parse_content simplified

Split $package/Makefile into $package/Makefile and $package/package.mk.

fixed the issue with transactional actions on /queue resources

made the tests a bit smarter when waiting for multiple messages

segmented /queue from other destinations on a separate channel

fixed the build script

added some more error case tests

changed how we reference stomppy now, so that it is pulled down from hg

adding missing test file, correct branch this time

merge with default

committed against default in error

missing test file

updated .hgignore

reworked error handling to get better messages when dealing with invalid destinations

Merge bug23124 again.

cosmetics

merge with bug23124

fixed use of rabbit_misc:die

merge with default

more tests, and added /topic

added all tests back in. removed stray io:format

more tests for /queue. added a basic.qos call temporarily while I decide what to do with prefetch for /queue

reworked tests and introduced /exchange and /queue destinations

Introduced /exchange support

cosmetics: tabs->spaces, nuke trailing whitespace, <80 columns

Merge bug23124, use direct mode client rather than mimicking a rabbit_channel

Changed mention of amq.direct to the direct exchange. Changed binding as appropriate

more unit tests for the destination parser

merged .hgignore from parent

fixed .hgignore

unit tests for the destination parser

working on unit tests

first cut of the destination parsing code

design doc

design comments

correct branch name for bug 23124

tests tweaked to accound for different error frames

still failing a test, need to decide what to do about lack of method names in errors coming from the erlang client

moved stomp to erlang client, just got one failing test

stomp is releasable

minor

correct naming of .app file template

Adjust stomp to work with new build

Remove deprecated vars

Added tag rabbitmq_v2_1_0 for changeset 44d574ddeb5a

Merge bug23231 (patch from Tony)

Update for latest server API (patch contributed by Tony Garnock-Jones)

Merge bug23130 into default (place plugin version into .app descriptor