- public void notifyTypeRegistered(InfoType type, InfoTypeSubscriptions.SubscriptionInfo subscriptionInfo) {
- ConsumerTypeRegistrationInfo info = new ConsumerTypeRegistrationInfo(type.getJobDataSchema(),
- ConsumerTypeRegistrationInfo.ConsumerTypeStatusValues.REGISTERED, type.getId());
- String body = gson.toJson(info);
-
- post(subscriptionInfo.getCallbackUrl(), body);
-
+ public Mono<String> notifyTypeRegistered(InfoType type, InfoTypeSubscriptions.SubscriptionInfo subscriptionInfo) {
+ String body = body(type, ConsumerTypeRegistrationInfo.ConsumerTypeStatusValues.REGISTERED);
+ return restClient.post(subscriptionInfo.getCallbackUrl(), body);