Skip to content

Commit

Permalink
RabbitMQ server no longer supports "immediate" deliveries
Browse files Browse the repository at this point in the history
  • Loading branch information
tonyg committed Oct 30, 2012
1 parent 6bbbc91 commit 6d05e5e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/rabbithub_web.erl
Expand Up @@ -483,7 +483,7 @@ extract_message(ExchangeResource, ParsedQuery, Req) ->


perform_request('POST', endpoint, '', exchange, Resource, ParsedQuery, Req) -> perform_request('POST', endpoint, '', exchange, Resource, ParsedQuery, Req) ->
Msg = extract_message(Resource, ParsedQuery, Req), Msg = extract_message(Resource, ParsedQuery, Req),
Delivery = rabbit_basic:delivery(false, false, Msg, none), Delivery = rabbit_basic:delivery(false, Msg, none),
case rabbit_basic:publish(Delivery) of case rabbit_basic:publish(Delivery) of
{ok, _, _} -> {ok, _, _} ->
Req:respond({202, [], []}); Req:respond({202, [], []});
Expand All @@ -493,7 +493,7 @@ perform_request('POST', endpoint, '', exchange, Resource, ParsedQuery, Req) ->


perform_request('POST', endpoint, '', queue, Resource, ParsedQuery, Req) -> perform_request('POST', endpoint, '', queue, Resource, ParsedQuery, Req) ->
Msg = extract_message(rabbithub:r(exchange, ""), ParsedQuery, Req), Msg = extract_message(rabbithub:r(exchange, ""), ParsedQuery, Req),
Delivery = rabbit_basic:delivery(false, false, Msg, none), Delivery = rabbit_basic:delivery(false, Msg, none),
case rabbit_amqqueue:lookup([Resource]) of case rabbit_amqqueue:lookup([Resource]) of
[Queue] -> [Queue] ->
{routed, _} = rabbit_amqqueue:deliver([Queue], Delivery), {routed, _} = rabbit_amqqueue:deliver([Queue], Delivery),
Expand Down

0 comments on commit 6d05e5e

Please sign in to comment.