Skip to content

Commit

Permalink
Update references of LaunchpadLogRecord to LogRecord
Browse files Browse the repository at this point in the history
  • Loading branch information
jvanecek committed Jul 26, 2024
1 parent cbb0331 commit d75c19a
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions source/Ansible-RabbitMQ/RabbitMQClient.class.st
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ RabbitMQClient >> initializeConnection [
{ #category : 'private - connecting' }
RabbitMQClient >> logFailedConnectionAttempt: attemptNumber dueTo: error [

LaunchpadLogRecord emitError: ( 'Attempt #<1p>/<2p> to connect to RabbitMQ failed: <3s>'
LogRecord emitError: ( 'Attempt #<1p>/<2p> to connect to RabbitMQ failed: <3s>'

Check warning on line 70 in source/Ansible-RabbitMQ/RabbitMQClient.class.st

View check run for this annotation

Codecov / codecov/patch

source/Ansible-RabbitMQ/RabbitMQClient.class.st#L70

Added line #L70 was not covered by tests
expandMacrosWith: attemptNumber
with: self retryCount + 1
with: error messageText )
Expand All @@ -77,7 +77,7 @@ RabbitMQClient >> logFailedConnectionAttempt: attemptNumber dueTo: error [
RabbitMQClient >> openConnection [

self withSuccessfulConnectionDo: [ :succesfulConnection |
LaunchpadLogRecord emitInfo: 'Connecting to RabbitMQ' during: [
LogRecord emitInfo: 'Connecting to RabbitMQ' during: [
self
try: [ succesfulConnection open ]
onConnectivityErrorDo: [ :attemptNumber :error |
Expand All @@ -104,11 +104,11 @@ RabbitMQClient >> start [
self openConnection.
connection
whenConnected: [
LaunchpadLogRecord emitInfo: 'Connected to RabbitMQ'.
LogRecord emitInfo: 'Connected to RabbitMQ'.
self startProcessing
]
whenNot: [ :error |
LaunchpadLogRecord emitError:
LogRecord emitError:
( 'Cannot connect to RabbitMQ, <1s>' expandMacrosWith: error messageText ).
AmqpDisconnectedError signal: error messageText
]
Expand All @@ -125,7 +125,7 @@ RabbitMQClient >> stop [

connection
whenConnected: [ connection close ]
whenNot: [ LaunchpadLogRecord emitWarning: 'RabbitMQ connection was already closed.' ]
whenNot: [ LogRecord emitWarning: 'RabbitMQ connection was already closed.' ]
]

{ #category : 'private - connecting' }
Expand All @@ -146,7 +146,7 @@ RabbitMQClient >> withSuccessfulConnectionDo: aBlock [
try: [ connection whenConnected: [ aBlock value: connection ] whenNot: [ :error | error signal ] ]
onConnectivityErrorDo: [ :attemptNumber :error |
self logFailedConnectionAttempt: attemptNumber dueTo: error.
LaunchpadLogRecord emitWarning: 'Reconnecting socket to RabbitMQ'.
LogRecord emitWarning: 'Reconnecting socket to RabbitMQ'.
connection initializeSocketConnection
]
]

0 comments on commit d75c19a

Please sign in to comment.