Got rid of compiler warnings
This commit is contained in:
		
							parent
							
								
									61f1313f66
								
							
						
					
					
						commit
						612ae4248f
					
				|  | @ -265,11 +265,11 @@ init([InitialState]) -> | |||
| handle_call({call, Method}, From, State = #channel_state{closing = false}) -> | ||||
|     rpc_top_half(Method, From, State); | ||||
| 
 | ||||
| handle_call({call, Method, Content}, From, | ||||
| handle_call({call, _Method, _Content}, _From, | ||||
|             State = #channel_state{flow_control = true}) -> | ||||
|     {reply, blocked, State}; | ||||
| 
 | ||||
| handle_call({call, Method, Content}, From, | ||||
| handle_call({call, Method, Content}, _From, | ||||
|             State = #channel_state{writer_pid = Writer, do3 = Do3}) -> | ||||
|     Do3(Writer, Method, Content), | ||||
|     {reply, ok, State}; | ||||
|  |  | |||
|  | @ -300,7 +300,7 @@ cf_consumer_loop(Channel, Tag) -> | |||
|     receive | ||||
|         #'basic.consume_ok'{} -> cf_consumer_loop(Channel, Tag); | ||||
|         #'basic.cancel_ok'{} -> ok; | ||||
|         {#'basic.deliver'{delivery_tag = DeliveryTag}, Content} -> | ||||
|         {#'basic.deliver'{delivery_tag = DeliveryTag}, _Content} -> | ||||
|              lib_amqp:ack(Channel, DeliveryTag), | ||||
|              cf_consumer_loop(Channel, Tag); | ||||
|         stop -> | ||||
|  |  | |||
		Loading…
	
		Reference in New Issue