Hi,
I am using Camel mail to send an email when something happens in a rabbitmq
queue.
I have all of my properties in a properties file.
I have the propertyplaceholder defined before camel context:
context:property-placeholder ignore-resource-not-found=true
location=classpath:xxx
Below is my
All,
I am getting the following exception when I made a redis hmget call.
According to the online doc: HMGET Get the values of all the given hash
fields CamelRedis.Key (String), CamelRedis.Fields (CollectionString)
Collection
Should return a collection of objects.
Stacktrace
Hi,
I have a json that needs to be converted into a map.
I used Jackson as dataformat and then gson
unmarshal ref=gson/
I noticed instead of hashmap I get linkedHashMap in the exchange
BodyTypejava.util.LinkedHashMap
Body{op=i, type=zones,
Okay I did something stupid..
Instead of setHeader headerName=CamelRedis.Values I did setHeader
headerName=CamelRedis.Value for hmset
But now I am having a really strange exception:
Stacktrace
Hi,
I have questions regarding the camel-spring-redis component.
I have a rabbitmq producer that send out a json.
From other people's suggestions I took the json and converts into a Map
which I can then use simple expression language.
Below is my configuration:
route
Found the answer here:
http://camel.465427.n5.nabble.com/Simple-td3242568.html#a3242571
Gordon
--
View this message in context:
http://camel.465427.n5.nabble.com/Simple-expression-with-JSON-and-redis-tp5760520p5760521.html
Sent from the Camel - Users mailing list archive at Nabble.com.
All,
I have a requirement where we take data from rabbitmq and insert them into
redis
Below is my exchange taken from stacktrace:
Exchange[
Id ID-MRT-GMH1119-49410-1418246041340-0-2
ExchangePattern InOptionalOut
Headers
All,
I am reading the oplog of Mongodb in my project in order to synch with
redis.
The BSON data I am capturing has the following format.
{
ts: Timestamp(1415124334, 1),
op: i,
ns: test.products,
o: {
_id: ObjectId(5459156e7950e8c18c094992),
item: card,
qty: 15
}
}
The problem I am
All,
In my sample code I am reading a json file and doing a jsonpath to do
content based routing.
Here is the simple route
from(file:src/data2/test.json?noop=true)
.choice()
.when(PredicateBuilder.isEqualTo(ExpressionBuilder.languageExpression(jsonpath,
$.op),
Claus,
I tried that approach first and did not work.
I took the maven java dsl archetype and changed the route to point to the
.json file and then added the additional route.
Do I need to add any other configurations or libraries?
Gordon
--
View this message in context:
Claus,
It looks like the problem with my json.
ts: Timestamp(1415124334, 1),
Once it is removed I had no problems.
The json file is from Mongodb oplog.
It is used to synchronize data between Mongodb and Redis.
Do you have suggestions for dealing with that name: value pair?
Maybe something
I guess the more appropriate question is how do I convert BSON into JSON.
Timestamp is not been converted into JSON is the problem.
Gordon
--
View this message in context:
http://camel.465427.n5.nabble.com/how-to-read-json-in-a-file-and-use-jsonpath-tp5759546p5759562.html
Sent from the Camel -
All,
I am trying to come up with a processing pattern for a business case.
Assume we have something like this form a queue (ActiveMQ/Rabbbitmq) does
not matter
Below is the json
{
name:xyz
address: 123 Somewhere, USA
ssn: 1234
}
For each name/value pair I want to make a call to the
Hi all,
I have a requirement where we would leverage redis as cache and Mongodb as
our backend.
So we would first do a query against redis cache, if no result can be found
we would then query against Mongodb for data. Assuming redis and Mongodb
components are working, what type of integration
HI,
We are trying to use Camel redis component when I found this following
article:
http://stackoverflow.com/questions/16428371/camel-redis-component-subscribe-to-a-channel-not-working
I tried to run this project (https://github.com/soumyasd/camelredisdemo) and
not able to see any results.
I ran
All,
I have a simple use case I am trying to implement.
We will be receiving data from websocket.
I am thinking about using poll consumer pattern to test for now.
Essentially I will have the following json coming thru the activemq queue.
{name: abc
address: xyz
}
Where the json does not
Thanks Claus.
I have came across the Composed Message Processor in my research before and
it does look like something we can leverage.
How do you incorporate JsonPath in this pattern?
Are there simple test cases I can use to illustrate the use of this pattern?
How about concurrency issue?
Can we
All,We have a use case where our Mongodb database needs to be able to synch
with Redis cache.I am thinking about using Mongodb and Camel component and
the tailable cursor consumer pattern.Has anyone have any experience with
this type of setup?Here is the workflow.Data is inserted into MongodbCamel
Great testimonials!
However, I am trying to understand when it is appropriate to use Akka within
the context of a Camel application? Maybe something along the line of the
following:
if your requirements are xyz then akka would/not be appropriate...
Assuming large steaming data coming from 1
All,
I am trying to investigate Akka and camel
Our use case is as follows:
Subscribe to websocket queue and retrieve json from the queue
process each json thru Camel routes (atomically)
assume large amount of data
What would the appropriate design as far as fail over/
dristributed/threading
Hi,I am trying to subscribe to websocket over STOMP.The websocket require
user/password authentication using WebSocketHttpHeaders. Has anyone tried it
before?If so, can someone share their experience and the
configurations/code?Thanks, Gordon
--
View this message in context:
21 matches
Mail list logo