summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* refactoring: rename "round robin" to "active consumers"bug20943Matthias Radestock2009-06-101-27/+31
|
* proper round-robining even when blockingMatthias Radestock2009-06-101-124/+111
| | | | | | | | | | | | | | | | | | | | This involved some substantial changes to the queue internal data structures - mostly by choice; the new design is cleaner: - We no longer keep a list of consumers in the channel records. Now the channel records just contain a consumer count instead, and that's only there for efficiency so we can more easily tell when we need to register/unregister with the limiter. - We now keep *two* consumer queues - one of active consumers (that's the one we've always had) and one of blocked consumers. We round-robin on the first one as before, and move things between the two queues when blocking/unblocking channels. When doing so the relative order of a channel's consumers is preserved, so the effects of any round-robining the active consumers get carried through to the blocked consumers when they get blocked and then back to the active consumers when they get unblocked.
* emergency merge of bug20958 into defaultMatthias Radestock2009-06-103-14/+21
|\ | | | | | | | | | | We point to the macports files of the default branch from our web site and they got broken with the merge of bug20333. This hopefully fixes that, but further qa is required.
| * merge in bug20955Matthew Sackman2009-06-101-4/+11
| |\
| | * respect channel blocking when adding consumersbug20955Matthias Radestock2009-06-101-4/+11
| |/
| * Merge bug20801 into defaultHubert Plociniczak2009-06-101-8/+10
| |\
| | * Merge two default branches into one.Hubert Plociniczak2009-06-103-23/+50
| | |\
| | * | fix off-by-one errorMatthias Radestock2009-06-101-1/+1
| | | | | | | | | | | | | | | | not that it really matters much
| | * | cosmeticMatthias Radestock2009-06-101-7/+9
| | | |
| * | | Use dist macro for building correct distribution versions.bug20801Hubert Plociniczak2009-06-102-5/+3
| | |/ | |/|
* | | Removed default shell, changed wrapper to work without default shelltimc2009-06-102-2/+2
| | |
* | | Creates rabbitmq user with a default shell and uses correct arguments to the ↵timc2009-06-102-3/+3
|/ / | | | | | | os x su command
* | Merge from bug20333 post verificationtimc2009-06-103-23/+50
|\ \ | |/ |/|
| * remove/add files missed on previous commitbug20333Matthias Radestock2009-04-062-2/+23
| |
| * use wrapper scripts in macportsMatthias Radestock2009-04-061-21/+27
| |
* | merge bug20940 into defaultMatthias Radestock2009-06-102-9/+12
|\ \
| * | cosmeticbug20940Matthias Radestock2009-06-101-6/+7
| | |
| * | Made can_send/2 into can_send/3.Matthew Sackman2009-06-092-9/+11
|/ /
* | merging in bug20782Matthew Sackman2009-06-088-81/+103
|\ \
| * | clean up tx records in queues when a transaction's channel diesbug20782Matthias Radestock2009-06-054-23/+43
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Previously queues were only monitoring channels with subscribers or to which ack-requiring messages had been delivered. Now queues also monitor channels from which they have received transactional publishes. Queues record the last tx id they have seen from a channel. This then makes it easy and efficient to find the associated tx record in the queue's process dictionary when a channel process dies - the alternative would be to scan the tx records for matching channel pids - and perform the required rollback activities for the tx.
| * | refactoring: bundle up all the data for a publishMatthias Radestock2009-06-057-64/+66
|/ / | | | | | | | | Passing this around as separate args was becoming a pain. Also, now it's easier to add more data items.
* | Split out internal_declare/2.Tony Garnock-Jones2009-06-041-2/+10
| |
* | merge bug20633 into defaultMatthew Sackman2009-06-041-16/+24
|\ \
| * | make delete_binding return an error when the binding does not existbug20633Matthias Radestock2009-06-021-16/+24
| | | | | | | | | | | | | | | This required some refactoring in order to avoid duplication of the code that constructs #binding records.
* | | merge bug20877 into defaultMatthias Radestock2009-06-030-0/+0
|\ \ \
* | | | alignbug20877Matthias Radestock2009-06-031-2/+2
| | | |
* | | | Change from number to atom.Tony Garnock-Jones2009-06-032-5/+11
|/ / /
* | | merge bug20654 into defaultTony Garnock-Jones2009-06-037-86/+178
|\ \ \
| * \ \ mergerbug20654Tony Garnock-Jones2009-06-031-1/+1
| |\ \ \
| | * | | fix typoMatthias Radestock2009-05-291-1/+1
| | | | |
| * | | | merge default into bug20654Tony Garnock-Jones2009-05-2714-54/+77
| |\ \ \ \ | |/ / / / |/| / / / | |/ / /
* | | | merge v1_5 into defaultTony Garnock-Jones2009-05-274-10/+19
|\ \ \ \ | |_|/ / |/| | |
| * | | Added tag rabbitmq_v1_5_5 for changeset 5dc463f43bb7v1_5Matthias Radestock2009-05-190-0/+0
| | | |
| * | | add package changelog entries for 1.5.5 releaserabbitmq_v1_5_5Matthias Radestock2009-05-193-1/+10
| | | |
| * | | merge bug20676 into v1_5David Wragg2009-05-183-10/+17
| |\ \ \
| * | | | Change to dependenciesbug20676Matthew Sackman2009-05-181-1/+1
| | | | |
* | | | | helper method for not_found errorsMatthias Radestock2009-05-204-12/+9
| | | | | | | | | | | | | | | | | | | | There was enough repetition to make it worthwhile
* | | | | document support for headers exchangeMatthias Radestock2009-05-191-1/+1
| | | | | | | | | | | | | | | | | | | | We forgot to do this bug 20152.
* | | | | merge v1_5 into defaultTony Garnock-Jones2009-05-1834-777/+2376
|\ \ \ \ \ | |_|/ / / |/| | | |
| * | | | merge v1_5 into defaultTony Garnock-Jones2009-05-131-1/+5
| |\ \ \ \
| * \ \ \ \ merge v1_5 into defaultTony Garnock-Jones2009-05-1334-777/+2376
| |\ \ \ \ \
* | \ \ \ \ \ merge bug20767 into v1_5Tony Garnock-Jones2009-05-183-10/+17
|\ \ \ \ \ \ \ | |_|_|_|/ / / |/| | | | | |
| * | | | | | Silence unused variable warningbug20767Tony Garnock-Jones2009-05-181-1/+1
| | | | | | |
| * | | | | | display node name and db dir on startupMatthias Radestock2009-05-183-10/+17
|/ / / / / / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | ...in a pretty and easy-to-parse way In the process we introduce rabbit_mnesia:dir() so we don't depend directly on the mnesia module - this also removes a dependency in the persister.
* | | | | | Merge bug20745 into v1_5Hubert Plociniczak2009-05-161-0/+2
|\ \ \ \ \ \
| * \ \ \ \ \ Merge bug20679 into v1_5Hubert Plociniczak2009-05-161-0/+2
| |\ \ \ \ \ \ | | |_|_|/ / / | |/| | | | |
| | * | | | | Add Default-Start and Default-Stop LSB init script linesbug20679David Wragg2009-05-081-0/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | To shut rpmlint up.
* | | | | | | Don't package the INSTALL documentbug20745David Wragg2009-05-131-1/+1
|/ / / / / /
* | | | | | merge bug20702 into v1_5Tony Garnock-Jones2009-05-131-1/+5
|\ \ \ \ \ \ | |_|/ / / / |/| | | | |
| * | | | | Set PATH to workaround case when escript is not in /usr/binbug20702David Wragg2009-05-081-1/+5
| | | | | |