Skip to content

Commit 8ec23f2

Browse files
committed
Clean up code and allow osgi to set servlet listeners
1 parent 158684f commit 8ec23f2

File tree

2 files changed

+11
-11
lines changed

2 files changed

+11
-11
lines changed

src/main/java/graphql/servlet/GraphQLServlet.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -361,12 +361,6 @@ private <T> void runCallbacks(List<T> callbacks, Consumer<T> action) {
361361
});
362362
}
363363

364-
/**
365-
* Don't let listener errors escape to the client.
366-
*/
367-
private <T, R> void runListener(T listener, Function<? super T, ? super R> action) {
368-
}
369-
370364
protected static class VariablesDeserializer extends JsonDeserializer<Map<String, Object>> {
371365
@Override
372366
public Map<String, Object> deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {

src/main/java/graphql/servlet/OsgiGraphQLServlet.java

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,7 @@
1414
*/
1515
package graphql.servlet;
1616

17-
import graphql.execution.ExecutionStrategy;
1817
import graphql.execution.instrumentation.Instrumentation;
19-
import graphql.schema.GraphQLFieldDefinition;
2018
import graphql.schema.GraphQLObjectType;
2119
import graphql.schema.GraphQLSchema;
2220
import graphql.schema.GraphQLType;
@@ -103,13 +101,13 @@ public void bindProvider(GraphQLProvider provider) {
103101
}
104102
public void unbindProvider(GraphQLProvider provider) {
105103
if (provider instanceof GraphQLQueryProvider) {
106-
queryProviders.remove((GraphQLQueryProvider) provider);
104+
queryProviders.remove(provider);
107105
}
108106
if (provider instanceof GraphQLMutationProvider) {
109-
mutationProviders.remove((GraphQLMutationProvider) provider);
107+
mutationProviders.remove(provider);
110108
}
111109
if (provider instanceof GraphQLTypesProvider) {
112-
typesProviders.remove((GraphQLTypesProvider) provider);
110+
typesProviders.remove(provider);
113111
}
114112
updateSchema();
115113
}
@@ -144,6 +142,14 @@ public void unbindTypesProvider(GraphQLTypesProvider typesProvider) {
144142
updateSchema();
145143
}
146144

145+
@Reference(cardinality = ReferenceCardinality.MULTIPLE, policyOption = ReferencePolicyOption.GREEDY)
146+
public void bindServletListener(GraphQLServletListener listener) {
147+
this.addListener(listener);
148+
}
149+
public void unbindServletListener(GraphQLServletListener listener) {
150+
this.removeListener(listener);
151+
}
152+
147153
@Reference(cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY)
148154
public void setContextProvider(GraphQLContextBuilder contextBuilder) {
149155
this.contextBuilder = contextBuilder;

0 commit comments

Comments
 (0)