Skip to content

Commit 4e5b2ca

Browse files
authored
Update AMQPDestination.java
Fixed whitespaces
1 parent 91d189e commit 4e5b2ca

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

src/main/java/org/mule/extension/jsonlogger/internal/destinations/AMQPDestination.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -69,11 +69,11 @@ public ArrayList<String> getSupportedCategories() {
6969
@Override
7070
public void sendToExternalDestination(String finalLog) {
7171
try {
72-
Consumer<OperationParameterizer> parameters = operationParameterizer ->
73-
operationParameterizer.withConfigRef(this.amqpConfigurationRef)
74-
.withParameter("exchangeName", this.exchangeDestination)
75-
.withParameter("body", new TypedValue<>(finalLog, JSON_STRING))
76-
.withParameter("properties", new AmqpProperties());
72+
Consumer<OperationParameterizer> parameters = operationParameterizer ->
73+
operationParameterizer.withConfigRef(this.amqpConfigurationRef)
74+
.withParameter("exchangeName", this.exchangeDestination)
75+
.withParameter("body", new TypedValue<>(finalLog, JSON_STRING))
76+
.withParameter("properties", new AmqpProperties());
7777
extensionsClient.execute("AMQP", "publish", parameters);
7878
} catch (Exception e) {
7979
LOGGER.error("Error: " + e.getMessage());

0 commit comments

Comments
 (0)