JMS无法使用使用spring/jms的Oracle队列中的消息

我遵循Spring文档并设置了Spring JMS侦听器。然而，即使我向队列中添加消息，我的代码也没有检测到这一点。我的Spring配置如下：JMS无法使用使用spring/jms的Oracle队列中的消息

<bean id="dataSourceListener" class="oracle.jdbc.pool.OracleDataSource"> 
    <property name="URL" value="xxx"/> 
    <property name="user" value="xxx"/> 
    <property name="password" value="xxx"/> 
</bean> 

<bean id="jmsConnectionFactory" class="OracleAqFactoryBean"> 
    <property name="dataSource" ref="dataSourceListener" /> 
</bean> 

<jms:listener-container connection-factory="jmsConnectionFactory" acknowledge="transacted" concurrency="1-5"> 
    <jms:listener destination="queuename" ref="myMessageListener"/> 
</jms:listener-container> 

<bean id="myMessageListener" class="Listener"/>

我的Java如下：

我定制的监听器：

class Listener implements MessageListener { 

    @Override 
    void onMessage(Message message) { 
     // code to handle message is here 
    } 
}

而且我OracleAqFactoryBean：

public class OracleAqFactoryBean implements FactoryBean { 
private DataSource dataSource; 

public void setDataSource(DataSource dataSource) { 
    this.dataSource = dataSource; 
} 

@Override 
public Object getObject() throws Exception { 
    return AQjmsFactory.getConnectionFactory(dataSource); 
} 

@Override 
public Class<?> getObjectType() { 
    return ConnectionFactory.class; 
} 

@Override 
public boolean isSingleton() { 
    return true; 
} 

}

[编辑：以上设置现在正在工作]

来源

2013-03-11 user1740752

我不明白你为什么要将一个FactoryBean实现连接到Spring DMLC destination属性。这显然不正确，因为setDestinationmethod只接受javax.jms.Destination类型。你已经连线了connectionFactory和messageListener。这就是开始消费信息所需要的一切。如果您删除已连接到destination属性的testmq引用，则应成功使用消息。

来源

2013-03-12 15:36:14 bsnyder

您好，感谢您的回复。我改变了我的配置，上面的设置正在工作。虽然我试图将它移植到Grails应用程序中，但它不会消耗队列中的任何消息。我不认为任何人曾经尝试过，并有任何想法？ – user1740752 2013-03-12 17:08:01

JMS无法使用使用spring/jms的Oracle队列中的消息

回答

相关问题