@@ -713,6 +713,32 @@ public static class Builder {
713713 private int poolSize = Runtime .getRuntime ().availableProcessors () * 2 ;
714714 private Supplier <Tracer > tracerSupplier = () -> null ;
715715
716+ public static Builder fromCustomizableBuilder (CustomizableBuilder customizableBuilder ) {
717+ Builder builder = new Builder ();
718+
719+ builder .clientTransportFactory = customizableBuilder .clientTransportFactory ;
720+ builder .accessKey = customizableBuilder .accessKey ;
721+ builder .accessToken = customizableBuilder .accessToken ;
722+ builder .accessTokenBytes = customizableBuilder .accessTokenBytes ;
723+ builder .ackTimeoutSeconds = customizableBuilder .ackTimeoutSeconds ;
724+ builder .addressSelector = customizableBuilder .addressSelector ;
725+ builder .connectionIdSeed = customizableBuilder .connectionIdSeed ;
726+ builder .destination = customizableBuilder .destination ;
727+ builder .discoveryStrategy = customizableBuilder .discoveryStrategy ;
728+ builder .group = customizableBuilder .group ;
729+ builder .host = customizableBuilder .host ;
730+ builder .inetAddress = customizableBuilder .inetAddress ;
731+ builder .missedAcks = customizableBuilder .missedAcks ;
732+ builder .poolSize = customizableBuilder .poolSize ;
733+ builder .port = customizableBuilder .port ;
734+ builder .seedAddresses = customizableBuilder .seedAddresses ;
735+ builder .tags = customizableBuilder .tags ;
736+ builder .tickPeriodSeconds = customizableBuilder .tickPeriodSeconds ;
737+ builder .tracerSupplier = customizableBuilder .tracerSupplier ;
738+
739+ return builder ;
740+ }
741+
716742 public Builder clientTransportFactory (
717743 Function <SocketAddress , ClientTransport > clientTransportFactory ) {
718744 this .clientTransportFactory = clientTransportFactory ;
@@ -878,6 +904,33 @@ public Builder addressSelector(Function<Broker, InetSocketAddress> addressSelect
878904 return this ;
879905 }
880906
907+
908+ public CustomizableBuilder toCustomizableBuilder () {
909+ CustomizableBuilder builder = new CustomizableBuilder ();
910+
911+ builder .clientTransportFactory = this .clientTransportFactory ;
912+ builder .accessKey = this .accessKey ;
913+ builder .accessToken = this .accessToken ;
914+ builder .accessTokenBytes = this .accessTokenBytes ;
915+ builder .ackTimeoutSeconds = this .ackTimeoutSeconds ;
916+ builder .addressSelector = this .addressSelector ;
917+ builder .connectionIdSeed = this .connectionIdSeed ;
918+ builder .destination = this .destination ;
919+ builder .discoveryStrategy = this .discoveryStrategy ;
920+ builder .group = this .group ;
921+ builder .host = this .host ;
922+ builder .inetAddress = this .inetAddress ;
923+ builder .missedAcks = this .missedAcks ;
924+ builder .poolSize = this .poolSize ;
925+ builder .port = this .port ;
926+ builder .seedAddresses = this .seedAddresses ;
927+ builder .tags = this .tags ;
928+ builder .tickPeriodSeconds = this .tickPeriodSeconds ;
929+ builder .tracerSupplier = this .tracerSupplier ;
930+
931+ return builder ;
932+ }
933+
881934 public Proteus build () {
882935 Objects .requireNonNull (accessKey , "account key is required" );
883936 Objects .requireNonNull (accessToken , "account token is required" );
0 commit comments