summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Send unexpected_frame if we get the wrong frame type or mismatched class ids.bug21835Simon MacMullen2010-06-151-11/+20
|
* Merged default into amqp_0_9_1Emile Joubert2010-06-1510-132/+144
|\
| * Merged default into amqp_0_9_1Simon MacMullen2010-06-0812-143/+195
| |\
| | * Merge default into amqp_0_9_1.Simon MacMullen2010-05-2812-164/+232
| | |\
| | | * Merging bug 22695 into amq_0_9_1Matthew Sackman2010-05-120-0/+0
| | | |\
| | | * | Correct formattingbug22695Matthew Sackman2010-05-121-21/+25
| | | | |
| | | * | Don't recover exclusive queues if the owner pid has gone away.Simon MacMullen2010-05-112-63/+36
| | | |/
| | | * Merge default into amqp_0_9_1.Simon MacMullen2010-05-1012-311/+389
| | | |\
| | | | * Merge a182153c2578 into amqp_0_9_1Simon MacMullen2010-05-1012-308/+388
| | | | |\
| | | | | * Merge up to a8da11d231ff from default to amqp_0_9_1. This causesSimon MacMullen2010-05-1022-237/+225
| | | | | |\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | testConnectionQueueSameNode to fail due to a race in recovering exclusive queues (bug 22695). We'll need a fix from default, so leaving as is for the time being.
| | | | | * \ Merge default into amqp_0_9_1 (for the sake of bug22619)David Wragg2010-04-2812-324/+380
| | | | | |\ \
| | | | | | * \ Merge default into amqp_0_9_1. There was a conflict inMichael Bridgen2010-04-2617-174/+250
| | | | | | |\ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | rabbit_amqqueue.erl, due in the main to recover/0 being removed and refactoring of durable queue recovery in general.
| | | | | | * \ \ Merge default into amqp_0_9_1Tony Garnock-Jones2010-04-0612-321/+377
| | | | | | |\ \ \
| | | | | | | * \ \ Merging default into amqp_0_9_1Matthew Sackman2010-03-2429-1078/+2379
| | | | | | | |\ \ \
| | | | | | | * \ \ \ Non-trivial merge of default into amqp_0_9_1. Queue exclusivity (bugMichael Bridgen2010-03-1832-437/+1264
| | | | | | | |\ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 20578) and exchange hooks intersect in a few places. The main things to take care over are that the post-queue-deletion hooks gets called, and the exclusivity check is called. NB: exchange auto-delete machinery needs to be removed, which will simplify things in a few places.
| | | | | | | * | | | | Fix up things that dialyze complains aboutMichael Bridgen2010-02-153-11/+2
| | | | | | | | | | | |
| | | | | | | * | | | | Remove usused variables. That includes removing ReaderPid from the ↵Michael Bridgen2010-02-155-11/+10
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | signature of rabbit_amqqueue:basic_consume/8
| | | | | | | * | | | | De-bitrot by merging default in. Passes rabbit_tests:all_tests() andMichael Bridgen2010-02-1513-329/+365
| | | | | | | |\ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | the ../rabbitmq-test test suite. Some unused variables appear to have crept in during previous commits to the branch; will fix in another commit.
| | | | | | | | * | | | | fixing mergesDavid R. MacIver2010-01-221-39/+12
| | | | | | | | | | | | |
| | | | | | | | * | | | | merge with previous head for merge of default into 0_9_1David R. MacIver2010-01-220-0/+0
| | | | | | | | |\ \ \ \ \
| | | | | | | | | * \ \ \ \ Merge default into amqp_0_9_1Tony Garnock-Jones2009-12-013-59/+62
| | | | | | | | | |\ \ \ \ \
| | | | | | | | * | \ \ \ \ \ merge of default into amqp_0_9_1. Not quite working yet, but runs and passes ↵David R. MacIver2010-01-2233-830/+778
| | | | | | | | |\ \ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | some tests
| | | | | | | | * | | | | | | | Bug 21838: check equivalence on exchange.declareMichael Bridgen2009-12-022-3/+31
| | | | | | | | | | | | | | | |
| | | | | | | | * | | | | | | | Bug 21838: Don't check the type in a exchange.declare{passive=true},Michael Bridgen2009-12-021-3/+1
| | | | | | | | | |/ / / / / / | | | | | | | | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | as per the field doc in the spec.
| | | | | | | | * | | | | | | Merge default in. This includes bug22020. There were someMichael Bridgen2009-11-2413-319/+336
| | | | | | | | |\ \ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | non-obvious conflict resolutions: - getting rid of the q/x durability agreement check - in getting rid of the exchange may_auto_deleting, making sure all branches returned 'ok' (the tests all start failing!).
| | | | | | | | | * \ \ \ \ \ \ Merge default into amqp_0_9_1Tony Garnock-Jones2009-11-2113-327/+329
| | | | | | | | | |\ \ \ \ \ \ \
| | | | | | | | | | * | | | | | | Bug 21986: Use gen_server2:call instead of gen_server2:cast to makeMichael Bridgen2009-11-172-15/+16
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | this synchronous. This means recover_async is now also synchronous, but it's deprecated, and anyway we do the same thing with no_wait elsewhere. This way we have just the one code path.
| | | | | | | | | | * | | | | | | Bug 21986: Implement synchronous basic.recoverMichael Bridgen2009-11-171-0/+8
| | | | | | | | | | | | | | | | |
| | | | | | | | | | * | | | | | | Merge from default, to get recent work as well as support for field-array.Michael Bridgen2009-11-1713-317/+310
| | | | | | | | | | |\ \ \ \ \ \ \
| | | | | | | | | | | * | | | | | | Enforce frame-max negotiationMichael Bridgen2009-11-121-9/+20
| | | | | | | | | | | | | | | | | |
| | | | | | | | | | | * | | | | | | Bug 21836: Test that the content framing code doesn't produce frames that ↵Michael Bridgen2009-11-121-0/+40
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | break frame-max
| | | | | | | | | | | * | | | | | | bug 20578: factor out the check-if-the-queue-has-changed pattern of the two ↵Michael Bridgen2009-11-041-19/+18
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | branches
| | | | | | | | | | | * | | | | | | bug 20578: Spring-clean queues on recovery by checking each to see ifMichael Bridgen2009-11-041-20/+37
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | it is exclusive to a dead process (connection); and if so, deleting it. As things stand, a queue can't be owned by a connection on another node (so the aliveness check is redundant), but this will account for such scenarios in the event of connection- or queue-mobility.
| | | | | | | | | | | * | | | | | | Merge from default to get, among other things, better memory management and ↵Michael Bridgen2009-11-0413-291/+217
| | | | | | | | | | | |\ \ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | synchronous auto_deletes
| | | | | | | | | | | | * | | | | | | Update test to rabbit_amqqueue:declare/5Michael Bridgen2009-11-041-1/+1
| | | | | | | | | | | | | | | | | | |
| | | | | | | | | | | | * | | | | | | bug 21385: Make basic.get respect exclusivityMichael Bridgen2009-11-041-1/+5
| | | | | | | | | | | | | | | | | | |
| | | | | | | | | | | | * | | | | | | bug 21385: check exclusivity for queue.bind as well. Because I needMichael Bridgen2009-11-033-22/+29
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | to do the check inside the transaction, I had to change rabbit_exchange:add_binding/4 (and delete_binding/4) to take another parameter for the check. I also made the exclusivity check more obviously run for its side-effect.
| | | | | | | | | | | | * | | | | | | bug 21385: Move exclusive queue checks to rabbit_channel, and add themMichael Bridgen2009-11-032-68/+58
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | in to the queue operations mentioned in the 0-9-1 spec's "exclusive" rule (except for queue.bind which is a bit harder).
| | | | | | | | | | | | * | | | | | | - keep track of the owner in the amqqueue record. We need this so weMichael Bridgen2009-10-224-82/+70
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | can check equivalence on queue.declare - speaking of which, implement the "equivalent" rule of queue.declare (bug 21832) - queues are exclusive on creation, and don't change owner, so get rid of claim_queue - also check exclusive in the passive version of queue.declare; this is explicitly mandated by the spec (queue.declare, exclusive) - bug 21385: exclusive queues are deleted when their owners go away, as per the spec. This didn't actually change implementation -- it was wrong for 0-8
| | | | | | | | | | | | * | | | | | | Merge default into amqp_0_9_1Tony Garnock-Jones2009-10-1911-142/+79
| | | | | | | | | | | | |\ \ \ \ \ \ \
| | | | | | | | | | | | | * | | | | | | Include protocol revision in bannerMichael Bridgen2009-10-191-1/+2
| | | | | | | | | | | | | | | | | | | |
| | | | | | | | | | | | | * | | | | | | Bug 20768: Accept a protocol header with 0-9 or 0-9-1 only, and disconnect ↵Michael Bridgen2009-10-131-48/+44
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | otherwise
| | | | | | | | | | | | | * | | | | | | auto_delete is no longer a property of exchangesMichael Bridgen2009-10-061-2/+2
| | | | | | | | | | | | | | | | | | | |
| | | | | | | | | | | | | * | | | | | | auto_delete is no longer a property of the exchange class (protocol spec ↵Michael Bridgen2009-10-051-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | section 1.6)
| | | | | | | | | | | | | * | | | | | | Merge from default. Resolved some conflicts due to bool->boolean inMichael Bridgen2009-10-058-108/+48
| | | | | | | | | | | | | |\ \ \ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | type specs, and a bad automerge in rabbit_reader.erl.
| | | | | | | | | | | | | | * \ \ \ \ \ \ merge default into amqp_0_9_1Tony Garnock-Jones2009-08-128-112/+50
| | | | | | | | | | | | | | |\ \ \ \ \ \ \
| | | | | | | | | | | | | | | * \ \ \ \ \ \ Merge default into amqp_0_9_1Tony Garnock-Jones2009-06-2417-211/+244
| | | | | | | | | | | | | | | |\ \ \ \ \ \ \
| | | | | | | | | | | | | | | * | | | | | | | Removed check for durable queues on transient exchangesBen Hood2009-06-081-6/+2
| | | | | | | | | | | | | | | | | | | | | | |
| | | | | | | | | | | | | | | * | | | | | | | Merged default back into amqp_0_9_1Ben Hood2009-06-088-106/+48
| | | | | | | | | | | | | | | |\ \ \ \ \ \ \ \
| | | | | | | | | | | | | | | | * \ \ \ \ \ \ \ merge default into amqp_0_9_1Tony Garnock-Jones2009-06-0313-105/+207
| | | | | | | | | | | | | | | | |\ \ \ \ \ \ \ \