Skip to content

Commit c2abd6c

Browse files
committed
docs: fix rabbitmq docs
1 parent a1408ca commit c2abd6c

6 files changed

+17
-17
lines changed

docs/docs/reactive-commons/2-sending-a-domain-event.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ For example:
4040
@EnableDomainEventBus
4141
public class ReactiveEventsGateway {
4242
public static final String SOME_EVENT_NAME = "some.event.name";
43-
private final DomainEventBus domainEventBus; // Auto injectec bean created by the @EnableDomainEventBus annotation
43+
private final DomainEventBus domainEventBus; // Auto injected bean created by the @EnableDomainEventBus annotation
4444

4545
public Mono<Void> emit(Object event) {
4646
return Mono.from(domainEventBus.emit(new DomainEvent<>(SOME_EVENT_NAME, UUID.randomUUID().toString(), event)));

docs/docs/reactive-commons/4-making-an-async-query.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ For example:
5252
public class ReactiveDirectAsyncGateway {
5353
public static final String TARGET_NAME = "other-app";// refers to remote spring.application.name property
5454
public static final String SOME_QUERY_NAME = "some.query.name";
55-
private final DirectAsyncGateway gateway; // Auto injectec bean created by the @EnableDirectAsyncGateway annotation
55+
private final DirectAsyncGateway gateway; // Auto injected bean created by the @EnableDirectAsyncGateway annotation
5656

5757
public Mono<Object /*change for proper model*/> requestForRemoteData(Object query/*change for proper model*/) {
5858
return gateway.requestReply(new AsyncQuery<>(SOME_QUERY_NAME, query), TARGET_NAME, Object.class/*change for proper model*/);

docs/docs/reactive-commons/8-serving-async-queries.md

+3-3
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ As the model of queries is direct, a consumer always can send queries to the ser
3838

3939
### Wildcards
4040

41-
You may need to handle variable querie names that have the same structure, in that case you can specfy a pattern with '*' wildcard, for example:
41+
You may need to handle variable queries names that have the same structure, in that case you can specfy a pattern with '*' wildcard, for example:
4242

4343
```java
4444
@Configuration
@@ -60,7 +60,7 @@ There is a concept introduced in queries that cannot be resolved locally and may
6060

6161
- A consumer application called APP1 make an async query to an application called APP2 (with horizontal scaling).
6262
- an instance A of the APP2 receives the query and stores a reference to respond later.
63-
- When response is fullfilled, an external source makes an HTTPS Call to an endpoint of an instance of APP2 but it can be diferent to the instance A, for example can be the instance B.
63+
- When response is fulfilled, an external source makes an HTTPS Call to an endpoint of an instance of APP2 but it can be diferent to the instance A, for example can be the instance B.
6464
- The instance B of APP2 queries for the saved reference and uses DirectAsyncGateway to answer the pending query to the application APP1.
6565

6666
This scenario can be resolved with ReactiveCommons by using the next resources:
@@ -106,7 +106,7 @@ When some external source notifies our APP2 instance with the answer we should f
106106
@RequiredArgsConstructor
107107
@EnableDirectAsyncGateway
108108
public class ReactiveDirectAsyncGateway {
109-
private final DirectAsyncGateway gateway; // Auto injectec bean created by the @EnableDirectAsyncGateway annotation
109+
private final DirectAsyncGateway gateway; // Auto injected bean created by the @EnableDirectAsyncGateway annotation
110110

111111
public Mono<Void> replyDelegate(String correlationId, Object response/*change for proper model*/) {
112112
return getReference(correlationId)

docs/docs/reactive-commons/9-configuration-properties.md

+3-3
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ app:
6262
virtual-host: /accounts
6363
```
6464
65-
You can override this settings programmatically through a `AsyncPropsDomainProperties` bean.
65+
You can override this settings programmatically through a `AsyncRabbitPropsDomainProperties` bean.
6666

6767
```java
6868
package sample;
@@ -78,7 +78,7 @@ public class MyDomainConfig {
7878
7979
@Bean
8080
@Primary
81-
public AsyncPropsDomainProperties customDomainProperties() {
81+
public AsyncRabbitPropsDomainProperties customDomainProperties() {
8282
RabbitProperties propertiesApp = new RabbitProperties();
8383
propertiesApp.setHost("localhost");
8484
propertiesApp.setPort(5672);
@@ -93,7 +93,7 @@ public class MyDomainConfig {
9393
propertiesAccounts.setUsername("guest");
9494
propertiesAccounts.setPassword("guest");
9595
96-
return AsyncPropsDomainProperties.builder()
96+
return AsyncRabbitPropsDomainProperties.builder()
9797
.withDomain("app", AsyncProps.builder()
9898
.connectionProperties(propertiesApp)
9999
.build())

docs/docs/scenarios/1-single-broker.md

+5-5
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ app:
6060
virtual-host: /
6161
```
6262
63-
You can override this settings programmatically through a `AsyncPropsDomainProperties` bean.
63+
You can override this settings programmatically through a `AsyncRabbitPropsDomainProperties` bean.
6464

6565
```java
6666
package sample;
@@ -76,15 +76,15 @@ public class MyDomainConfig {
7676
7777
@Bean
7878
@Primary
79-
public AsyncPropsDomainProperties customDomainProperties() {
79+
public AsyncRabbitPropsDomainProperties customDomainProperties() {
8080
RabbitProperties propertiesApp = new RabbitProperties();
8181
propertiesApp.setHost("localhost");
8282
propertiesApp.setPort(5672);
8383
propertiesApp.setVirtualHost("/");
8484
propertiesApp.setUsername("guest");
8585
propertiesApp.setPassword("guest");
8686
87-
return AsyncPropsDomainProperties.builder()
87+
return AsyncRabbitPropsDomainProperties.builder()
8888
.withDomain("app", AsyncProps.builder()
8989
.connectionProperties(propertiesApp)
9090
.build())
@@ -93,13 +93,13 @@ public class MyDomainConfig {
9393
}
9494
```
9595

96-
Additionally, if you want to set only connection properties you can use the `AsyncPropsDomain.SecretFiller` class.
96+
Additionally, if you want to set only connection properties you can use the `AsyncPropsDomain.RabbitSecretFiller` class.
9797

9898
```java
9999
100100
@Bean
101101
@Primary
102-
public AsyncPropsDomain.SecretFiller customFiller() {
102+
public AsyncPropsDomain.RabbitSecretFiller customFiller() {
103103
return (domain, asyncProps) -> {
104104
// customize asyncProps here by domain
105105
};

docs/docs/scenarios/2-two-brokers-same-type.md

+4-4
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ public HandlerRegistry handlerRegistrySubs(UseCase useCase) {
5151

5252
```java
5353
@Service
54-
@AllArgsConstructor
54+
@RequiredArgsConstructor
5555
public class SampleRestController {
5656
private final DirectAsyncGateway directAsyncGateway;
5757

@@ -126,7 +126,7 @@ app:
126126
virtual-host: /accounts
127127
```
128128
129-
You can override this settings programmatically through a `AsyncPropsDomainProperties` bean.
129+
You can override this settings programmatically through a `AsyncRabbitPropsDomainProperties` bean.
130130

131131
```java
132132
package sample;
@@ -142,7 +142,7 @@ public class MyDomainConfig {
142142
143143
@Bean
144144
@Primary
145-
public AsyncPropsDomainProperties customDomainProperties() {
145+
public AsyncRabbitPropsDomainProperties customDomainProperties() {
146146
RabbitProperties propertiesApp = new RabbitProperties(); // this may be loaded from secrets
147147
propertiesApp.setHost("localhost");
148148
propertiesApp.setPort(5672);
@@ -157,7 +157,7 @@ public class MyDomainConfig {
157157
propertiesAccounts.setUsername("guest");
158158
propertiesAccounts.setPassword("guest");
159159
160-
return AsyncPropsDomainProperties.builder()
160+
return AsyncRabbitPropsDomainProperties.builder()
161161
.withDomain("app", AsyncProps.builder()
162162
.connectionProperties(propertiesApp)
163163
.build())

0 commit comments

Comments
 (0)