Spring JMS与Apache Pulsar的集成

Question

我们当前的代码是使用MQ接收来自上游应用程序的消息。JMS将使用来自MQ的消息并插入到数据库中。

我们现在需要使用Apache Pulsar，而不是MQ。是否可以使用Apache脉冲星来连接JMS。如果是这样的话，我们是否有任何Apache Pulsar连接工厂和属性来连接到JMS，类似于我在下面发布的IBM MQ到JMS的连接：

<bean id="NEPrimaryJmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
<property name="hostName" value="${CSGW_NE_PRIMARY_HOST_NAME}" />
<property name="port" value="${CSGW_NE_PRIMARY_PORT_NO}" />
<property name="queueManager" value="${CSGW_NE_PRIMARY_QUEUE_MANAGER}" />
<property name="transportType" value="1" />
</bean>
<bean id="NEPrimaryJmsDestination" class="com.ibm.mq.jms.MQQueue">
<constructor-arg value="${CSGW_NE_PRIMARY_QUEUE_NAME}" />
</bean>
<bean id="NEPrimaryConnectionFactory"
class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="NEPrimaryJmsConnectionFactory" />
</bean>
<bean id="NEPrimaryJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="NEPrimaryConnectionFactory" />
<property name="defaultDestination" ref="NEPrimaryJmsDestination" />
</bean>

Answer 1

这是Apache Pulsar和JMS的一个开源绑定。https://github.com/datastax/pulsar-jms

还有一个在存储库中使用Spring JMS的示例

我是维护者之一。如果您有问题，请随时在GH问题选项卡上打开问题。

Answer 2

Pulsar文档中没有引用JMS。由此，我只能得出结论，Pulsar没有JMS客户端实现，这意味着您将无法像使用IBM MQ那样通过Spring JMS与Pulsar集成。