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 28
28
<project .build.sourceEncoding>UTF-8</project .build.sourceEncoding>
29
29
<maven .compiler.source>1.7</maven .compiler.source>
30
30
<maven .compiler.target>1.7</maven .compiler.target>
31
- <spring .version>5.2.6.RELEASE</spring .version>
32
31
<log4j .version>2.13.2</log4j .version>
33
32
<gson .version>2.8.6</gson .version>
34
33
</properties >
62
61
<scope >provided</scope >
63
62
</dependency >
64
63
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
-
79
64
<dependency >
80
65
<groupId >org.apache.logging.log4j</groupId >
81
66
<artifactId >log4j-api</artifactId >
Original file line number Diff line number Diff line change 13
13
import static java .lang .System .getenv ;
14
14
import static java .util .Optional .ofNullable ;
15
15
16
+ /**
17
+ * AWS SQS client for publishing messages to SQS queues
18
+ */
16
19
@ Slf4j
17
20
public class SQSClient
18
21
{
19
22
private static final String QUEUE_NAME_ENV = "AAL_QUEUE_NAME" ;
20
23
private static final String QUEUE_NAME_SYS_PROP = "all.queue_name" ;
21
24
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 " ;
24
27
25
28
private final Gson gson ;
26
29
private final String queueUrl ;
@@ -40,6 +43,8 @@ public SQSClient()
40
43
*/
41
44
public void publish (ApiAccessLog apiAccessLog )
42
45
{
46
+ apiAccessLog .setClientId (getClientId ());
47
+
43
48
SendMessageRequest send_msg_request = new SendMessageRequest ()
44
49
.withQueueUrl (queueUrl )
45
50
.withMessageBody (gson .toJson (apiAccessLog ));
Original file line number Diff line number Diff line change 2
2
3
3
import lombok .Builder ;
4
4
import lombok .Getter ;
5
+ import lombok .Setter ;
5
6
import lombok .ToString ;
6
7
8
+ @ Setter
7
9
@ Getter
8
10
@ Builder
9
11
@ ToString
You can’t perform that action at this time.
0 commit comments