summaryrefslogtreecommitdiff
path: root/src
Commit message (Expand)AuthorAgeFilesLines
* refactorAlexandru Scvortov2010-09-293-32/+37
* cosmetics and minor refactorsMatthias Radestock2010-09-293-71/+53
* refactorAlexandru Scvortov2010-09-291-5/+4
* pull from defaultAlexandru Scvortov2010-09-2911-195/+664
|\
| * server tests passAlexandru Scvortov2010-09-273-13/+28
| * revert rabbit_tests to defaultAlexandru Scvortov2010-09-271-4/+1
| * bugfixes; passes same java tests as defaultAlexandru Scvortov2010-09-272-4/+7
| * better separation between amqqueue_process and bqAlexandru Scvortov2010-09-273-24/+20
| * cosmeticAlexandru Scvortov2010-09-271-23/+23
| * no performance penalty when *not* using confirmsAlexandru Scvortov2010-09-275-40/+52
| * solved a couple of bad_matches/function_clausesAlexandru Scvortov2010-09-273-12/+15
| * merge default into bug20284Alexandru Scvortov2010-09-2232-1437/+1569
| |\
| * | message store keeps track of queues through their client refsAlexandru Scvortov2010-09-062-51/+58
| * | stopped a raceAlexandru Scvortov2010-09-031-20/+37
| * | moved some confirm logic from router to channelAlexandru Scvortov2010-09-032-12/+4
| * | use client_terminate instead of monitoring for DOWNAlexandru Scvortov2010-09-031-10/+12
| * | cosmeticAlexandru Scvortov2010-09-031-4/+5
| * | cosmetic renamesAlexandru Scvortov2010-09-031-6/+6
| * | remove rabbit_basic:delivery/4 since it's not used by anythingAlexandru Scvortov2010-09-031-8/+3
| * | when a consumer ack is received, the publisher ack is sent by the amqqueue_pr...Alexandru Scvortov2010-09-033-38/+50
| * | moved most of the confirm logic from amqqueue_process to variable_queueAlexandru Scvortov2010-09-022-79/+83
| * | pending acks are sent out when the channel becomes idle or every 1sAlexandru Scvortov2010-08-311-10/+19
| * | fixed message leak caused by confirmsAlexandru Scvortov2010-08-312-17/+35
| * | merge default into bug20284Alexandru Scvortov2010-08-2743-889/+1319
| |\ \
| * | | solve a warningAlexandru Scvortov2010-08-251-1/+1
| * | | stopped a raceAlexandru Scvortov2010-08-201-5/+13
| * | | fixed an ever-expanding dictionaryAlexandru Scvortov2010-08-191-10/+7
| * | | refactoring + don't do useless workAlexandru Scvortov2010-08-193-22/+19
| * | | don't do any unnecessary work when publishing in confirm modeAlexandru Scvortov2010-08-191-3/+4
| * | | fixed a small empty-set bugAlexandru Scvortov2010-08-181-5/+4
| * | | deleting a queue causes all of its messages to be puback'dAlexandru Scvortov2010-08-184-18/+69
| * | | confirm transient messages only after basic.returnAlexandru Scvortov2010-08-181-19/+19
| * | | refactoringAlexandru Scvortov2010-08-171-61/+56
| * | | publisher acks for persistent messagesAlexandru Scvortov2010-08-173-25/+53
| * | | queue_index keeps track of which messages have been published but not written...Alexandru Scvortov2010-08-172-19/+35
| * | | persistent messages are ack'd only after the consumer acks itAlexandru Scvortov2010-08-172-15/+25
| * | | move msg_seq_no from #basic_message{} to #delivery{}Alexandru Scvortov2010-08-175-34/+62
| * | | first stab at keeping track of when messages are synced to diskAlexandru Scvortov2010-08-173-25/+92
| * | | refactoringAlexandru Scvortov2010-08-161-13/+12
| * | | PubAcks are de-dupped in rabbit_channelAlexandru Scvortov2010-08-151-29/+64
| * | | typo + reformattingAlexandru Scvortov2010-08-132-5/+4
| * | | refactoringAlexandru Scvortov2010-08-133-12/+7
| * | | puback for persistent non-mandatory, non-immediate, unrouted messagesAlexandru Scvortov2010-08-131-1/+7
| * | | pubacks are sent right after basic.returnsAlexandru Scvortov2010-08-131-8/+12
| * | | simplified code a bitAlexandru Scvortov2010-08-131-9/+7
| * | | puback is also sent after something basic.gets the messageAlexandru Scvortov2010-08-131-0/+1
| * | | partial acks for persistent messagesAlexandru Scvortov2010-08-133-27/+26
| * | | only transient messages are immediately ack'd (so far)Alexandru Scvortov2010-08-132-9/+21
| * | | new logicAlexandru Scvortov2010-08-131-21/+26
| * | | some instrumentationAlexandru Scvortov2010-08-133-5/+24