Emile Joubert
decb2055aa
Merged bug24505 into default
2012-02-08 15:53:59 +00:00
Emile Joubert
db6410658f
Merged bug24670 into default
2012-02-06 15:50:53 +00:00
Simon MacMullen
f358bf688c
Merge bug24606
2012-02-03 13:07:05 +00:00
Emile Joubert
d4f7bec443
Update copyright 2012
2012-02-02 17:52:58 +00:00
Matthias Radestock
d4dd7b7b96
refactor: use new rabbit_misc:format/2
2012-02-02 15:51:33 +00:00
Simon MacMullen
0a6902a55f
Merge in default
2012-02-02 15:50:40 +00:00
Francesco Mazzoli
8a3e93e7fe
rabbit_guid:string_guid/1 -> rabbit_guid:string/2.
2012-02-01 11:34:50 +00:00
Matthias Radestock
f41f76406e
oops
2012-01-31 17:07:07 +00:00
Matthias Radestock
2aac8f851d
merge default into bug24336
2012-01-31 16:40:46 +00:00
Matthias Radestock
cbb0a88cd6
extract error logging
...
so we don't conflate it with returning an {error, ...} tuple
2012-01-31 16:32:56 +00:00
Simon MacMullen
80bab072eb
Don't explode on AMQP death.
2012-01-31 14:35:48 +00:00
Simon MacMullen
7fd3b3ffd0
Merge default
2012-01-30 14:43:42 +00:00
Matthias Radestock
b0c41e59ac
merge default into bug22470
2012-01-27 17:21:53 +00:00
Simon MacMullen
26b25bd3eb
Tweak the tuple we get...
2012-01-27 16:42:39 +00:00
Simon MacMullen
87fe7bb0f2
Only link to the connection, otherwise we get a race where the link conn -> stomp_processor -> channel can take out the channel from under the connection. This solves bug24336 but is perhaps not completely ideal.
2012-01-27 16:00:08 +00:00
Steve Powell
6eab090c14
Merge in default
2012-01-27 15:11:07 +00:00
Matthias Radestock
a0558f9722
use the existing error reason formatter
2012-01-27 13:58:24 +00:00
Matthias Radestock
a28bbf70e9
refactored error message creation
...
and got rid of the trailing ~n - the message does *not* get formatted
by Erlang, and the 'message' is meant to be a *header*, so, ideally,
on one line.
2012-01-27 13:35:07 +00:00
Matthias Radestock
1eab0dfa2b
always use rabbit_log for logging
2012-01-26 22:16:37 +00:00
Simon MacMullen
ad4c395b14
Sicne we trap_exits why don't we link to the connection / channel(s) and do something sensible if they die?
2012-01-20 14:35:48 +00:00
Simon MacMullen
11761e08dc
Silence warnings
2012-01-20 14:34:56 +00:00
Matthias Radestock
9ee1c4f117
only create destination queues once per session
...
...which is more efficient that doing so once per SEND.
2012-01-18 19:38:44 +00:00
Simon MacMullen
e77606c146
WIP
2012-01-18 14:48:54 +00:00
Emile Joubert
bada7600e5
Wrap
2011-12-01 12:51:02 +00:00
Steve Powell
7bc29fbcf0
Added check for headers not allowed on SEND
...
o also factored out some more headers
2011-11-25 12:49:56 +00:00
Steve Powell
d6dd68e42f
Factored out header strings.
2011-11-25 12:11:22 +00:00
Steve Powell
2064790dba
Moved common constraints into an hrl
2011-11-10 17:39:33 +00:00
Steve Powell
777d982822
Code to pass test.
2011-11-10 10:20:03 +00:00
Matthias Radestock
9fb8203cdf
cosmetic and minor refactors
2011-09-09 17:02:11 +01:00
Steve Powell
ff4d932862
Merge in default.
2011-08-26 15:16:03 +01:00
Steve Powell
db0afba9da
Merge in default
2011-08-26 13:46:25 +01:00
Rob Harrop
ad11737eb1
Handle case when we get acks with no recorded receipts
2011-08-26 13:10:44 +01:00
Rob Harrop
23b5e5bfd9
Fix handling of confirms for unrecorded receipts
2011-08-25 18:43:24 +01:00
Rob Harrop
945666a34b
Support header trimming for 1.0 clients
2011-08-25 12:41:26 +01:00
Steve Powell
3ced79cb3a
Rename and simplify shutdown_channel_and_connection to close_connection.
2011-08-25 12:35:38 +01:00
Steve Powell
bfe5632152
Remove catch from rabbit_net:*name calls but retain case (in case of {error, einval}).
2011-08-25 12:02:40 +01:00
Rob Harrop
1c5220a553
Merge with default
2011-08-25 08:01:29 +01:00
Steve Powell
62ab30729f
Make shutdown_channel_and_connection more comprehensive
2011-08-24 17:05:54 +01:00
Steve Powell
4a950ab8f7
Prevent premature death of stomp_reader and stomp_processor to clean up connection:
...
- change reader to temporary from intrinsic
- protect alien calls from processor by catch so as to avoid premature death
- call processor:flush_and_die/1 from reader when mainloop exits before reader dies
2011-08-24 14:50:48 +01:00
Rob Harrop
1da379c42a
Remove default prefetch for /queue destinations
2011-08-22 14:05:09 +01:00
Steve Powell
25556a657b
Merge bug24304 into default
2011-08-10 10:24:55 +01:00
Steve Powell
241f524bbc
Merge default in.
2011-07-27 16:57:17 +01:00
Steve Powell
8ef68aaa9d
Merge in default, resolving conflicts.
2011-07-27 15:16:25 +01:00
Steve Powell
1264a1fcac
Merge bug23864 into default
2011-07-27 12:11:57 +01:00
Rob Harrop
6f0255bbf7
Fixed heartbeat byte
2011-07-27 10:29:18 +01:00
Rob Harrop
e9663d0651
Support for durable subscriptions
2011-07-20 18:20:14 +01:00
Rob Harrop
cc5331c642
Merge with bug23864
2011-07-20 09:32:33 +01:00
Rob Harrop
e6499f9cdc
Support /temp-queue/ and /reply-queue/ destinations
2011-07-19 16:15:59 +01:00
Rob Harrop
7bdd9ce893
Allow SEND and SUBSCRIBE to /amq/queue destinations
2011-07-19 11:54:16 +01:00
Steve Powell
1ee1e65208
Suppress CONNECTED response on implicit connect.
2011-07-13 17:35:21 +01:00