public class MessageInterceptorRegistry extends Object
public static MessageInterceptorRegistry getInstance()
public MessageInterceptorRegistry get(String brokerName)
public MessageInterceptorRegistry get(BrokerService brokerService)
public MessageInterceptor addMessageInterceptor(String destinationName, MessageInterceptor messageInterceptor)
public void removeMessageInterceptor(String destinationName, MessageInterceptor messageInterceptor)
public MessageInterceptor addMessageInterceptorForQueue(String destinationName, MessageInterceptor messageInterceptor)
public void removeMessageInterceptorForQueue(String destinationName, MessageInterceptor messageInterceptor)
public MessageInterceptor addMessageInterceptorForTopic(String destinationName, MessageInterceptor messageInterceptor)
public void removeMessageInterceptorForTopic(String destinationName, MessageInterceptor messageInterceptor)
public MessageInterceptor addMessageInterceptor(ActiveMQDestination activeMQDestination, MessageInterceptor messageInterceptor)
public void removeMessageInterceptor(ActiveMQDestination activeMQDestination, MessageInterceptor interceptor)
public void injectMessage(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
Exception
Copyright © 2005–2018 The Apache Software Foundation. All rights reserved.