在 Redhat MRG/Apache QPID 中创建仅浏览队列

Question

如何在 Red Hat MRG/Apache QPID 中强制仅浏览队列，以便客户端只能浏览队列。即使某些客户端尝试从队列中消费消息，他也不应该这样做。

Answer 1

我认为没有配置代理的选项，但您的客户端可以在仅浏览模式下连接到队列。

direct://amq.direct//myqueue?browse=true

---

--编辑--

另一种让客户端使用browse_only队列的方法。

package foo.bar;

import java.util.Hashtable;
import java.util.Map;

import org.apache.qpid.client.AMQDestination;
import org.apache.qpid.jndi.PropertiesFileInitialContextFactory;
import org.apache.qpid.jndi.ReadOnlyContext;

public class CustomPropertiesFileInitialContextFactory extends PropertiesFileInitialContextFactory {

    @SuppressWarnings({ "rawtypes", "unchecked" })
    @Override
    protected ReadOnlyContext createContext(Map data, Hashtable environment) {
        makeDestinationsReadOnly(data);
        return super.createContext(data, environment);
    }
    protected void makeDestinationsReadOnly(Map<String, AMQDestination> dests) {
        for(AMQDestination dest : dests.values()) {
            dest.setBrowseOnly(true);
        }
    }
}