File tree Expand file tree Collapse file tree 1 file changed +2
-6
lines changed
server/src/main/kotlin/com/example/demo Expand file tree Collapse file tree 1 file changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -5,7 +5,6 @@ import org.springframework.boot.autoconfigure.SpringBootApplication
5
5
import org.springframework.boot.runApplication
6
6
import org.springframework.context.annotation.Bean
7
7
import org.springframework.data.annotation.Id
8
- import org.springframework.data.mongodb.core.CollectionOptions
9
8
import org.springframework.data.mongodb.core.ReactiveMongoTemplate
10
9
import org.springframework.data.mongodb.core.mapping.Document
11
10
import org.springframework.data.mongodb.repository.ReactiveMongoRepository
@@ -16,15 +15,12 @@ import reactor.core.publisher.Flux
16
15
import java.time.Instant
17
16
18
17
@SpringBootApplication
19
- class RSocketServerApplication {
18
+ class RSocketServerApplication {
20
19
21
20
@Bean
22
21
fun runner (template : ReactiveMongoTemplate ) = CommandLineRunner {
23
22
println (" running CommandLineRunner..." )
24
- template.executeCommand(" {\" convertToCapped\" : \" messages\" , size: 100000}" )
25
- .subscribe(::println)
26
- // template.dropCollection(Message::class.java).then().block();
27
- // template.createCollection(Message::class.java, CollectionOptions.empty().capped().size(100000L)).then().block()
23
+ template.executeCommand(" {\" convertToCapped\" : \" messages\" , size: 100000}" ).log().subscribe(::println)
28
24
}
29
25
}
30
26
You can’t perform that action at this time.
0 commit comments