@@ -119,6 +119,25 @@ public static Instrumenter<DbRequest, Void> createTransactionInstrumenter(
119119 return createTransactionInstrumenter (openTelemetry , transactionEnabled (openTelemetry , false ));
120120 }
121121
122+ public static Instrumenter <DbRequest , Void > createTransactionInstrumenter (
123+ OpenTelemetry openTelemetry , boolean enabled ) {
124+ return createTransactionInstrumenter (openTelemetry , emptyList (), enabled );
125+ }
126+
127+ public static Instrumenter <DbRequest , Void > createTransactionInstrumenter (
128+ OpenTelemetry openTelemetry ,
129+ List <AttributesExtractor <DbRequest , Void >> extractors ,
130+ boolean enabled ) {
131+ return Instrumenter .<DbRequest , Void >builder (
132+ openTelemetry , INSTRUMENTATION_NAME , DbRequest ::getOperation )
133+ .addAttributesExtractor (SqlClientAttributesExtractor .builder (dbAttributesGetter ).build ())
134+ .addAttributesExtractor (TransactionAttributeExtractor .INSTANCE )
135+ .addAttributesExtractor (ServerAttributesExtractor .create (netAttributesGetter ))
136+ .addAttributesExtractors (extractors )
137+ .setEnabled (enabled )
138+ .buildInstrumenter (SpanKindExtractor .alwaysClient ());
139+ }
140+
122141 private static boolean transactionEnabled (OpenTelemetry openTelemetry , boolean defaultEnabled ) {
123142 if (openTelemetry instanceof ExtendedOpenTelemetry ) {
124143 ExtendedOpenTelemetry extendedOpenTelemetry = (ExtendedOpenTelemetry ) openTelemetry ;
@@ -163,24 +182,5 @@ private static boolean statementSanitizationEnabled(
163182 }
164183 }
165184
166- public static Instrumenter <DbRequest , Void > createTransactionInstrumenter (
167- OpenTelemetry openTelemetry , boolean enabled ) {
168- return createTransactionInstrumenter (openTelemetry , emptyList (), enabled );
169- }
170-
171- public static Instrumenter <DbRequest , Void > createTransactionInstrumenter (
172- OpenTelemetry openTelemetry ,
173- List <AttributesExtractor <DbRequest , Void >> extractors ,
174- boolean enabled ) {
175- return Instrumenter .<DbRequest , Void >builder (
176- openTelemetry , INSTRUMENTATION_NAME , DbRequest ::getOperation )
177- .addAttributesExtractor (SqlClientAttributesExtractor .builder (dbAttributesGetter ).build ())
178- .addAttributesExtractor (TransactionAttributeExtractor .INSTANCE )
179- .addAttributesExtractor (ServerAttributesExtractor .create (netAttributesGetter ))
180- .addAttributesExtractors (extractors )
181- .setEnabled (enabled )
182- .buildInstrumenter (SpanKindExtractor .alwaysClient ());
183- }
184-
185185 private JdbcInstrumenterFactory () {}
186186}
0 commit comments