2014-02-22 32 views
1

我想设置一个持久订阅我的跺脚客户端使用activemq。 到目前为止,我已经制定了增加activemq.subscriptionName用于发送订阅框架:如何发送自定义标题连接跺脚使用activemq

HashMap<String, String> header = new HashMap<String,String>(); 
header.put("activemq.subscriptionName","unique-string-for-feed"); 
connection.subscribe("/topic/location", Stomp.Headers.Subscribe.AckModeValues.CLIENT, header); 

但我不知道如何与联接架,做到这一点,因为没有接受一个HashMap方法。我是否仅使用StompConnection.class中的客户端参数设置客户端ID?

public void connect(java.lang.String username, java.lang.String password, java.lang.String client) 

回答

2

要创建你需要设置STOMP框架上的客户端编号,并使用相同的ID每次连接时间持久订阅。然后,您需要在订阅中设置持久订阅名称,因为您已经制定了该名称。

查看ActiveMQ Stomp Documentation

你可以找到在ActiveMQ的践踏单元测试的一些好的例子践踏,以及,看到testDurableUnsub在StompTest.java

+0

我看到它,线路1502是否正确?非常感谢你的链接:)我认为我们只能使用activemq中提供的方法 – obsessiveCookie

相关问题