Commit 93d7dfe
File tree
187 files changed
+217
-69
lines changed- api/src/main/java/com/jashmore/sqs
- argument
- aws
- decorator
- core/src
- integrationTest/java/com/jashmore/sqs
- argument
- container
- batching
- fifo
- prefetching
- decorator
- listener/concurrent
- processor
- util
- main/java/com/jashmore/sqs
- argument
- attribute
- payload
- mapper
- visibility
- broker
- concurrent
- grouping
- container
- batching
- fifo
- prefetching
- decorator
- processor
- resolver/batching
- retriever
- batching
- prefetch
- test/java/com/jashmore/sqs
- argument
- attribute
- messageid
- message
- payload
- mapper
- visibility
- broker
- concurrent
- grouping
- container
- decorator
- processor
- resolver/batching
- retriever
- batching
- prefetch
- doc/how-to-guides
- core
- spring
- examples
- auto-visibility-extender-example/src/main/java/com/jashmore/sqs/examples
- aws-xray-spring-example/src/main/java/com/jashmore/sqs/examples
- core-example/src/main/java/com/jashmore/sqs/examples
- fifo-example/src/main/java/com/jashmore/sqs/examples
- spring-cloud-schema-registry-example
- spring-cloud-schema-registry-producer-two/src/main/java/com/jashmore/sqs/examples/schemaregistry
- spring-cloud-schema-registry-producer/src/main/java/com/jashmore/sqs/examples/schemaregistry
- spring-integration-test-example/src
- main/java/com/jashmore/sqs/examples/integrationtests
- test/java/com/jashmore/sqs/examples/integrationtests
- spring-multiple-aws-account-example/src/main/java/com/jashmore/sqs/examples
- spring-sleuth-example/src/main/java/com/jashmore/sqs/examples/sleuth
- spring-starter-example/src/main/java/com/jashmore/sqs/examples
- spring-starter-minimal-example/src/main/java/com/jashmore/sqs/examples
- sqs-listener-library-comparison/src/main/java/com/jashmore/sqs/examples
- latency
- extensions
- aws-xray-extension
- core/src
- main/java/com/jashmore/sqs/extensions/xray
- client
- decorator
- test/java/com/jashmore/sqs/extensions/xray
- client
- decorator
- spring-boot/src
- integrationTest/java/com/jashmore/sqs/extensions/xray
- test/java/com/jashmore/sqs/extensions/xray/decorator
- brave-extension
- core/src
- main/java/com/jashmore/sqs/extensions/brave/decorator
- test/java/com/jashmore/sqs/extensions/brave/decorator
- spring-boot/src/test/java/com/jashmore/sqs/extensions/brave
- spring-cloud-schema-registry-extension
- avro-spring-cloud-schema-registry-extension/src
- main/java/com/jashmore/sqs/extensions/registry/avro
- test/java
- com/jashmore/sqs/extensions/registry/avro
- it/com/jashmore/sqs/extensions/registry/avro
- in-memory-spring-cloud-schema-registry/src/main/java/com/jashmore/sqs/extensions/registry
- spring-cloud-schema-registry-extension-api/src
- main/java/com/jashmore/sqs/extensions/registry
- test/java/com/jashmore/sqs/extensions/registry
- spring
- spring-core/src
- integrationTest/java/com/jashmore/sqs
- argument
- client
- container
- basic
- prefetch
- decorator/visibilityextender
- proxy
- queue
- service
- main/java/com/jashmore/sqs/spring
- client
- container
- basic
- fifo
- prefetch
- decorator/visibilityextender
- processor
- queue
- test/java/com/jashmore/sqs/spring
- client
- config
- container
- basic
- fifo
- prefetch
- decorator/visibilityextender
- processor
- queue
- spring-starter/src/test/java/com/jashmore/sqs
- util
- avro-spring-cloud-schema-registry-sqs-client/src/main/java/com/jashmore/sqs/registry
- common-utils/src
- main/java/com/jashmore/sqs/util
- thread
- test/java/com/jashmore/sqs/util
- elasticmq-sqs-client/src/main/java/com/jashmore/sqs/elasticmq
- local-sqs-async-client/src
- main/java/com/jashmore/sqs/util
- test/java/com/jashmore/sqs/util
- proxy-method-interceptor/src/main/java/com/jashmore/sqs/util
- sqs-brave-tracing/src
- integrationTest/java/com/jashmore/sqs/brave
- main/java/com/jashmore/sqs/brave
- test/java/com/jashmore/sqs/brave
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
187 files changed
+217
-69
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
338 | 338 | | |
339 | 339 | | |
340 | 340 | | |
| 341 | + | |
341 | 342 | | |
342 | 343 | | |
343 | 344 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
11 | 11 | | |
12 | 12 | | |
13 | 13 | | |
| 14 | + | |
14 | 15 | | |
15 | 16 | | |
16 | 17 | | |
| |||
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
10 | 10 | | |
11 | 11 | | |
12 | 12 | | |
| 13 | + | |
13 | 14 | | |
14 | 15 | | |
15 | 16 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| 7 | + | |
7 | 8 | | |
8 | 9 | | |
9 | 10 | | |
| |||
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
10 | 10 | | |
11 | 11 | | |
12 | 12 | | |
| 13 | + | |
13 | 14 | | |
14 | 15 | | |
15 | 16 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
| 34 | + | |
34 | 35 | | |
35 | 36 | | |
36 | 37 | | |
| |||
100 | 101 | | |
101 | 102 | | |
102 | 103 | | |
| 104 | + | |
103 | 105 | | |
104 | 106 | | |
105 | 107 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
| 39 | + | |
39 | 40 | | |
40 | 41 | | |
41 | 42 | | |
| |||
121 | 122 | | |
122 | 123 | | |
123 | 124 | | |
| 125 | + | |
124 | 126 | | |
125 | 127 | | |
126 | 128 | | |
| |||
core/src/integrationTest/java/com/jashmore/sqs/argument/MessageSystemAttributeIntegrationTest.java
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
| 42 | + | |
42 | 43 | | |
43 | 44 | | |
44 | 45 | | |
| |||
108 | 109 | | |
109 | 110 | | |
110 | 111 | | |
| 112 | + | |
111 | 113 | | |
112 | 114 | | |
113 | 115 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
| 40 | + | |
40 | 41 | | |
41 | 42 | | |
42 | 43 | | |
| |||
115 | 116 | | |
116 | 117 | | |
117 | 118 | | |
| 119 | + | |
118 | 120 | | |
119 | 121 | | |
120 | 122 | | |
| |||
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
| 16 | + | |
16 | 17 | | |
17 | 18 | | |
18 | 19 | | |
| |||
0 commit comments