diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java index f6a4cfa317..e72d6ea0e3 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java @@ -63,8 +63,12 @@ public interface ServiceRegistry Transformer getDivertTransformer(String name); + void addDivertTransformer(String name, Transformer transformer); + Transformer getBridgeTransformer(String name); + void addBridgeTransformer(String name, Transformer transformer); + AcceptorFactory getAcceptorFactory(String name, String className); void addAcceptorFactory(String name, AcceptorFactory acceptorFactory); diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java index 26ee8d9f91..dffecc56f1 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java @@ -140,16 +140,19 @@ public class ServiceRegistryImpl implements ServiceRegistry return Collections.unmodifiableCollection(outgoingInterceptors.values()); } + @Override public void addDivertTransformer(String name, Transformer transformer) { divertTransformers.put(name, transformer); } + @Override public Transformer getDivertTransformer(String name) { return divertTransformers.get(name); } + @Override public void addBridgeTransformer(String name, Transformer transformer) { bridgeTransformers.put(name, transformer);