File tree Expand file tree Collapse file tree 3 files changed +9
-17
lines changed
src/main/java/com/actigence/aal Expand file tree Collapse file tree 3 files changed +9
-17
lines changed Original file line number Diff line number Diff line change 2828 <project .build.sourceEncoding>UTF-8</project .build.sourceEncoding>
2929 <maven .compiler.source>1.7</maven .compiler.source>
3030 <maven .compiler.target>1.7</maven .compiler.target>
31- <spring .version>5.2.6.RELEASE</spring .version>
3231 <log4j .version>2.13.2</log4j .version>
3332 <gson .version>2.8.6</gson .version>
3433 </properties >
6261 <scope >provided</scope >
6362 </dependency >
6463
65- <!-- https://mvnrepository.com/artifact/org.springframework/spring-core -->
66- <dependency >
67- <groupId >org.springframework</groupId >
68- <artifactId >spring-core</artifactId >
69- <version >${spring.version} </version >
70- </dependency >
71-
72- <!-- https://mvnrepository.com/artifact/org.springframework/spring-context -->
73- <dependency >
74- <groupId >org.springframework</groupId >
75- <artifactId >spring-context</artifactId >
76- <version >${spring.version} </version >
77- </dependency >
78-
7964 <dependency >
8065 <groupId >org.apache.logging.log4j</groupId >
8166 <artifactId >log4j-api</artifactId >
Original file line number Diff line number Diff line change 1313import static java .lang .System .getenv ;
1414import static java .util .Optional .ofNullable ;
1515
16+ /**
17+ * AWS SQS client for publishing messages to SQS queues
18+ */
1619@ Slf4j
1720public class SQSClient
1821{
1922 private static final String QUEUE_NAME_ENV = "AAL_QUEUE_NAME" ;
2023 private static final String QUEUE_NAME_SYS_PROP = "all.queue_name" ;
2124 private static final String CLIENT_ID_ENV = "AAL_CLIENT_ID" ;
22- private static final String CLIENT_ID_SYS_PROP = "all .client_id" ;
23- private static final String DEFAULT_QUEUE_NAME = "aal_api_invocation_queue " ;
25+ private static final String CLIENT_ID_SYS_PROP = "aal .client_id" ;
26+ private static final String DEFAULT_QUEUE_NAME = "aal_inbound_request_logging_queue " ;
2427
2528 private final Gson gson ;
2629 private final String queueUrl ;
@@ -40,6 +43,8 @@ public SQSClient()
4043 */
4144 public void publish (ApiAccessLog apiAccessLog )
4245 {
46+ apiAccessLog .setClientId (getClientId ());
47+
4348 SendMessageRequest send_msg_request = new SendMessageRequest ()
4449 .withQueueUrl (queueUrl )
4550 .withMessageBody (gson .toJson (apiAccessLog ));
Original file line number Diff line number Diff line change 22
33import lombok .Builder ;
44import lombok .Getter ;
5+ import lombok .Setter ;
56import lombok .ToString ;
67
8+ @ Setter
79@ Getter
810@ Builder
911@ ToString
You can’t perform that action at this time.
0 commit comments