JarCasting
Pousse-Café Spring Mongo
This storage plugin uses Spring Data MongoDB as its backend and is therefore able to store data into a MongoDB database.
EntityAttributes implementations should be annotated like Spring Data MongoDB documents (i.e. using @Document, @Id, etc.).
MongoDataAccess expects subclasses to define mongoRepository method which must return a Spring Data MongoRepository. The convertId method must be defined in order to convert an aggregate's ID into a serializable object. In order to access the MongoRepository, simply autowire it in your data access.
Here is an example of data access implementation:
public class ExampleMongoDataAccess extends MongoDataAccess<ExampleId, ExampleData, String> implements ExampleDataAccess<ProductData> {
@Override
protected String convertId(ExampleId id) {
return ...;
}
@Override
protected MongoRepository<ExampleData, String> mongoRepository() {
return repository;
}
@Autowired
private ExampleDataMongoRepository repository;
...
}
Your Spring configuration class then looks like this (do not forget to include poussecafe.spring in your package scan):
@Configuration
@ComponentScan(basePackages = { "poussecafe.spring" })
public class AppConfiguration {
@Bean
public Bundles bundles(
Messaging messaging,
SpringMongoDbStorage storage) {
MessagingAndStorage messagingAndStorage = new MessagingAndStorage(messaging, storage);
return new Bundles.Builder()
// Register your bundles here using withBundle and use messagingAndStorage
// when building them
.build();
}
}
Configure your Spring Boot Maven project
Add the following snippet to your POM:
<dependency>
<groupId>org.pousse-cafe-framework</groupId>
<artifactId>pousse-cafe-spring-pulsar</artifactId>
<version>${poussecafe.spring.pulsar.version}</version>
</dependency>
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client</artifactId>
<version>${pulsar.client.version}</version>
</dependency>
