Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #37 Service Registry Transformers

This commit is contained in:
Clebert Suconic 2015-06-17 14:06:02 -04:00
parent 2485bb7af6 ba7a991b11
commit 7de88ef87a
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ServiceRegistry.java
View File

@ -63,8 +63,12 @@ public interface ServiceRegistry
Transformer getDivertTransformer(String name); Transformer getDivertTransformer(String name);
void addDivertTransformer(String name, Transformer transformer);
Transformer getBridgeTransformer(String name); Transformer getBridgeTransformer(String name);
void addBridgeTransformer(String name, Transformer transformer);
AcceptorFactory getAcceptorFactory(String name, String className); AcceptorFactory getAcceptorFactory(String name, String className);
void addAcceptorFactory(String name, AcceptorFactory acceptorFactory); void addAcceptorFactory(String name, AcceptorFactory acceptorFactory);

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServiceRegistryImpl.java
View File

@ -140,16 +140,19 @@ public class ServiceRegistryImpl implements ServiceRegistry
return Collections.unmodifiableCollection(outgoingInterceptors.values()); return Collections.unmodifiableCollection(outgoingInterceptors.values());
} }
@Override
public void addDivertTransformer(String name, Transformer transformer) public void addDivertTransformer(String name, Transformer transformer)
{ {
divertTransformers.put(name, transformer); divertTransformers.put(name, transformer);
} }
@Override
public Transformer getDivertTransformer(String name) public Transformer getDivertTransformer(String name)
{ {
return divertTransformers.get(name); return divertTransformers.get(name);
} }
@Override
public void addBridgeTransformer(String name, Transformer transformer) public void addBridgeTransformer(String name, Transformer transformer)
{ {
bridgeTransformers.put(name, transformer); bridgeTransformers.put(name, transformer);