使用Spring Boot和AMQP訂閱Azure服務總線主題

我有一個名爲「state-changed」的Azure服務總線主題，它有一個名爲「reverb」的訂閱。我試圖建立一個法@JmsListener訂閱的話題，但我得到一個錯誤：使用Spring Boot和AMQP訂閱Azure服務總線主題

2017-03-22 18:34:41.049 WARN 23356 --- [enerContainer-6] o.s.j.l.DefaultMessageListenerContainer : Setup of JMS message listener invoker failed for destination 'state-changed' - trying to recover. Cause: The messaging entity 'sb://[MySERVICEBUS].servicebus.windows.net/state-changed' could not be found. TrackingId:d2b442f79e0f44bdb449861ea57155ce_G44, SystemTracker:gateway6, Timestamp:3/22/2017 6:34:37 PM 

javax.jms.JMSException: The messaging entity 'sb://[MySERVICEBUS].servicebus.windows.net/state-changed' could not be found. TrackingId:d2b442f79e0f44bdb449861ea57155ce_G44, SystemTracker:gateway6, Timestamp:3/22/2017 6:34:37 PM 
    at org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.createClientReceiver(TopicSubscriberImpl.java:111) ~[qpid-amqp-1-0-client-jms-0.32.jar:0.32] 
    at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.<init>(MessageConsumerImpl.java:129) ~[qpid-amqp-1-0-client-jms-0.32.jar:0.32] 
    at org.apache.qpid.amqp_1_0.jms.impl.TopicSubscriberImpl.<init>(TopicSubscriberImpl.java:46) ~[qpid-amqp-1-0-client-jms-0.32.jar:0.32] 
    at org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:544) ~[qpid-amqp-1-0-client-jms-0.32.jar:0.32] 
    at org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createDurableSubscriber(SessionImpl.java:59) ~[qpid-amqp-1-0-client-jms-0.32.jar:0.32] 
    at org.springframework.jms.listener.AbstractMessageListenerContainer.createConsumer(AbstractMessageListenerContainer.java:870) ~[spring-jms-4.3.6.RELEASE.jar:4.3.6.RELEASE] 
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.createListenerConsumer(AbstractPollingMessageListenerContainer.java:215) ~[spring-jms-4.3.6.RELEASE.jar:4.3.6.RELEASE] 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1189) ~[spring-jms-4.3.6.RELEASE.jar:4.3.6.RELEASE] 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1165) ~[spring-jms-4.3.6.RELEASE.jar:4.3.6.RELEASE] 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1158) ~[spring-jms-4.3.6.RELEASE.jar:4.3.6.RELEASE] 
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1055) ~[spring-jms-4.3.6.RELEASE.jar:4.3.6.RELEASE] 
    at java.lang.Thread.run(Unknown Source) [na:1.8.0_77]

我一直在使用這個博客帖子，試圖讓一切都運行起來：http://ramblingstechnical.blogspot.co.uk/p/using-azure-service-bus-with-spring-jms.html

我可以使用JmsTemplate將消息添加到主題中，並使用Azure文檔中列出的普通舊式Java JMS庫從中讀取消息：https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-java-how-to-use-jms-api-amqp因此我知道我的主題確實有效並且可訪問，它似乎只是在使用Spring進行配置時我做錯了什麼。

我的配置是這樣的：

@Configuration 
public class JmsConfiguration 
{ 

    @Bean 
    public JmsListenerContainerFactory topicJmsListenerContainerFactory() throws NamingException 
    { 
     DefaultJmsListenerContainerFactory returnValue = new DefaultJmsListenerContainerFactory(); 

     Context context = context(); 
     ConnectionFactory cf = connectionFactory(context); 

     returnValue.setConnectionFactory(cf); 
     returnValue.setSubscriptionDurable(Boolean.TRUE); 
     return returnValue; 
    } 

    private Context context() throws NamingException 
    { 
     Hashtable<String, String> env = new Hashtable<String, String>(); 
     env.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory"); 
     env.put(Context.PROVIDER_URL, "src/main/resources/servicebus.properties"); 
     Context context = new InitialContext(env); 
     return context; 
    } 



    /** 
    * @param context 
    * @return 
    * @throws NamingException 
    */ 
    private ConnectionFactory connectionFactory(Context context) throws NamingException 
    { 
     ConnectionFactory cf = (ConnectionFactory) context.lookup("SBCF"); 
     return cf; 
    } 

}

servicebus.properties（用戶名和密碼等節錄）：

# servicebus.properties - sample JNDI configuration 

# Register a ConnectionFactory in JNDI using the form: 
# connectionfactory.[jndi_name] = [ConnectionURL] 
connectionfactory.SBCF=amqps://[USER]:[PASSWORD]@[MYSERVICEBUS] 

# Register some queues in JNDI using the form 
# queue.[jndi_name] = [physical_name] 
# topic.[jndi_name] = [physical_name] 
queue.workflow = workflow 
topic.state-changed = stage-changed

最後我的監聽器類：

@Component 
public class TestListener 
{ 
    Logger logger = LoggerFactory.getLogger(LoggingWorkflowEventHandler.class); 

    @JmsListener(destination = "state-changed", containerFactory = "topicJmsListenerContainerFactory", subscription = "reverb") 
    public void onMessage(String message) 
    { 
     logger.info("Received message from topic: {}", message); 
    } 
}

如果有人有沒有設法得到這個工作，我會感激一些指針。

來源

2017-03-22 Matt Watson

什麼問題你得到了嗎？根據您的配置代碼，代碼env.put（Context.PROVIDER_URL，「src/main/resources/servicebus.properties」）中的'servicebus.properties'文件似乎不會在運行中加載。請檢查並將其更改爲'classes'根路徑下的相對路徑。 –

其他組件使用相同的配置，它們似乎工作正常。我可以使用該配置向主題發送消息，這只是我的聽衆不起作用。 –

您的錯誤消息表明未找到目的地的名稱（未找到消息實體）。請注意，你需要告訴天青您訂閱的名字在這樣一個特定的方式：

<TopicName>/Subscriptions/<SubscriptionName>

你的情況：

state-changed/Subscriptions/reverb

希望幫助

乾杯勒布

來源

2017-04-04 06:14:17 Seb

使用Spring Boot和AMQP訂閱Azure服務總線主題

回答

相關問題