You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@tomee.apache.org by "Jonathan S. Fisher" <jo...@springventuregroup.com> on 2015/09/30 19:40:33 UTC
Can't get messages to flow between embedded broker and external broker
I have a standalone external broker I want all of my TomEE instances to
connect to.
Everything is connected, but messages published to a Topic or Queue on one
JVM don't make it across the bridge to another JVM. Consumers will register
just fine on the external broker (The consumer count goes up) but they do
not get any messages.
Here's my TomEE xbean configuration. Any help is greatly appreciated!
<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:amq="http://activemq.apache.org/schema/core"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd">
<broker
xmlns="http://activemq.apache.org/schema/core"
brokerName="tomee2"
persistent="false"
schedulerSupport="false"
enableStatistics="false"
offlineDurableSubscriberTimeout="259200000"
offlineDurableSubscriberTaskSchedule="3600000">
<managementContext>
<managementContext createConnector="false" />
</managementContext>
<networkConnectors>
<!-- Fixed outbound connector to main broker -->
<networkConnector
name="networkConnector_activemq_tomee2"
uri="static:(tcp://localhost:61616/activemq-hawkeye)" />
</networkConnectors>
<transportConnectors>
<transportConnector
name="transportConnector_vm_tomee2"
uri="vm://tomee2" />
<!-- Advertise inbound on multicast so main broker connects back -->
<transportConnector
name="transportConnector_tcp_tomee2"
uri="nio://0.0.0.0:61618"
discoveryUri="multicast://224.6.1.6:61616" />
</transportConnectors>
</broker>
</beans>
--
Email Confidentiality Notice: The information contained in this
transmission is confidential, proprietary or privileged and may be subject
to protection under the law, including the Health Insurance Portability and
Accountability Act (HIPAA). The message is intended for the sole use of the
individual or entity to whom it is addressed. If you are not the intended
recipient, you are notified that any use, distribution or copying of the
message is strictly prohibited and may subject you to criminal or civil
penalties. If you received this transmission in error, please contact the
sender immediately by replying to this email and delete the material from
any computer.
Re: Can't get messages to flow between embedded broker and external broker
Posted by "Jonathan S. Fisher" <jo...@springventuregroup.com>.
Let me ask this question a different way...
Does anyone have a configuration where they've successfully connected the
embedded broker to an external one and messages flow outbound? I can only
get inbound to work. Any messages produced do not get forwarded to the
external broker.
*Jonathan S. Fisher*
*VP - Information Technology*
*Spring Venture Group*
(o) 913-653-8820
On Wed, Sep 30, 2015 at 12:40 PM, Jonathan S. Fisher <
jonathan@springventuregroup.com> wrote:
> I have a standalone external broker I want all of my TomEE instances to
> connect to.
>
> Everything is connected, but messages published to a Topic or Queue on one
> JVM don't make it across the bridge to another JVM. Consumers will register
> just fine on the external broker (The consumer count goes up) but they do
> not get any messages.
>
> Here's my TomEE xbean configuration. Any help is greatly appreciated!
>
>
>
> <?xml version="1.0" encoding="UTF-8"?>
> <beans
> xmlns="http://www.springframework.org/schema/beans"
> xmlns:amq="http://activemq.apache.org/schema/core"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
> http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core-5.8.0.xsd">
>
> <broker
> xmlns="http://activemq.apache.org/schema/core"
> brokerName="tomee2"
> persistent="false"
> schedulerSupport="false"
> enableStatistics="false"
> offlineDurableSubscriberTimeout="259200000"
> offlineDurableSubscriberTaskSchedule="3600000">
>
> <managementContext>
> <managementContext createConnector="false" />
> </managementContext>
>
> <networkConnectors>
> <!-- Fixed outbound connector to main broker -->
> <networkConnector
> name="networkConnector_activemq_tomee2"
> uri="static:(tcp://localhost:61616/activemq-hawkeye)" />
> </networkConnectors>
>
> <transportConnectors>
> <transportConnector
> name="transportConnector_vm_tomee2"
> uri="vm://tomee2" />
> <!-- Advertise inbound on multicast so main broker connects back -->
> <transportConnector
> name="transportConnector_tcp_tomee2"
> uri="nio://0.0.0.0:61618"
> discoveryUri="multicast://224.6.1.6:61616" />
> </transportConnectors>
> </broker>
> </beans>
>
>
--
Email Confidentiality Notice: The information contained in this
transmission is confidential, proprietary or privileged and may be subject
to protection under the law, including the Health Insurance Portability and
Accountability Act (HIPAA). The message is intended for the sole use of the
individual or entity to whom it is addressed. If you are not the intended
recipient, you are notified that any use, distribution or copying of the
message is strictly prohibited and may subject you to criminal or civil
penalties. If you received this transmission in error, please contact the
sender immediately by replying to this email and delete the material from
any computer.