Hi
The code should be ready. I was just waiting to see if there would be any
need for such a component.
I will try to do a PR in the coming days, so the component can get a proper
home.
Best,
Preben
--
View this message in context:
http://camel.465427.n5.nabble.com/IronMQ-support-tp5778300p57
Hi
I dont think Preben got around doing it yet and getting the code ready
for donation.
Preben wonder if you could give us any status?
On Fri, Feb 26, 2016 at 1:46 AM, John D. Ament wrote:
> All,
>
> I was wondering what the status of Iron MQ support was?
>
> I saw this thread from mid last
If you want to log the type, the you can get the class name
${header.foo.class.name}
(you can omit the getXXX and do XXX)
If you want to check if a body is a specific type using instanceof
then use the is operator
${body} is 'String'
http://camel.apache.org/simple
On Thu, Feb 25, 2016 at 10:4
All,
I was wondering what the status of Iron MQ support was?
I saw this thread from mid last year about a possible donation, but it
doesn't seem like it ever came to fruition?
http://mail-archives.apache.org/mod_mbox/camel-dev/201505.mbox/%3c1431160610135-5766898.p...@n5.nabble.com%3E
Looking b
Hello,
I am trying to use header.type in simple to determine the type of the body. I
have tried many variations of header ie (in.header, headers) etc, but it always
seems like type and BodyType are empty or null.
I have tried with Camel 2.16.1 and 2.16.2. I assume I'm missing something basic.
hello,
Is there any prefetch option for the JMS componenet, I see option in
ActiveMQ component.
I want to fetch 100 messages at a time from a queue .
I have configured as below, I am able to connect using connection
Factory.
However I have a query about the ackknwl
Here's how I'm doing it in my route:
.setHeader(Exchange.FILE_NAME, namespace.xpath(FILENAME_XPATH,
String.class))
Hope that helps.
On Wed, Feb 24, 2016 at 5:25 AM, krish_p wrote:
> HI There,
>
> I am trying to set a header value using xpath with no luck (Camel 2.16.2)
>
> eg:
>
> .setHeader("
> On 25 Feb 2016, at 15:30, Matt Sicker wrote:
>
> I thought camel-amqp mostly used JMS anyway.
Yes it is - though if you want to change your broker without updating clients,
AMQP 1.0 makes that easy for you. Though in reality other AMQP 1.0 broker
implementations are currently limited (Swift
> On 25 Feb 2016, at 15:22, Claus Ibsen wrote:
>
> camel-amqp is compiled with an older qpid-proton library I think.
Yeah - it uses 0.70 - the latest is 0.80
>
> We would need to upgrade but the mock test server that qpid provided
> is changed / gone etc. So maybe the idea is to use an embedde
I thought camel-amqp mostly used JMS anyway.
On 25 February 2016 at 09:22, Claus Ibsen wrote:
> camel-amqp is compiled with an older qpid-proton library I think.
>
> We would need to upgrade but the mock test server that qpid provided
> is changed / gone etc. So maybe the idea is to use an embed
Or if you want to use AMQP as the wire protocol - I’ve had success with
camel-amqp and artemis.
> On 25 Feb 2016, at 15:13, Matt Sicker wrote:
>
> You can use activemq-camel if you're using the openwire transport, too.
>
> On 25 February 2016 at 00:39, Claus Ibsen wrote:
>
>> The camel-jms c
camel-amqp is compiled with an older qpid-proton library I think.
We would need to upgrade but the mock test server that qpid provided
is changed / gone etc. So maybe the idea is to use an embedded artemis
as testing, just like we use amq for testing camel-jms.
Then we could likely upgrade qpid i
You can use activemq-camel if you're using the openwire transport, too.
On 25 February 2016 at 00:39, Claus Ibsen wrote:
> The camel-jms component would be the best.
>
>
> On Wed, Feb 24, 2016 at 10:37 PM, John D. Ament
> wrote:
> > All,
> >
> > I was wondering, whats the right component to use
I will try this myself later and let you know.
On Thu, Feb 25, 2016 at 2:05 PM, FabianChanton [via Camel]
wrote:
> I forgot to write that I only need to read from that queue.
>
> The server side requires each client to declare a queue on the default
> exchange to receive messages. To send message
I forgot to write that I only need to read from that queue.
The server side requires each client to declare a queue on the default
exchange to receive messages. To send messages the client uses pre-declared
queues and exchanges (this side works well, like you said).
So my problem only exists wh
That is strange because I write messages to queues on exchanges where
both are already declared and that works.
On Thu, Feb 25, 2016 at 1:43 PM, FabianChanton [via Camel]
wrote:
> I tried what I described without camel, by directly using the RabbitMQ Java
> Client. By directly using the client I
I tried what I described without camel, by directly using the RabbitMQ Java
Client. By directly using the client I am able to declare a queue on the
default exchange.
It seems the problem lies in the method declareExchangeAndQueue of the
RabbitMQEndpoint. This method calls channel.exchangeDeclare
Also, to be sure, is the default exchange and other exchanges on the same vhost?
On Thu, Feb 25, 2016 at 1:36 PM, Souciance Eqdam Rashti
wrote:
> Are you sure you have access to declare the queue on the default
> exchange? You can use the same user/password and login to the Rabbit
> webgui and pe
Are you sure you have access to declare the queue on the default
exchange? You can use the same user/password and login to the Rabbit
webgui and perform the same operation manually to verify.
I think it should work because I don't think endpoint declares the
exchange as well as just "/" means reve
Hello Souciance
Thanks for your answer!
The standard case you described works well for me.
However the following does not work:
I create an endpoint with the following URI:
rabbitmq://:/
(leaving the exchange part empty because i need to declare the queue on the
default exchange)
This causes
Hello Fabian
This is how the standard rabbit URI looks. rabbitmq://:/
Write in any exchange that you want and it will declare the queue on
that exchange.
Best Souciance
On Thu, Feb 25, 2016 at 11:24 AM, FabianChanton [via Camel]
wrote:
> Hi!
>
> We are using Camel CDI 1.2.0, Camel core 2.16.1
Hi!
We are using Camel CDI 1.2.0, Camel core 2.16.1 and Camel RabbitMQ 2.16.1 in
our project.
For this project, I need to declare a queue on the default exchange of an
existing RabbitMQ Server. If i set declare=true on my endpoint URI the
RabbitMQConsumer tries to declare the queue and the defaul
22 matches
Mail list logo
