You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by contactreji <co...@gmail.com> on 2013/09/04 13:25:14 UTC
Accessing FUSE MQ Enterprise Messaging broker
Hi all
Can someone guide me how can we send message to queue in FUSE MQ Enterprise.
Whats the camel code for it?
I am doing it as follows
<bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL" value="tcp://:localhost:61616" />
</bean>
<route>
<from uri="file:D:\inputFolder"/>
<convertBodyTo type="java.lang.String"/>
<to uri="activemq:queue:REQUEST_QUEUE"/>
<log message="Sent ${body} to REQUEST_QUEUE"/>
</route>
I was doing the same code for ActiveMQ run as separate instance.
But now I want to send to Internal Instance of MQ runnig in FUSE ESB itself.
It doesnt seem to be working though the route starts, the program is doing a
rollback after exhaustive attempt to deliver the message.
Can someone post a code ..
Reji
--
View this message in context: http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Accessing FUSE MQ Enterprise Messaging broker
Posted by Christian Posta <ch...@gmail.com>.
Default port is 61616. And if you run it locally, it should appear on
localhost/127.0.0.1
Are you seeing any exceptions in the logs? Or what is it doing when trying
to route the message to the queue?
But if you're running within the ESB container itself, you should try the
vm:// transport (of activemq, not camel):
http://activemq.apache.org/vm-transport-reference.html
On Wed, Sep 4, 2013 at 9:17 AM, contactreji <co...@gmail.com> wrote:
> Hey thanks for the reply
>
> I did it with the vm but my project requirements demands using the FUSE MQ
> itself.
> Could u guide me how to connect to broker on my local system itself. What
> is the default URI and port for fuse mq enterprise broker.
> Do I have to start the instance anywhere inside the karaf console?
>
>
> Cheers
> Reji
>
> "ceposta [via Camel]" <ml...@n5.nabble.com> wrote:
>
> >
> >
> >you have to figure out the host/port for the internally running broker.
> or,
> >better yet, use the vm:// protocol. So you'll have different connection
> >factories (and components) for the broker in the ESB and any external
> >brokers.
> >
> >
> >On Wed, Sep 4, 2013 at 4:25 AM, contactreji <co...@gmail.com>
> wrote:
> >
> >> Hi all
> >>
> >> Can someone guide me how can we send message to queue in FUSE MQ
> >> Enterprise.
> >> Whats the camel code for it?
> >> I am doing it as follows
> >>
> >> <bean id="activemq"
> >> class="org.apache.activemq.camel.component.ActiveMQComponent">
> >> <property name="brokerURL"
> value="tcp://:localhost:61616"
> >> />
> >> </bean>
> >>
> >> <route>
> >> <from uri="file:D:\inputFolder"/>
> >> <convertBodyTo type="java.lang.String"/>
> >> <to uri="activemq:queue:REQUEST_QUEUE"/>
> >> <log message="Sent ${body} to REQUEST_QUEUE"/>
> >> </route>
> >>
> >>
> >> I was doing the same code for ActiveMQ run as separate instance.
> >>
> >>
> >> But now I want to send to Internal Instance of MQ runnig in FUSE ESB
> >> itself.
> >> It doesnt seem to be working though the route starts, the program is
> doing
> >> a
> >> rollback after exhaustive attempt to deliver the message.
> >>
> >>
> >>
> >>
> >> Can someone post a code ..
> >>
> >> Reji
> >>
> >>
> >>
> >> --
> >> View this message in context:
> >>
> http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667.html
> >> Sent from the Camel - Users mailing list archive at Nabble.com.
> >>
> >
> >
> >
> >--
> >*Christian Posta*
> >http://www.christianposta.com/blog
> >twitter: @christianposta
> >
> >
> >
> >
> >-----
> >http://www.christianposta.com/blog
> >_______________________________________________
> >If you reply to this email, your message will be added to the discussion
> below:
> >
> http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667p5738676.html
> >
> >To unsubscribe from Accessing FUSE MQ Enterprise Messaging broker, visit
> http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5738667&code=Y29udGFjdHJlamlAZ21haWwuY29tfDU3Mzg2Njd8MTAwNDkxODIzMw==
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667p5738694.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Re: Accessing FUSE MQ Enterprise Messaging broker
Posted by contactreji <co...@gmail.com>.
Hey thanks for the reply
I did it with the vm but my project requirements demands using the FUSE MQ itself.
Could u guide me how to connect to broker on my local system itself. What is the default URI and port for fuse mq enterprise broker.
Do I have to start the instance anywhere inside the karaf console?
Cheers
Reji
"ceposta [via Camel]" <ml...@n5.nabble.com> wrote:
>
>
>you have to figure out the host/port for the internally running broker. or,
>better yet, use the vm:// protocol. So you'll have different connection
>factories (and components) for the broker in the ESB and any external
>brokers.
>
>
>On Wed, Sep 4, 2013 at 4:25 AM, contactreji <co...@gmail.com> wrote:
>
>> Hi all
>>
>> Can someone guide me how can we send message to queue in FUSE MQ
>> Enterprise.
>> Whats the camel code for it?
>> I am doing it as follows
>>
>> <bean id="activemq"
>> class="org.apache.activemq.camel.component.ActiveMQComponent">
>> <property name="brokerURL" value="tcp://:localhost:61616"
>> />
>> </bean>
>>
>> <route>
>> <from uri="file:D:\inputFolder"/>
>> <convertBodyTo type="java.lang.String"/>
>> <to uri="activemq:queue:REQUEST_QUEUE"/>
>> <log message="Sent ${body} to REQUEST_QUEUE"/>
>> </route>
>>
>>
>> I was doing the same code for ActiveMQ run as separate instance.
>>
>>
>> But now I want to send to Internal Instance of MQ runnig in FUSE ESB
>> itself.
>> It doesnt seem to be working though the route starts, the program is doing
>> a
>> rollback after exhaustive attempt to deliver the message.
>>
>>
>>
>>
>> Can someone post a code ..
>>
>> Reji
>>
>>
>>
>> --
>> View this message in context:
>> http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>
>
>
>--
>*Christian Posta*
>http://www.christianposta.com/blog
>twitter: @christianposta
>
>
>
>
>-----
>http://www.christianposta.com/blog
>_______________________________________________
>If you reply to this email, your message will be added to the discussion below:
>http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667p5738676.html
>
>To unsubscribe from Accessing FUSE MQ Enterprise Messaging broker, visit http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5738667&code=Y29udGFjdHJlamlAZ21haWwuY29tfDU3Mzg2Njd8MTAwNDkxODIzMw==
--
View this message in context: http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667p5738694.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Accessing FUSE MQ Enterprise Messaging broker
Posted by Christian Posta <ch...@gmail.com>.
you have to figure out the host/port for the internally running broker. or,
better yet, use the vm:// protocol. So you'll have different connection
factories (and components) for the broker in the ESB and any external
brokers.
On Wed, Sep 4, 2013 at 4:25 AM, contactreji <co...@gmail.com> wrote:
> Hi all
>
> Can someone guide me how can we send message to queue in FUSE MQ
> Enterprise.
> Whats the camel code for it?
> I am doing it as follows
>
> <bean id="activemq"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
> <property name="brokerURL" value="tcp://:localhost:61616"
> />
> </bean>
>
> <route>
> <from uri="file:D:\inputFolder"/>
> <convertBodyTo type="java.lang.String"/>
> <to uri="activemq:queue:REQUEST_QUEUE"/>
> <log message="Sent ${body} to REQUEST_QUEUE"/>
> </route>
>
>
> I was doing the same code for ActiveMQ run as separate instance.
>
>
> But now I want to send to Internal Instance of MQ runnig in FUSE ESB
> itself.
> It doesnt seem to be working though the route starts, the program is doing
> a
> rollback after exhaustive attempt to deliver the message.
>
>
>
>
> Can someone post a code ..
>
> Reji
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Accessing-FUSE-MQ-Enterprise-Messaging-broker-tp5738667.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta