mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove remaining kotlin code

Browse Source
This commit is contained in:
Loredana Crusoveanu
2020-11-25 11:52:43 +02:00
parent 12ab97f7d6
commit 7947131504
30 changed files with 0 additions and 954 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-5-data-reactive/src/main/kotlin/com/baeldung/Application.kt
View File

@@ -1,12 +0,0 @@
package com.baeldung
import org.springframework.boot.SpringApplication
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.autoconfigure.data.mongo.MongoReactiveDataAutoConfiguration
@SpringBootApplication(exclude = arrayOf(MongoReactiveDataAutoConfiguration::class))
class Application
fun main(args: Array<String>) {
SpringApplication.run(Application::class.java, *args)
}

6
spring-5-data-reactive/src/main/kotlin/com/baeldung/Event.kt
View File

@@ -1,6 +0,0 @@
package com.baeldung
import org.springframework.data.mongodb.core.mapping.Document
@Document
data class Event(val id: String, val name: String)

6
spring-5-data-reactive/src/main/kotlin/com/baeldung/EventRepository.kt
View File

@@ -1,6 +0,0 @@
package com.baeldung
import org.springframework.data.mongodb.core.mapping.Document
import org.springframework.data.mongodb.repository.ReactiveMongoRepository
interface EventRepository : ReactiveMongoRepository<Event, String>

25
spring-5-data-reactive/src/main/kotlin/com/baeldung/MongoConfig.kt
View File

@@ -1,25 +0,0 @@
package com.baeldung
import com.mongodb.reactivestreams.client.MongoClient
import com.mongodb.reactivestreams.client.MongoClients
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguration
import org.springframework.data.mongodb.core.ReactiveMongoTemplate
import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories
@Configuration
@EnableReactiveMongoRepositories(basePackageClasses = arrayOf(EventRepository::class))
class MongoConfig : AbstractReactiveMongoConfiguration() {
override fun reactiveMongoClient(): MongoClient = mongoClient()
@Bean
fun mongoClient(): MongoClient = MongoClients.create()
override fun getDatabaseName(): String = "mongoDatabase"
@Bean
override fun reactiveMongoTemplate(): ReactiveMongoTemplate = ReactiveMongoTemplate(mongoClient(), databaseName)
}

16
spring-5-data-reactive/src/main/kotlin/com/baeldung/SendEmitter.kt
View File

@@ -1,16 +0,0 @@
package com.baeldung
import org.springframework.http.MediaType
import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.RequestParam
import org.springframework.web.bind.annotation.RestController
import java.util.*
@RestController
class SendEmitter(val eventRepository: EventRepository) {
@GetMapping(value = "/save", produces = arrayOf(MediaType.TEXT_EVENT_STREAM_VALUE))
fun executeExample(@RequestParam("eventName") eventName: String) =
eventRepository.save(Event(UUID.randomUUID().toString(), eventName)).flux()
}

39
spring-5-data-reactive/src/main/resources/static/index.html
View File

@@ -1,39 +0,0 @@
<html>
<body>
<!-- Save new event -->
<form method="get" action="/save">
<input type="text" name="eventName">
<button type="submit">Save new event</button>
</form>
<!-- Receive saved event -->
<div id="content"></div>
<script>
let source = new EventSource("save");
source.addEventListener('message', function (e) {
console.log('New message is received');
const index = JSON.parse(e.data);
const content = `New event added: ${index.name}<br>`;
document.getElementById("content").innerHTML += content;
}, false);
source.addEventListener('open', function(e) {
console.log('The connection has been opened');
}, false);
source.addEventListener('error', function(e) {
if (e.readyState == EventSource.CLOSED){
console.log('The connection has been closed');
}
}, false);
</script>
</body>
<html>