@@ -64,17 +64,19 @@ public IotJobsClient(MqttConnection connection) {
6464 this .connection = connection ;
6565 }
6666
67- private Gson getGson () {
67+ private Gson getGson () {
6868 GsonBuilder gson = new GsonBuilder ();
6969 gson .registerTypeAdapter (Timestamp .class , new Timestamp .Serializer ());
7070 gson .registerTypeAdapter (Timestamp .class , new Timestamp .Deserializer ());
7171 addTypeAdapters (gson );
7272 return gson .create ();
7373 }
74+
7475 private void addTypeAdapters (GsonBuilder gson ) {
75- gson .registerTypeAdapter (JobStatus .class , new EnumSerializer <JobStatus >());
7676 gson .registerTypeAdapter (RejectedErrorCode .class , new EnumSerializer <RejectedErrorCode >());
77+ gson .registerTypeAdapter (JobStatus .class , new EnumSerializer <JobStatus >());
7778 }
79+
7880 public CompletableFuture <Integer > SubscribeToJobExecutionsChangedEvents (
7981 JobExecutionsChangedSubscriptionRequest request ,
8082 QualityOfService qos ,
@@ -107,6 +109,7 @@ public CompletableFuture<Integer> SubscribeToJobExecutionsChangedEvents(
107109 Consumer <JobExecutionsChangedEvent > handler ) {
108110 return SubscribeToJobExecutionsChangedEvents (request , qos , handler , null );
109111 }
112+
110113 public CompletableFuture <Integer > SubscribeToStartNextPendingJobExecutionAccepted (
111114 StartNextPendingJobExecutionSubscriptionRequest request ,
112115 QualityOfService qos ,
@@ -139,6 +142,7 @@ public CompletableFuture<Integer> SubscribeToStartNextPendingJobExecutionAccepte
139142 Consumer <StartNextJobExecutionResponse > handler ) {
140143 return SubscribeToStartNextPendingJobExecutionAccepted (request , qos , handler , null );
141144 }
145+
142146 public CompletableFuture <Integer > SubscribeToDescribeJobExecutionRejected (
143147 DescribeJobExecutionSubscriptionRequest request ,
144148 QualityOfService qos ,
@@ -177,6 +181,7 @@ public CompletableFuture<Integer> SubscribeToDescribeJobExecutionRejected(
177181 Consumer <RejectedError > handler ) {
178182 return SubscribeToDescribeJobExecutionRejected (request , qos , handler , null );
179183 }
184+
180185 public CompletableFuture <Integer > SubscribeToNextJobExecutionChangedEvents (
181186 NextJobExecutionChangedSubscriptionRequest request ,
182187 QualityOfService qos ,
@@ -209,6 +214,7 @@ public CompletableFuture<Integer> SubscribeToNextJobExecutionChangedEvents(
209214 Consumer <NextJobExecutionChangedEvent > handler ) {
210215 return SubscribeToNextJobExecutionChangedEvents (request , qos , handler , null );
211216 }
217+
212218 public CompletableFuture <Integer > SubscribeToUpdateJobExecutionRejected (
213219 UpdateJobExecutionSubscriptionRequest request ,
214220 QualityOfService qos ,
@@ -247,6 +253,7 @@ public CompletableFuture<Integer> SubscribeToUpdateJobExecutionRejected(
247253 Consumer <RejectedError > handler ) {
248254 return SubscribeToUpdateJobExecutionRejected (request , qos , handler , null );
249255 }
256+
250257 public CompletableFuture <Integer > SubscribeToUpdateJobExecutionAccepted (
251258 UpdateJobExecutionSubscriptionRequest request ,
252259 QualityOfService qos ,
@@ -285,6 +292,7 @@ public CompletableFuture<Integer> SubscribeToUpdateJobExecutionAccepted(
285292 Consumer <UpdateJobExecutionResponse > handler ) {
286293 return SubscribeToUpdateJobExecutionAccepted (request , qos , handler , null );
287294 }
295+
288296 public CompletableFuture <Integer > PublishUpdateJobExecution (
289297 UpdateJobExecutionRequest request ,
290298 QualityOfService qos ) {
@@ -307,6 +315,7 @@ public CompletableFuture<Integer> PublishUpdateJobExecution(
307315 MqttMessage message = new MqttMessage (topic , payload );
308316 return connection .publish (message , qos , false );
309317 }
318+
310319 public CompletableFuture <Integer > SubscribeToDescribeJobExecutionAccepted (
311320 DescribeJobExecutionSubscriptionRequest request ,
312321 QualityOfService qos ,
@@ -345,6 +354,7 @@ public CompletableFuture<Integer> SubscribeToDescribeJobExecutionAccepted(
345354 Consumer <DescribeJobExecutionResponse > handler ) {
346355 return SubscribeToDescribeJobExecutionAccepted (request , qos , handler , null );
347356 }
357+
348358 public CompletableFuture <Integer > PublishGetPendingJobExecutions (
349359 GetPendingJobExecutionsRequest request ,
350360 QualityOfService qos ) {
@@ -361,6 +371,7 @@ public CompletableFuture<Integer> PublishGetPendingJobExecutions(
361371 MqttMessage message = new MqttMessage (topic , payload );
362372 return connection .publish (message , qos , false );
363373 }
374+
364375 public CompletableFuture <Integer > SubscribeToGetPendingJobExecutionsAccepted (
365376 GetPendingJobExecutionsSubscriptionRequest request ,
366377 QualityOfService qos ,
@@ -393,6 +404,7 @@ public CompletableFuture<Integer> SubscribeToGetPendingJobExecutionsAccepted(
393404 Consumer <GetPendingJobExecutionsResponse > handler ) {
394405 return SubscribeToGetPendingJobExecutionsAccepted (request , qos , handler , null );
395406 }
407+
396408 public CompletableFuture <Integer > SubscribeToStartNextPendingJobExecutionRejected (
397409 StartNextPendingJobExecutionSubscriptionRequest request ,
398410 QualityOfService qos ,
@@ -425,6 +437,7 @@ public CompletableFuture<Integer> SubscribeToStartNextPendingJobExecutionRejecte
425437 Consumer <RejectedError > handler ) {
426438 return SubscribeToStartNextPendingJobExecutionRejected (request , qos , handler , null );
427439 }
440+
428441 public CompletableFuture <Integer > SubscribeToGetPendingJobExecutionsRejected (
429442 GetPendingJobExecutionsSubscriptionRequest request ,
430443 QualityOfService qos ,
@@ -457,6 +470,7 @@ public CompletableFuture<Integer> SubscribeToGetPendingJobExecutionsRejected(
457470 Consumer <RejectedError > handler ) {
458471 return SubscribeToGetPendingJobExecutionsRejected (request , qos , handler , null );
459472 }
473+
460474 public CompletableFuture <Integer > PublishStartNextPendingJobExecution (
461475 StartNextPendingJobExecutionRequest request ,
462476 QualityOfService qos ) {
@@ -473,6 +487,7 @@ public CompletableFuture<Integer> PublishStartNextPendingJobExecution(
473487 MqttMessage message = new MqttMessage (topic , payload );
474488 return connection .publish (message , qos , false );
475489 }
490+
476491 public CompletableFuture <Integer > PublishDescribeJobExecution (
477492 DescribeJobExecutionRequest request ,
478493 QualityOfService qos ) {
@@ -495,4 +510,5 @@ public CompletableFuture<Integer> PublishDescribeJobExecution(
495510 MqttMessage message = new MqttMessage (topic , payload );
496511 return connection .publish (message , qos , false );
497512 }
513+
498514}
0 commit comments