summaryrefslogtreecommitdiff
path: root/src/rabbit_channel.erl
Commit message (Collapse)AuthorAgeFilesLines
* merge default into bug25160Matthias Radestock2012-09-251-12/+9
|\
| * nuke 'immediate'bug23896Matthias Radestock2012-09-171-12/+9
| |
* | improve workingnessMatthias Radestock2012-09-241-1/+1
|/
* Remove the previous hack, add a check for the "impersonator" tag instead.Simon MacMullen2012-09-111-20/+17
|
* RenameSimon MacMullen2012-09-101-14/+14
|
* Add a backdoor to allow the direct client to set a trusted user-id. Yes, ↵Simon MacMullen2012-09-071-6/+13
| | | | this is ugly, but the diff is small.
* merge defaultFrancesco Mazzoli2012-07-191-37/+33
|\
| * make channel/soft errors easier to distinguish from hard errorsMatthias Radestock2012-07-161-1/+1
| |
| * more consistent error handling in readerMatthias Radestock2012-07-151-9/+9
| |
| * call the correct functionMatthias Radestock2012-07-151-1/+1
| | | | | | | | oops
| * refactor: precondition_failed helper functionMatthias Radestock2012-07-151-21/+17
| |
| * oops - 'hg record' diff boundary failMatthias Radestock2012-07-151-0/+4
| |
| * renamingMatthias Radestock2012-07-151-11/+7
| | | | | | | | | | ... for consistency with reader, and to better describe what the fun does
* | change naming from "termination" to "exit". also add `IS_' prefix to macroFrancesco Mazzoli2012-07-171-1/+1
|/
* track queues which may have delivered non-autoack messages to channelbug24860Matthias Radestock2012-04-121-13/+28
| | | | | | ...so that we can ensure that acks/requeues have been seen by those queues during an orderly shutdown by the time a 'close' (in the error case) or 'close_ok' is sent.
* Merge bug 24769.Simon MacMullen2012-04-121-3/+1
|\
| * tiny space saving refactorMatthias Radestock2012-04-121-3/+1
| |
* | merge bug24769Matthias Radestock2012-04-111-81/+22
|\ \ | |/
| * fix nack handling in channelMatthias Radestock2012-04-031-5/+6
| | | | | | | | | | | | When a queue dies abnormally we nack all messages sent to that queue and still pending confirms. Any confirms coming in for these messages thereafter - from other queues - are ignored.
| * convert channel to use new dtree data structure for confirm trackingMatthias Radestock2012-03-221-81/+21
| |
* | use pmon in queue_collectorMatthias Radestock2012-03-231-2/+2
| | | | | | | | | | | | this required a tweak to the amqqueue API - making delete_immediately/1 take a list of qpids rather than a single #amqqueue record.
* | use pmon in rabbit_channelMatthias Radestock2012-03-231-12/+9
|/
* cosmeticMatthias Radestock2012-03-221-3/+2
|
* cosmeticMatthias Radestock2012-03-021-3/+3
|
* merge bug24650 into default (Move names for connections and channels from ↵Alexandru Scvortov2012-02-281-13/+4
|\ | | | | | | mgmt to broker)
| * delay stopping the queue until all confirms have been receivedAlexandru Scvortov2012-02-171-1/+1
| | | | | | | | | | | | | | | | The only two cases we don't delay are when 1) there are no outstanding confirms and 2) if the queue is blowing up (e.g. because it's received an 'EXIT'). Also, small refactor for rabbit_misc:is_abnormal_termination/1.
| * simplify MsgFun logic for VQ:dropwhile/3 and VQ:ack/3Alexandru Scvortov2012-02-171-8/+3
| | | | | | | | | | | | MsgFun now takes a message (rather than a message reading callback). Also, only warn of lost messages when DLQ exits abnormally.
| * merge default into bug20337Alexandru Scvortov2012-02-121-5/+1
| |\ | | | | | | | | | All tests pass. This also fixes the rabbit_guid rename.
| | * merge default into bug20337Alexandru Scvortov2012-02-061-86/+75
| | |\
| | * \ merge default into bug20337Alexandru Scvortov2012-01-241-1/+2
| | |\ \
| | * | | amqqueue_process re-publishes with confirmsAlexandru Scvortov2011-11-141-5/+1
| | | | |
* | | | | Marginally tidierbug24605Simon MacMullen2012-02-241-3/+4
| | | | |
* | | | | Channel names.Simon MacMullen2012-02-231-10/+16
|/ / / /
* | | | Merged bug24505 into defaultEmile Joubert2012-02-081-64/+76
|\ \ \ \
| * \ \ \ Merge bug24234Simon MacMullen2012-02-081-11/+32
| |\ \ \ \
| | * | | | Cosmetic, restored reject/4 arguments to the previous order.Francesco Mazzoli2012-02-011-7/+8
| | | | | |
| | * | | | Merge default.Francesco Mazzoli2012-02-011-12/+32
| | |\ \ \ \
| | | * \ \ \ Merge default.Francesco Mazzoli2012-01-311-86/+74
| | | |\ \ \ \
| | | * | | | | Renamede reject_tx/4 to reject/4.Francesco Mazzoli2012-01-311-4/+4
| | | | | | | |
| | | * | | | | Delete extra whitespace.Francesco Mazzoli2012-01-251-2/+0
| | | | | | | |
| | | * | | | | Cons instead of append, reject does not change the channel state.Francesco Mazzoli2012-01-251-6/+5
| | | | | | | |
| | | * | | | | 'case' statement styleFrancesco Mazzoli2012-01-251-2/+3
| | | | | | | |
| | | * | | | | reject doesn't need to know about the channel state.Francesco Mazzoli2012-01-251-5/+6
| | | | | | | |
| | | * | | | | Fix to reject_tx, list comprehension instead of map.Francesco Mazzoli2012-01-251-2/+3
| | | | | | | |
| | | * | | | | Flatten the list of lists.Francesco Mazzoli2012-01-251-1/+1
| | | | | | | |
| | | * | | | | Executing basick.{nack,reject} transactionally.Francesco Mazzoli2012-01-241-15/+36
| | | | |_|/ / | | | |/| | |
| * | | | | | refactor: extract commonality between basic.deliver and basic.getMatthias Radestock2012-02-071-52/+43
| | |_|_|_|/ | |/| | | | | | | | | | | | | | | | | | | | | | ...and move the writer communication as early as possible, which improves latency.
* | | | | | Merged default.Francesco Mazzoli2012-02-071-2/+4
|\ \ \ \ \ \ | |/ / / / / |/| | | | |
| * | | | | Merge master in.Francesco Mazzoli2012-01-311-85/+74
| |\ \ \ \ \ | | |/ / / /
| * | | | | Change naming in rabbit_guid, explicit guid passing in string/0 and binary/0.Francesco Mazzoli2012-01-171-2/+4
| | |/ / / | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Specifically: fast_guid() -> gen() guid() -> secure_gen() string_guid(Prefix) -> string(Guid, Prefix) binstring_guid(Prefix) -> binary(Guid, Prefix)
View Lorry Controller Status