search

tonyg / udp-exchange

Extends RabbitMQ Server with support for a new experimental exchange type, `x-udp`.
Other
48 stars 15 forks source link

Doesn't work on latest rabbit build #2

Closed marksteele closed 11 years ago

marksteele commented 11 years ago

Here's a patch:

--- src/udp_exchange.erl.orig 2013-07-04 10:48:44.642337012 -0400 +++ src/udp_exchange.erl 2013-07-04 10:52:56.454301420 -0400 @@ -18,7 +18,7 @@ {enables, kernel_ready}]}).

-export([description/0, serialise_events/0, route/2]). --export([validate/1, create/2, delete/3, policy_changed/3, add_binding/3, +-export([validate/1, validate_binding/2, create/2, delete/3, policy_changed/3, add_binding/3, remove_bindings/3, assert_args_equivalence/2]).

-export([truncatebin/2]). %% utility @@ -39,6 +39,8 @@ = endpoint_params(X), ok.

+validate_binding(_X, _B) -> ok. + %% Called just the first time the exchange is declared. create(transaction, X) -> ensure_relay_exists(X),

tonyg commented 11 years ago

Thanks for the patch - I've applied something similar, and things seem to be working OK. Please let me know if things are still busted.