ex_nsq

v1.1.0

ex_nsq v1.1.0 NSQ.Connection.MessageHandling

Link to this section Summary

Functions

handle_nsq_message(arg, state)
recv_nsq_messages(conn_state, conn)

This is the recv loop that we kick off in a separate process immediately after the handshake. We send each incoming NSQ message as an erlang message back to the connection for handling

update_conn_stats_on_message_done(state, ret_val)

Link to this section Functions

Link to this function handle_nsq_message(arg, state)
Link to this function recv_nsq_messages(conn_state, conn)

This is the recv loop that we kick off in a separate process immediately after the handshake. We send each incoming NSQ message as an erlang message back to the connection for handling.

Link to this function update_conn_stats_on_message_done(state, ret_val) 
update_conn_stats_on_message_done(NSQ.Connection.state, any) :: any