5
5
import no .nav .dolly .bestilling .ConsumerStatus ;
6
6
import no .nav .dolly .bestilling .tpsmessagingservice .command .EgenansattDeleteCommand ;
7
7
import no .nav .dolly .bestilling .tpsmessagingservice .command .EgenansattPostCommand ;
8
- import no .nav .dolly .bestilling .tpsmessagingservice .command .PersonGetCommand ;
8
+ import no .nav .dolly .bestilling .tpsmessagingservice .command .PersonHentCommand ;
9
9
import no .nav .dolly .bestilling .tpsmessagingservice .command .TpsMessagingPostCommand ;
10
10
import no .nav .dolly .config .Consumers ;
11
11
import no .nav .dolly .metrics .Timed ;
@@ -52,7 +52,7 @@ public TpsMessagingConsumer(
52
52
.build ();
53
53
}
54
54
55
- @ Timed (name = "providers" , tags = {"operation" , "tps_messaging_createUtenlandskBankkonto" })
55
+ @ Timed (name = "providers" , tags = { "operation" , "tps_messaging_createUtenlandskBankkonto" })
56
56
public Flux <TpsMeldingResponseDTO > sendUtenlandskBankkontoRequest (String ident , List <String > miljoer ,
57
57
BankkontonrUtlandDTO body ) {
58
58
@@ -61,42 +61,42 @@ public Flux<TpsMeldingResponseDTO> sendUtenlandskBankkontoRequest(String ident,
61
61
new TpsMessagingPostCommand (webClient , ident , miljoer , body , UTENLANDSK_BANKKONTO_URL , token .getTokenValue ()).call ());
62
62
}
63
63
64
- @ Timed (name = "providers" , tags = {"operation" , "tps_messaging_createNorskBankkonto" })
64
+ @ Timed (name = "providers" , tags = { "operation" , "tps_messaging_createNorskBankkonto" })
65
65
public Flux <TpsMeldingResponseDTO > sendNorskBankkontoRequest (String ident , List <String > miljoer , BankkontonrNorskDTO body ) {
66
66
67
67
return tokenService .exchange (serverProperties )
68
68
.flatMapMany (token ->
69
69
new TpsMessagingPostCommand (webClient , ident , miljoer , body , NORSK_BANKKONTO_URL , token .getTokenValue ()).call ());
70
70
}
71
71
72
- @ Timed (name = "providers" , tags = {"operation" , "tps_messaging_createSkjerming" })
72
+ @ Timed (name = "providers" , tags = { "operation" , "tps_messaging_createSkjerming" })
73
73
public Flux <TpsMeldingResponseDTO > sendEgenansattRequest (String ident , List <String > miljoer , LocalDate fraOgMed ) {
74
74
75
75
return tokenService .exchange (serverProperties )
76
76
.flatMapMany (token ->
77
77
new EgenansattPostCommand (webClient , ident , miljoer , fraOgMed , token .getTokenValue ()).call ());
78
78
}
79
79
80
- @ Timed (name = "providers" , tags = {"operation" , "tps_messaging_deleteSkjerming" })
80
+ @ Timed (name = "providers" , tags = { "operation" , "tps_messaging_deleteSkjerming" })
81
81
public Flux <TpsMeldingResponseDTO > deleteEgenansattRequest (String ident , List <String > miljoer ) {
82
82
83
83
return tokenService .exchange (serverProperties )
84
84
.flatMapMany (token -> new EgenansattDeleteCommand (webClient , ident , miljoer , token .getTokenValue ()).call ());
85
85
}
86
86
87
- @ Timed (name = "providers" , tags = {"operation" , "tps_messaging_createSpraakkode" })
87
+ @ Timed (name = "providers" , tags = { "operation" , "tps_messaging_createSpraakkode" })
88
88
public Flux <TpsMeldingResponseDTO > sendSpraakkodeRequest (String ident , List <String > miljoer , SpraakDTO body ) {
89
89
90
90
return tokenService .exchange (serverProperties )
91
91
.flatMapMany (token ->
92
92
new TpsMessagingPostCommand (webClient , ident , miljoer , body , SPRAAKKODE_URL , token .getTokenValue ()).call ());
93
93
}
94
94
95
- @ Timed (name = "providers" , tags = {"operation" , "tps_messaging_getPerson" })
95
+ @ Timed (name = "providers" , tags = { "operation" , "tps_messaging_getPerson" })
96
96
public Flux <PersonMiljoeDTO > getPerson (String ident , List <String > miljoer ) {
97
97
98
98
return tokenService .exchange (serverProperties )
99
- .flatMapMany (token -> new PersonGetCommand (webClient , ident , miljoer , token .getTokenValue ()).call ());
99
+ .flatMapMany (token -> new PersonHentCommand (webClient , ident , miljoer , token .getTokenValue ()).call ());
100
100
}
101
101
102
102
@ Override
0 commit comments