我有一个可工作的示例,可以通过qpid消息传递将消息发送到服务器并由服务器接收。以下是发送到服务器的简单hello world示例:
http://pastebin.com/M7mSECJn
这是接收请求并发送响应的服务器(当前客户端不接收响应):
http://pastebin.com/2mEeuzrV
这是我的属性文件:
http://pastebin.com/TLEFdpXG
它们都能正常工作,我可以通过Qpid JMX管理控制台看到qpid队列中的消息。这些示例是从https://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example下载的(有人可能也需要)。
我以前使用Spring做过Jboss消息传递,但我无法使用qpid做同样的事情。在applicationsContext中,我有像jndiTemplate、conectionFactory、destinationQueue和jmscontainer这样的bean:
我以前使用Spring做过Jboss消息传递,但我无法使用qpid做同样的事情。在applicationsContext中,我有像jndiTemplate、conectionFactory、destinationQueue和jmscontainer这样的bean:
<!-- Queue configuration -->
<bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
<property name="environment">
<props>
<prop key="java.naming.factory.initial">org.jnp.interfaces.NamingContextFactory</prop>
<prop key="java.naming.provider.url">jnp://localhost:1099</prop>
<prop key="java.naming.factory.url.pkgs">org.jboss.naming:org.jnp.interfaces</prop>
<prop key="java.naming.security.principal">admin</prop>
<prop key="java.naming.security.credentials">admin</prop>
</props>
</property>
</bean>
<bean id="connectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiTemplate" ref="jndiTemplate" />
<property name="jndiName" value="ConnectionFactory" />
</bean>
<bean id="queueDestination" class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiTemplate" ref="jndiTemplate" />
<property name="jndiName">
<value>queue/testQueue</value>
</property>
</bean>
<bean id="jmsContainer"
class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory" />
<property name="destination" ref="queueDestination" />
<property name="messageListener" ref="listener" />
</bean>
当然还有发送者和监听者:
<bean id="sender" class="com.practice.Sender">
<property name="connectionFactory" ref="connectionFactory" />
<property name="queueDestination" ref="queueDestination" />
</bean>
<bean id="listener" class="com.practice.MsgListener" />
现在我想使用Spring上下文逻辑重写这个qpid示例。有人能帮我吗?