3e0231767b
merge default into bug18732
2008-10-17 17:21:02 +01:00
57dee61bf7
Merge bug19489 into default
2008-10-17 16:18:21 +01:00
3622512816
Merge bug19329 into default
2008-10-17 13:22:04 +01:00
bb98450a0e
Fixed typo
2008-10-17 00:13:57 +01:00
4c56b7bf21
Merge default into bug19382
2008-10-16 18:47:19 +01:00
cb732f4b17
Removed unused variables in the Makefile
2008-10-16 18:42:00 +01:00
635e10a074
Spec no longer requires non-standard macros,
...
include rpm-specifc files as sources instead of patch
2008-10-16 18:33:44 +01:00
c1374a89f7
Fixed QA remarks
2008-10-16 14:02:06 +01:00
dbf935be37
Merged default into bug19250
2008-10-16 13:03:49 +01:00
e138ddcf83
merge bug19552 into bug19468_channels
...
The former triggered errors in the latter
2008-10-16 06:51:33 +01:00
4df43062a0
fix 'duplicate_next' error when sending messages directly to proxied process
...
The buffering_proxy:mainloop was unconditionally requesting new
messages from the proxy. It should only do that when it has just
finished handling the messages given to it by the proxy in response to
a previous request, and not after handling a direct message.
2008-10-16 06:11:33 +01:00
9d11200ccb
some explanation
2008-10-16 05:46:04 +01:00
9eb25deee4
wire up channels to rabbit_alarm
...
We propagate changes in the high memory alarm status as channel.flow
messages to the client. The channel.flow_ok replies are simply
accepted.
2008-10-16 05:45:08 +01:00
d2f22dbbfa
make rabbit_alarm usable
...
This now supports the registration of alertee processes with callback
MFAs. We monitor the alertee process to keep the alertee list current,
and notify alertees of initial high memory conditions, and any
changes.
2008-10-16 05:36:51 +01:00
abce126e2e
cosmetic
2008-10-16 04:00:11 +01:00
3a178fdb53
branch off for effect-less alarm handling
...
so we can later experiment with different effects
2008-10-16 03:56:41 +01:00
7d47d3c66f
merge bug19432 into default
2008-10-15 12:19:39 +01:00
ee541db2ac
cosmetic
2008-10-15 12:15:28 +01:00
00ca078719
Got rid of unecessary queue:is_empty
2008-10-15 11:39:07 +01:00
e4f2aeaebe
Added function for Rabbiter
2008-10-13 22:51:23 +01:00
12e28a7f22
Got into a loop, I blame hg
2008-10-13 22:37:17 +01:00
1aceb2cc30
produce a nicer error message for common queue disappearance case
2008-10-13 21:56:26 +01:00
45090533fe
exit with a proper protocol error when commit/rollback fail
2008-10-13 21:37:02 +01:00
3ea54704a7
Set is the default
2008-10-13 21:27:33 +01:00
69305918ca
Changed index from ordered_set to set for durable routes
2008-10-13 21:09:53 +01:00
4f2846ca1f
don't log errors during delivery
...
If the target queue died normally we don't care, and if it died
abnormally the reason is logged by the queue supervisor. In both cases
we treat the message as unrouted.
2008-10-13 21:05:02 +01:00
7c77eb2025
Nuked a space
2008-10-13 19:18:12 +01:00
a81de67ef1
Used record wildcard match feature
2008-10-13 19:12:16 +01:00
b35534595c
Added wilcards to every argument field in binding record
2008-10-13 18:58:20 +01:00
de5b4fe2d4
Added arguments field to binding
2008-10-13 18:26:55 +01:00
908357efbd
maybe_auto_delete should always return ok
2008-10-12 23:43:16 +01:00
07f212e294
merge bug19332 into default
2008-10-12 17:36:14 +01:00
acd67e5e3b
merge bug19332 into default
2008-10-12 17:35:36 +01:00
75fba37dd3
cosmetic
2008-10-12 16:03:42 +01:00
6c6dbef97f
some minor formatting fixes
2008-10-12 11:59:28 +01:00
979415ea8b
refactoring: never construct reverse routes/bindings directly
2008-10-12 11:51:01 +01:00
b865db3a6d
fix indentation and comments
2008-10-12 11:44:58 +01:00
8512cde5b3
inline delete_bindings/1
...
and also refactor indexed_delete to use a list comprehension instead
of lists:foreach and return 'ok'.
2008-10-12 11:35:34 +01:00
e3a6cb0571
rejig call_with_exchange
...
We don't really need two flavours of call_with_exchange.
In delete_bindings/1 we can assume the exchange exists - this code is
called as part of queue deletion and we don't care about exchanges
that have gone missing.
Also, it is sufficient to use an ordinary read rather than wread.
2008-10-12 11:24:45 +01:00
4c33ba0972
Removed superfluous comment
2008-10-11 11:50:25 +01:00
92b89eb0a9
Don't hassle the HOF
2008-10-11 11:49:41 +01:00
74f7df23ae
Reinstated list_exchange_bindings/1
2008-10-10 23:09:25 +01:00
e71f140b9f
Changed select for has_bindings into a continuation
2008-10-10 21:59:06 +01:00
252aaf6657
Refactored all of the exchange delete functions
2008-10-10 21:51:39 +01:00
04189c2322
Print error message when codegen cannot import json
2008-10-10 16:26:06 +01:00
e7ec382c25
Default binding should be restored in exchange module
2008-10-10 16:18:06 +01:00
71fa0a4227
Moved and modified documentation
2008-10-10 09:11:22 +01:00
3af3be50fe
Adjusted some of the exit reasons
2008-10-09 11:37:02 +01:00
f1aee7cbec
Incorporated some QA remarks, added a test for this patch
2008-10-08 16:19:17 +01:00
f83fd93870
Simplified has_bindings because it only needs to do simple select and count
2008-10-08 14:07:36 +01:00
Matthias Radestock
Hubert Plociniczak
Emile Joubert
Ben Hood