ActiveMQ BrokerFilter Sınıfı

Giriş
Şu satırı dahil ederiz. Bağlantı isteklerinin reddedilebilmesini sağlar.

import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.BrokerFilter;
import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.broker.region.Subscription;
import org.apache.activemq.command.ConnectionInfo;
import org.apache.activemq.command.ConsumerInfo;

addConnection metodu
Şöyle yaparız

public class BrokerAuthentication extends BrokerFilter {

  public BrokerAuthentication(Broker broker) {
    super(broker);
    ...
  }

  @Override
  public void addConnection(ConnectionContext context, ConnectionInfo info)
  throws Exception {

    if (requiresAuth(context)) {
      //...
    }

      super.addConnection(context, info);
  }
  //...

  private boolean requiresAuth(ConnectionContext context) {
    ...
    return true;
  }
}