Michael Klishin
|
52694b227a
|
Towards using manual queue-to-consumer flow control in STOMP processor
|
2014-08-06 19:43:44 +04:00 |
|
Michael Klishin
|
9d6bc79031
|
Support the requeue header for NACK frames
GitHub: references #2.
|
2014-07-07 19:33:42 +04:00 |
|
Michael Klishin
|
3b3b5e9697
|
merge stable into default
|
2014-07-04 16:39:56 +04:00 |
|
Michael Klishin
|
7b7dc98b73
|
Better error message
|
2014-07-04 16:24:41 +04:00 |
|
Michael Klishin
|
330f70ec2d
|
Squash more warnings
|
2014-06-26 11:08:36 +04:00 |
|
Michael Klishin
|
4f1e7f0c41
|
Squash more warnings
|
2014-06-26 11:08:36 +04:00 |
|
Michael Klishin
|
a1a24a51bb
|
Rename function
|
2014-06-24 12:23:24 +04:00 |
|
Michael Klishin
|
e471c461fb
|
Prefix queues with generative names with stomp-subscription
|
2014-06-24 12:19:01 +04:00 |
|
Michael Klishin
|
b18e57044e
|
Shut down the processor cleanly when a STOMP client misses heartbeats
Abnormal termination causes it to be restarted when it's no longer
necessary, plus produces gen_server termination traces in the SASL
log.
|
2014-06-18 16:10:48 +04:00 |
|
Michael Klishin
|
0dbb125d9a
|
In case of SUBSCRIBE failure, clean up queues for topic destinations, too
|
2014-06-16 10:44:34 +04:00 |
|
Michael Klishin
|
3a2f143da7
|
catch all case
|
2014-06-16 09:48:01 +04:00 |
|
Michael Klishin
|
2a44a8860c
|
Only delete declared queue if destination is /exchange/*
This way we can be sure the queue was declared by us.
|
2014-06-16 09:42:42 +04:00 |
|
Michael Klishin
|
89e572a087
|
Clean up declared queue when SUBSCRIBE handler fails
|
2014-06-16 09:04:37 +04:00 |
|
Michael Klishin
|
d7254cd002
|
Refactor
|
2014-04-07 14:17:06 +04:00 |
|
Michael Klishin
|
1a19b3f2a5
|
Correctly report blank destination errors, add a test
|
2014-04-07 13:49:23 +04:00 |
|
Michael Klishin
|
49609933f6
|
Reject publishes to destination named ""
|
2014-04-04 19:38:00 +04:00 |
Simon MacMullen
|
514f0ce5fa
|
Update copyright for 2014
|
2014-03-17 17:25:25 +00:00 |
|
Simon MacMullen
|
bf6852cdf4
|
Merge bug25957
|
2014-03-06 17:20:24 +00:00 |
|
Simon MacMullen
|
820025a5f8
|
Use the new-old basic.qos, rather than x-prefetch
|
2014-03-04 14:41:58 +00:00 |
|
Simon MacMullen
|
9a85853a7b
|
Check source of user is acceptable.
|
2014-02-24 13:45:55 +00:00 |
|
Simon MacMullen
|
8a58268318
|
Use per-consumer prefetch, and thus abandon all those per-subscription channels.
|
2014-01-14 11:02:42 +00:00 |
|
Simon MacMullen
|
c1d0f71075
|
Merge bug 24094
|
2013-10-03 11:34:47 +01:00 |
Emile Joubert
|
204b8e0b4e
|
Make sure processor dies, also when connections are short-lived
|
2013-10-01 13:46:06 +01:00 |
|
Emile Joubert
|
12db723a28
|
Propagate Erlang client API change
|
2013-09-24 11:59:17 +01:00 |
|
Emile Joubert
|
389e3b19b4
|
Changes and renaming
|
2013-08-30 11:16:36 +01:00 |
|
Emile Joubert
|
2bab10ff4b
|
Spacing
|
2013-08-27 09:48:14 +01:00 |
|
Emile Joubert
|
84cd329ab0
|
Prevent possible deadlock because children call parents
|
2013-08-23 17:58:54 +01:00 |
|
Simon MacMullen
|
4a7ce2247e
|
stable to default (someone forgot)
|
2013-08-02 14:58:21 +01:00 |
|
Emile Joubert
|
e5cf4eca75
|
Merged bug25691 into stable
|
2013-08-01 14:30:11 +01:00 |
|
Simon MacMullen
|
d1728e6f90
|
Minimise distance from stable
|
2013-07-31 14:56:02 +01:00 |
|
Simon MacMullen
|
103aae55a0
|
Do not corrupt state on server-sent basic.cancel.
|
2013-07-31 14:47:34 +01:00 |
|
Emile Joubert
|
618a52aa40
|
Merged stable into default
|
2013-07-31 13:57:29 +01:00 |
|
Simon MacMullen
|
dde1f102e1
|
s/VMware/GoPivotal/g
|
2013-07-01 10:49:15 +01:00 |
|
Emile Joubert
|
61922e0217
|
Merged stable into default
|
2013-06-06 16:10:53 +01:00 |
|
Simon MacMullen
|
f3099f106f
|
Fix non-temp reply queues, and add a test.
|
2013-05-21 17:18:55 +01:00 |
|
Simon MacMullen
|
113f75bac0
|
rabbit_stomp_processor is used from web-stomp too, don't assume which application we are.
|
2013-05-20 17:48:23 +01:00 |
|
Emile Joubert
|
d3211f85b5
|
Alternative implementation for vhost
|
2013-05-15 13:07:30 +01:00 |
|
Simon MacMullen
|
aeecb419f2
|
Remove
a
number
of
blank
lines.
|
2013-03-07 15:04:00 +00:00 |
|
Emile Joubert
|
59f94c0b58
|
Propagate API change
|
2013-03-07 12:12:28 +00:00 |
|
Emile Joubert
|
84269c0b27
|
Propagate API change
|
2013-03-07 11:18:47 +00:00 |
|
Emile Joubert
|
31730f4f69
|
Prevent sending to /temp-queue destinations
|
2013-02-26 17:51:00 +00:00 |
|
Emile Joubert
|
89e6201ec7
|
Rename
|
2013-02-25 14:22:31 +00:00 |
|
Emile Joubert
|
d9ea791141
|
More wrapping
|
2013-02-22 14:48:10 +00:00 |
|
Emile Joubert
|
ae5bf097a4
|
Wrapping
|
2013-02-22 14:40:03 +00:00 |
|
Emile Joubert
|
3c4cc8d053
|
Transparent temp queues
|
2013-02-22 14:16:02 +00:00 |
|
Emile Joubert
|
b4c7d30330
|
Transparent subscriptions to durable topic destinations
|
2013-02-22 13:59:35 +00:00 |
|
Emile Joubert
|
c1699b0cc9
|
Rename
|
2013-02-22 12:14:36 +00:00 |
|
Emile Joubert
|
db043eae8b
|
Punctuation
|
2013-02-20 15:13:14 +00:00 |
|
Emile Joubert
|
3fbb532a59
|
Naming of topic exchange destinations
|
2013-02-19 18:23:13 +00:00 |
|
Emile Joubert
|
da447d4267
|
Merge destination semantics with AMQP 1.0
|
2013-02-15 16:11:17 +00:00 |