Skip to content

Commit 3bb55c6

Browse files
authored
Better naming for logs (#199)
1 parent 9c31483 commit 3bb55c6

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/amqproxy/channel_pool.cr

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ module AMQProxy
3939
upstream = Upstream.new(@host, @port, @tls_ctx, @credentials)
4040
Log.info { "Adding upstream connection" }
4141
@upstreams.unshift upstream
42-
spawn do
42+
spawn(name: "Upstream#read_loop") do
4343
begin
4444
upstream.read_loop
4545
ensure

src/amqproxy/client.cr

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ module AMQProxy
5555

5656
# frames from enduser
5757
def read_loop(channel_pool, socket = @socket) # ameba:disable Metrics/CyclomaticComplexity
58-
Log.context.set(remote_address: socket.remote_address.to_s)
58+
Log.context.set(client: socket.remote_address.to_s)
5959
Log.debug { "Connected" }
6060
i = 0u64
6161
socket.read_timeout = (@heartbeat / 2).ceil.seconds if @heartbeat > 0

src/amqproxy/upstream.cr

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ module AMQProxy
6666

6767
# Frames from upstream (to client)
6868
def read_loop(socket = @socket) # ameba:disable Metrics/CyclomaticComplexity
69-
Log.context.set(remote_address: @remote_address)
69+
Log.context.set(upstream: @remote_address)
7070
i = 0u64
7171
loop do
7272
case frame = AMQ::Protocol::Frame.from_io(socket, IO::ByteFormat::NetworkEndian)

0 commit comments

Comments
 (0)