diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2011-06-20 14:21:02 +0100 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2011-06-20 14:21:02 +0100 |
| commit | 0128bf7cce3568e00753f42a516646eb04399c2d (patch) | |
| tree | a8d47994fdb3a83270264fd9e372ffd2bea8db77 /src | |
| parent | 0e9ab79f92f700da57c0c2c96501afa853833629 (diff) | |
| download | rabbitmq-server-git-0128bf7cce3568e00753f42a516646eb04399c2d.tar.gz | |
DLE -> DLX
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 143a043de3..11b40395b3 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -190,9 +190,9 @@ init_expires(Expires, State) -> ensure_expiry_timer(State#q{expires = Expires}). init_ttl(TTL, State) -> drop_expired_messages(State#q{ttl = TTL}). -init_dlx(DLE, State = #q{q = #amqqueue{name = #resource{ +init_dlx(DLX, State = #q{q = #amqqueue{name = #resource{ virtual_host = VHostPath}}}) -> - State#q{dlx = rabbit_misc:r(VHostPath, exchange, DLE)}. + State#q{dlx = rabbit_misc:r(VHostPath, exchange, DLX)}. terminate_shutdown(Fun, State) -> State1 = #q{backing_queue = BQ, backing_queue_state = BQS} = @@ -766,8 +766,8 @@ maybe_dead_letter_queue(Reason, State = #q{ maybe_dead_letter_queue(Reason, State#q{backing_queue_state = BQS1}) end. -dead_letter_msg(Msg, Reason, State = #q{dlx = DLE}) -> - Exchange = rabbit_exchange:lookup_or_die(DLE), +dead_letter_msg(Msg, Reason, State = #q{dlx = DLX}) -> + Exchange = rabbit_exchange:lookup_or_die(DLX), rabbit_exchange:publish( Exchange, |