Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -122,8 +122,6 @@ public class ComponentsDefine {

public static final OfficialComponent RESTEASY = new OfficialComponent(62, "RESTEasy");

public static final OfficialComponent SOLRJ = new OfficialComponent(63, "solrj");

private static ComponentsDefine INSTANCE = new ComponentsDefine();

private String[] components;
Expand Down Expand Up @@ -181,7 +179,6 @@ public ComponentsDefine() {
addComponent(VERTX);
addComponent(SPRING_CLOUD_GATEWAY);
addComponent(RESTEASY);
addComponent(SOLRJ);
}

private void addComponent(OfficialComponent component) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -193,17 +193,5 @@ public static class Toolkit {
*/
public static boolean USE_QUALIFIED_NAME_AS_OPERATION_NAME = false;
}

public static class SolrJ {
/**
* If true, trace all the query parameters(include deleteByIds and deleteByQuery) in Solr query request, default is false.
*/
public static boolean TRACE_STATEMENT = false;

/**
* If true, trace all the operation parameters in Solr request, default is false.
*/
public static boolean TRACE_OPS_PARAMS = false;
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,7 @@ public void onComplete() throws Throwable {

@Override
public void shutdown() throws Throwable {
TracingContext.ListenerManager.remove(this);
carrier.shutdownConsumers();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,28 +39,34 @@ public static void clear() {
@Test
public void testSpanLimit() {
final boolean[] dataReceived = {false};
TracingContext.ListenerManager.add(new TracingContextListener() {
TracingContextListener listener = new TracingContextListener() {
@Override public void afterFinished(TraceSegment traceSegment) {
dataReceived[0] = true;
}
});
TracingContext tracingContext = new TracingContext();
AbstractSpan span = tracingContext.createEntrySpan("/url");
};
TracingContext.ListenerManager.add(listener);
try {
TracingContext tracingContext = new TracingContext();
AbstractSpan span = tracingContext.createEntrySpan("/url");

for (int i = 0; i < 10; i++) {
AbstractSpan localSpan = tracingContext.createLocalSpan("/java-bean");
for (int i = 0; i < 10; i++) {
AbstractSpan localSpan = tracingContext.createLocalSpan("/java-bean");

for (int j = 0; j < 100; j++) {
AbstractSpan exitSpan = tracingContext.createExitSpan("/redis","localhost");
tracingContext.stopSpan(exitSpan);
for (int j = 0; j < 100; j++) {
AbstractSpan exitSpan = tracingContext.createExitSpan("/redis", "localhost");
tracingContext.stopSpan(exitSpan);
}

tracingContext.stopSpan(localSpan);
}

tracingContext.stopSpan(localSpan);
}
tracingContext.stopSpan(span);

tracingContext.stopSpan(span);
Assert.assertTrue(dataReceived[0]);
} finally {
TracingContext.ListenerManager.remove(listener);
}
}


Assert.assertTrue(dataReceived[0]);
}
}
3 changes: 1 addition & 2 deletions apm-sniffer/apm-sdk-plugin/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,6 @@
<module>dubbo-2.7.x-conflict-patch</module>
<module>vertx-plugins</module>
<module>resteasy-plugin</module>
<module>solrj-7.x-plugin</module>
</modules>
<packaging>pom</packaging>

Expand Down Expand Up @@ -183,4 +182,4 @@
</plugin>
</plugins>
</build>
</project>
</project>
47 changes: 0 additions & 47 deletions apm-sniffer/apm-sdk-plugin/solrj-7.x-plugin/pom.xml

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Loading