Javaを使用してSolaceでワイルドカードを使用して耐久性のあるトピックエンドポイントに登録できますか？

Question

アイデアはトピックにメッセージを送信し、pub/subのみ（キューなし）とPERSISTENT配信モードを使用してメッセージをストライプで消費することです。簡単にするために、プロデューサーが次の階層を持つ特定のトピックにメッセージを公開するとします：bus/<componentId/<transactionId>シンプルさは、10人の消費者があると言うことができますため

消費者は、トピック "ストライプ" を受信したいと彼らはのtransactionIdによって自分たちの中でトラフィックをストライプ化したい：

• ​​
• bus/*/1*
• ...
• bus/*/9*

私がサブしようとするとこのようなワイルドカードを使用してトピックのエンドポイントにスクライブ、私は次の例外を取得

DurableTopicEndpoint topicEndpoint = JCSMPFactory.onlyInstance().createDurableTopicEndpoint("bus/*/1*"); 

    ConsumerFlowProperties propsFlow = new ConsumerFlowProperties(); 
    propsFlow.setEndpoint(topicEndpoint); 

：このarticleのセクション 『トピックエンドポイントへのサブスクリプションの追加』の光で

Exception in thread "main" java.lang.IllegalArgumentException: Topic Endpoint name "bus/*/1*" contains illegal character [*] 
    at com.solacesystems.common.util.DestinationUtil.isValidEndpointName(DestinationUtil.java:234) 
    at com.solacesystems.common.util.DestinationUtil.isValidTopicEndpointPhysicalName(DestinationUtil.java:209) 
    at com.solacesystems.common.util.DestinationUtil.isValidDTEPhysicalName(DestinationUtil.java:213) 
    at com.solacesystems.jcsmp.impl.SessionModeSupport.createFlow(SessionModeSupport.java:247) 
    at com.solacesystems.jcsmp.impl.SessionModeSupport.createFlow(SessionModeSupport.java:170) 
    at com.solacesystems.jcsmp.impl.JCSMPBasicSession.createFlow(JCSMPBasicSession.java:953) 

を - それはですすべてSolace Java APIで可能ですか？

Answer 1

ここには2つの問題があります。

あなたが bus/*/1*という名前 TopicEndpointを作成しようとしている

1. 。これはTopicEndpointの名前であり、購読しているトピックではありません。 は、TopicEndpointの名前には有効な文字ではありません。

2. TopicEndpointsは、1回のサブスクリプションしか許されません。つまり、​​にしか登録できません。​​に完全にbus/*/9*に登録する場合は、TopicEndpointの代わりにQueueを使用する必要があります。