@@ -131,9 +131,6 @@ handle_cast(client_timeout, State) ->
131131handle_cast (Msg , State ) ->
132132 {stop , {stomp_unexpected_cast , Msg }, State }.
133133
134-
135-
136-
137134handle_info (connection_created , State ) ->
138135 Infos = infos (? INFO_ITEMS ++ ? OTHER_METRICS , State ),
139136 rabbit_core_metrics :connection_created (self (), Infos ),
@@ -194,25 +191,6 @@ handle_info(login_timeout, State) ->
194191
195192% %----------------------------------------------------------------------------
196193
197- handle_info (# 'basic.consume_ok' {}, State ) ->
198- {noreply , State , hibernate };
199- handle_info (# 'basic.cancel_ok' {}, State ) ->
200- {noreply , State , hibernate };
201- handle_info (# 'basic.ack' {delivery_tag = Tag , multiple = IsMulti }, State ) ->
202- ProcState = processor_state (State ),
203- NewProcState = rabbit_stomp_processor :flush_pending_receipts (Tag ,
204- IsMulti ,
205- ProcState ),
206- {noreply , processor_state (NewProcState , State ), hibernate };
207- handle_info (# 'basic.cancel' {consumer_tag = CTag }, State ) ->
208- ProcState = processor_state (State ),
209- case rabbit_stomp_processor :cancel_consumer (CTag , ProcState ) of
210- {ok , NewProcState } ->
211- {noreply , processor_state (NewProcState , State ), hibernate };
212- {stop , Reason , NewProcState } ->
213- {stop , Reason , processor_state (NewProcState , State )}
214- end ;
215-
216194handle_info ({start_heartbeats , {0 , 0 }}, State ) ->
217195 {noreply , State # reader_state {timeout_sec = {0 , 0 }}};
218196
0 commit comments