@@ -348,6 +348,7 @@ protected GrpcSubscriberStub(
348348 builder .add ("name" , String .valueOf (request .getName ()));
349349 return builder .build ();
350350 })
351+ .setResourceNameExtractor (request -> request .getName ())
351352 .build ();
352353 GrpcCallSettings <GetSubscriptionRequest , Subscription > getSubscriptionTransportSettings =
353354 GrpcCallSettings .<GetSubscriptionRequest , Subscription >newBuilder ()
@@ -358,6 +359,7 @@ protected GrpcSubscriberStub(
358359 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
359360 return builder .build ();
360361 })
362+ .setResourceNameExtractor (request -> request .getSubscription ())
361363 .build ();
362364 GrpcCallSettings <UpdateSubscriptionRequest , Subscription > updateSubscriptionTransportSettings =
363365 GrpcCallSettings .<UpdateSubscriptionRequest , Subscription >newBuilder ()
@@ -380,6 +382,7 @@ protected GrpcSubscriberStub(
380382 builder .add ("project" , String .valueOf (request .getProject ()));
381383 return builder .build ();
382384 })
385+ .setResourceNameExtractor (request -> request .getProject ())
383386 .build ();
384387 GrpcCallSettings <DeleteSubscriptionRequest , Empty > deleteSubscriptionTransportSettings =
385388 GrpcCallSettings .<DeleteSubscriptionRequest , Empty >newBuilder ()
@@ -390,6 +393,7 @@ protected GrpcSubscriberStub(
390393 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
391394 return builder .build ();
392395 })
396+ .setResourceNameExtractor (request -> request .getSubscription ())
393397 .build ();
394398 GrpcCallSettings <ModifyAckDeadlineRequest , Empty > modifyAckDeadlineTransportSettings =
395399 GrpcCallSettings .<ModifyAckDeadlineRequest , Empty >newBuilder ()
@@ -400,6 +404,7 @@ protected GrpcSubscriberStub(
400404 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
401405 return builder .build ();
402406 })
407+ .setResourceNameExtractor (request -> request .getSubscription ())
403408 .build ();
404409 GrpcCallSettings <AcknowledgeRequest , Empty > acknowledgeTransportSettings =
405410 GrpcCallSettings .<AcknowledgeRequest , Empty >newBuilder ()
@@ -410,6 +415,7 @@ protected GrpcSubscriberStub(
410415 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
411416 return builder .build ();
412417 })
418+ .setResourceNameExtractor (request -> request .getSubscription ())
413419 .build ();
414420 GrpcCallSettings <PullRequest , PullResponse > pullTransportSettings =
415421 GrpcCallSettings .<PullRequest , PullResponse >newBuilder ()
@@ -420,10 +426,12 @@ protected GrpcSubscriberStub(
420426 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
421427 return builder .build ();
422428 })
429+ .setResourceNameExtractor (request -> request .getSubscription ())
423430 .build ();
424431 GrpcCallSettings <StreamingPullRequest , StreamingPullResponse > streamingPullTransportSettings =
425432 GrpcCallSettings .<StreamingPullRequest , StreamingPullResponse >newBuilder ()
426433 .setMethodDescriptor (streamingPullMethodDescriptor )
434+ .setResourceNameExtractor (request -> request .getSubscription ())
427435 .build ();
428436 GrpcCallSettings <ModifyPushConfigRequest , Empty > modifyPushConfigTransportSettings =
429437 GrpcCallSettings .<ModifyPushConfigRequest , Empty >newBuilder ()
@@ -434,6 +442,7 @@ protected GrpcSubscriberStub(
434442 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
435443 return builder .build ();
436444 })
445+ .setResourceNameExtractor (request -> request .getSubscription ())
437446 .build ();
438447 GrpcCallSettings <GetSnapshotRequest , Snapshot > getSnapshotTransportSettings =
439448 GrpcCallSettings .<GetSnapshotRequest , Snapshot >newBuilder ()
@@ -444,6 +453,7 @@ protected GrpcSubscriberStub(
444453 builder .add ("snapshot" , String .valueOf (request .getSnapshot ()));
445454 return builder .build ();
446455 })
456+ .setResourceNameExtractor (request -> request .getSnapshot ())
447457 .build ();
448458 GrpcCallSettings <ListSnapshotsRequest , ListSnapshotsResponse > listSnapshotsTransportSettings =
449459 GrpcCallSettings .<ListSnapshotsRequest , ListSnapshotsResponse >newBuilder ()
@@ -454,6 +464,7 @@ protected GrpcSubscriberStub(
454464 builder .add ("project" , String .valueOf (request .getProject ()));
455465 return builder .build ();
456466 })
467+ .setResourceNameExtractor (request -> request .getProject ())
457468 .build ();
458469 GrpcCallSettings <CreateSnapshotRequest , Snapshot > createSnapshotTransportSettings =
459470 GrpcCallSettings .<CreateSnapshotRequest , Snapshot >newBuilder ()
@@ -464,6 +475,7 @@ protected GrpcSubscriberStub(
464475 builder .add ("name" , String .valueOf (request .getName ()));
465476 return builder .build ();
466477 })
478+ .setResourceNameExtractor (request -> request .getName ())
467479 .build ();
468480 GrpcCallSettings <UpdateSnapshotRequest , Snapshot > updateSnapshotTransportSettings =
469481 GrpcCallSettings .<UpdateSnapshotRequest , Snapshot >newBuilder ()
@@ -484,6 +496,7 @@ protected GrpcSubscriberStub(
484496 builder .add ("snapshot" , String .valueOf (request .getSnapshot ()));
485497 return builder .build ();
486498 })
499+ .setResourceNameExtractor (request -> request .getSnapshot ())
487500 .build ();
488501 GrpcCallSettings <SeekRequest , SeekResponse > seekTransportSettings =
489502 GrpcCallSettings .<SeekRequest , SeekResponse >newBuilder ()
@@ -494,6 +507,7 @@ protected GrpcSubscriberStub(
494507 builder .add ("subscription" , String .valueOf (request .getSubscription ()));
495508 return builder .build ();
496509 })
510+ .setResourceNameExtractor (request -> request .getSubscription ())
497511 .build ();
498512 GrpcCallSettings <SetIamPolicyRequest , Policy > setIamPolicyTransportSettings =
499513 GrpcCallSettings .<SetIamPolicyRequest , Policy >newBuilder ()
@@ -504,6 +518,7 @@ protected GrpcSubscriberStub(
504518 builder .add ("resource" , String .valueOf (request .getResource ()));
505519 return builder .build ();
506520 })
521+ .setResourceNameExtractor (request -> request .getResource ())
507522 .build ();
508523 GrpcCallSettings <GetIamPolicyRequest , Policy > getIamPolicyTransportSettings =
509524 GrpcCallSettings .<GetIamPolicyRequest , Policy >newBuilder ()
@@ -514,6 +529,7 @@ protected GrpcSubscriberStub(
514529 builder .add ("resource" , String .valueOf (request .getResource ()));
515530 return builder .build ();
516531 })
532+ .setResourceNameExtractor (request -> request .getResource ())
517533 .build ();
518534 GrpcCallSettings <TestIamPermissionsRequest , TestIamPermissionsResponse >
519535 testIamPermissionsTransportSettings =
@@ -525,6 +541,7 @@ protected GrpcSubscriberStub(
525541 builder .add ("resource" , String .valueOf (request .getResource ()));
526542 return builder .build ();
527543 })
544+ .setResourceNameExtractor (request -> request .getResource ())
528545 .build ();
529546
530547 this .createSubscriptionCallable =
0 commit comments