gpt4 book ai didi

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

转载 作者:行者123 更新时间:2023-11-30 04:57:02 25 4
gpt4 key购买 nike

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

最佳答案

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

direct://amq.direct//myqueue?browse=true
<小时/>

--编辑--

让客户端使用 browser_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);
}
}
}

关于java - 在 Redhat MRG/Apache QPID 中创建仅浏览队列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8222551/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com