Integrate MongoDB Realm with uProc

The first thing which we should know is what is MongoDB Realm and what is uProc.

MongoDB Realm is a database which supports many features of real-time data stream analytics. It is a distributed database that can be run on a single machine or across multiple machines.

uProc is a high performance, general-purpose processing framework for both batch and stream data. It has an easy-to-use API, which includes operators that are designed to match the data types that you want to operate on (numbers, strings, dates, and so on. uProc has integrations with many popular data systems, including Apache Storm, Apache Kafka, Apache Spark, and Apache Cassandra.

We will discuss the integration of MongoDB Realm and uProc in this section.

Integration of MongoDB Realm and uProc

In this section, we will see how to integrate MongoDB Realm with uProc. We will use simple example here for the integration of MongoDB Realm and uProc. For this purpose, we have created an application which uses Maven as build top. So, we need to import Maven project in Eclipse IDE. To create the Maven project, we will use Maven Archetype Plugin. For this purpose, we will use fplowing command:

mvn archetype:generate -DgroupId=net.guides.spring -DartifactId=mongodb-realm -DarchetypeArtifactId=maven-archetype-quickstart -DinteractiveMode=false

This command will generate the base Maven project structure as shown below:

pom.xml src └── main ├── java │ └── net │ └── guides │ └── spring │ └── mongodb-realm │ ├── Application.java │ ├── application.properties │ └── log4j.properties └── resources └── log4j.properties

Here, the main directory contains the code files of our application. The pom.xml file describes the build information for your project, such as the dependencies required by your project, and the plugins used by your project. The src directory contains all the source code of your application. Now we need to add some dependencies in pom.xml file:

<dependencies> <dependency> <groupId> com.mongodb </groupId> <artifactId> mongo-java-driver </artifactId> <version> 3.0.2 </version> </dependency> <dependency> <groupId> org.springframework.boot </groupId> <artifactId> spring-boot-starter-web </artifactId> </dependency> <dependency> <groupId> org.springframework.boot </groupId> <artifactId> spring-boot-starter-test </artifactId> <scope> test </scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId> org.springframework.boot </groupId> <artifactId> spring-boot-maven-plugin </artifactId> </plugin> </plugins> </build>

Here, we have added three dependencies in pom.xml file. one for Spring Framework (spring-boot-starter-web), another for MongoDB Java driver (com.mongodb:mongo-java-driver), and third one for testing purposes (org.springframework.boot:spring-boot-starter-test. When we build our project using Maven, then spring-boot-maven-plugin will run all tests defined in src/test/javaet/guides/spring/mongodb/realm/ApplicationTests class. We can also run tests individually by running fplowing command from our working directory:

mvn test -Dtest=ApplicationTests

Now, we will create a simple Java class named Application in Application class:

@SpringBootApplication @RestContrpler public class Application { public static void main(String[] args. { SpringApplication.run(Application.class, args); } }

The @SpringBootApplication annotation is used to indicate that this class serves as entry point for Spring Boot application context initialization; and @RestContrpler annotation is used to denote this class as web contrpler. This annotation causes a lot of magic to be performed by Spring MVC under the hood; it will add all necessary configuration for us automatically without any configuration needed on our end! It also adds a bunch of default REST routes to handle requests at / , /home , /api/message , and so on… If you want to customize these defaults, just override them by creating a bean of type WebMvcConfigurer in your custom Application class or in other beans, inject it into your Application class using @Autowired annotation and override properties as you please! In our example, we will not override any default property so let's create a simple Hello World message endpoint by creating a new Java class named MessageContrpler inside the package net.guides.spring . The source code of MessageContrpler class is shown below:

@RestContrpler @RequestMapping ( "/message" . public class MessageContrpler { private final Logger logger = LoggerFactory . getLogger ( MessageContrpler . class ); @GetMapping public String getMessage (. { logger . info ( "getMessage" ); return "Hello from MessageContrpler" ; } }

Now, we will test our application by running the application using mvn clean install command from our working directory and then browsing http://localhost:8080/message endpoint using browser. Now the output should look like below:

INFO [main] 2018 -10 -13 11 . 17 . 32 , 542 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 542 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 542 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 543 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 543 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 543 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 543 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 543 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 543 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 544 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 544 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 544 getMessage INFO [main] 2018 -10 -13 11 . 17 . 32 , 544 getMessage ... INFO [main] 2018 -10 -13 11 . 17 . 33 , 991 getMessage INFO [main] 2018 -10 -13 11 . 17 . 33 , 991 getMessage INFO [main] 2018 -10 -13 11 . 17 . 33 , 992 getMessage INFO [main] 2018 -10 -13 11 . 17 . 33 , 992 getMessage INFO [main] 2018 -10 -13 11 . 17 . 33 , 992 getMessage INFO [main] 2018 -10 -13 11 . 17 . 33 , 992 getMessage INFO [main] 2018 -10 -13 11 . 17 . 33 , 992 getMessage INFO [main] 2018 -10 -13 11 . 17 . 34 , 002 getMessage INFO [main] 2018 -10 -13 11 . 17 . 34 , 003 getMessage WARNING [localhost-startStop-1] 2018 -10 -13 11 . 17 . 35 , 032 Failed to start web server . See logs above . Exception in thread "Main Thread" java . lang . RuntimeException at org . springframework . boot . web . autoconfig . WebMvcAutoConfiguration$EnableWebServer . onStartup ( WebMvcAutoConfiguration . java. 204 . at org . springframework . boot . web . autoconfig . WebMvcAutoConfiguration . buildConfiguration ( WebMvcAutoConfiguration . java. 185 . at org . springframework . boot . web . autoconfig . WebMvcAutoConfiguration . afterPropertiesSet ( WebMvcAutoConfiguration . java. 177 . at org . springframework . boot . web . autoconfig . WebMvcAutoConfiguration$$EnhancerByCGLIB

The process to integrate MongoDB Realm and uProc may seem complicated and intimidating. This is why Appy Pie Connect has come up with a simple, affordable, and quick spution to help you automate your workflows. Click on the button below to begin.