org.apache.activemq.broker.inteceptor
Class MessageInterceptorRegistry

java.lang.Object
  extended by org.apache.activemq.broker.inteceptor.MessageInterceptorRegistry

public class MessageInterceptorRegistry
extends Object


Method Summary
 MessageInterceptor addMessageInterceptor(ActiveMQDestination activeMQDestination, MessageInterceptor messageInterceptor)
           
 MessageInterceptor addMessageInterceptor(String destinationName, MessageInterceptor messageInterceptor)
           
 MessageInterceptor addMessageInterceptorForQueue(String destinationName, MessageInterceptor messageInterceptor)
           
 MessageInterceptor addMessageInterceptorForTopic(String destinationName, MessageInterceptor messageInterceptor)
           
 MessageInterceptorRegistry get(BrokerService brokerService)
           
 MessageInterceptorRegistry get(String brokerName)
           
static MessageInterceptorRegistry getInstance()
           
 void injectMessage(ProducerBrokerExchange producerExchange, Message messageSend)
          Re-inject into the Broker chain
 void removeMessageInterceptor(ActiveMQDestination activeMQDestination, MessageInterceptor interceptor)
           
 void removeMessageInterceptor(String destinationName, MessageInterceptor messageInterceptor)
           
 void removeMessageInterceptorForQueue(String destinationName, MessageInterceptor messageInterceptor)
           
 void removeMessageInterceptorForTopic(String destinationName, MessageInterceptor messageInterceptor)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInstance

public static MessageInterceptorRegistry getInstance()

get

public MessageInterceptorRegistry get(String brokerName)

get

public MessageInterceptorRegistry get(BrokerService brokerService)

addMessageInterceptor

public MessageInterceptor addMessageInterceptor(String destinationName,
                                                MessageInterceptor messageInterceptor)

removeMessageInterceptor

public void removeMessageInterceptor(String destinationName,
                                     MessageInterceptor messageInterceptor)

addMessageInterceptorForQueue

public MessageInterceptor addMessageInterceptorForQueue(String destinationName,
                                                        MessageInterceptor messageInterceptor)

removeMessageInterceptorForQueue

public void removeMessageInterceptorForQueue(String destinationName,
                                             MessageInterceptor messageInterceptor)

addMessageInterceptorForTopic

public MessageInterceptor addMessageInterceptorForTopic(String destinationName,
                                                        MessageInterceptor messageInterceptor)

removeMessageInterceptorForTopic

public void removeMessageInterceptorForTopic(String destinationName,
                                             MessageInterceptor messageInterceptor)

addMessageInterceptor

public MessageInterceptor addMessageInterceptor(ActiveMQDestination activeMQDestination,
                                                MessageInterceptor messageInterceptor)

removeMessageInterceptor

public void removeMessageInterceptor(ActiveMQDestination activeMQDestination,
                                     MessageInterceptor interceptor)

injectMessage

public void injectMessage(ProducerBrokerExchange producerExchange,
                          Message messageSend)
                   throws Exception
Re-inject into the Broker chain

Throws:
Exception


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.