Store variable in camel context for later use
Hi,
I need to store a date time variable in body. I need to use this variable in
different routes and change its date and time.
I am using following code for this.
${SYSDATE()}
I am a newbie in camel. Plz help.
Thanks,
Komal
--
View this message in context:
http://camel.465427.n5.nabble.com/Store-variable-in-camel-context-for-later-use-tp5743558.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Store variable in camel context for later use
Thanks a lot.. Will try it out ..
Regards,
Komal
Sent from my iPhone
On 20-Nov-2013, at 16:30, "Claus Ibsen-2 [via Camel]"
wrote:
> You can use a java bean and have methods to update date and time. And
> let Camel call this bean using its bean component etc.
>
>
> On Wed, Nov 20, 2013 at 7:36 AM, komal bhola <[hidden email]> wrote:
>
> > Hi,
> >
> > I need to store a date time variable in body. I need to use this variable
> > in
> > different routes and change its date and time.
> > I am using following code for this.
> >
> > ${SYSDATE()}
> >
> >
> > I am a newbie in camel. Plz help.
> >
> > Thanks,
> > Komal
> >
> >
> >
> > --
> > View this message in context:
> > http://camel.465427.n5.nabble.com/Store-variable-in-camel-context-for-later-use-tp5743558.html
> > Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
>
> --
> Claus Ibsen
> -
> Red Hat, Inc.
> Email: [hidden email]
> Twitter: davsclaus
> Blog: http://davsclaus.com
> Author of Camel in Action: http://www.manning.com/ibsen
>
>
> If you reply to this email, your message will be added to the discussion
> below:
> http://camel.465427.n5.nabble.com/Store-variable-in-camel-context-for-later-use-tp5743558p5743568.html
> To unsubscribe from Store variable in camel context for later use, click here.
> NAML
--
View this message in context:
http://camel.465427.n5.nabble.com/Store-variable-in-camel-context-for-later-use-tp5743558p5743569.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Handling soap request in http endpoint ? possible?
Hi , Currently I am using cxf endpoint to listen to soap requests. Actually I want to use http endpoint only to listen to soap requests. I need to provide different services on only 1 URL. So I want soap method name to be populated in camel headers, based on which I can call different different services. Please suggest a way out if any one has already tried this. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Handling-soap-request-in-http-endpoint-possible-tp5750524.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Handling soap request in http endpoint ? possible?
Hi I am still facing issue please help!! What i want to do is something like this --> http://0.0.0.0:6062/volt/SchedulingEngineWeb/services/CallSubscription?sessionSupport=true&enableJmx=true&enableTrace=true"; id="soap"> This endpoint receives soap requests from any web server. WEB Suppose if soap request is like below then i should set my operation code as "handle New Subscription" http://schemas.xmlsoap.org/soap/envelope/"; xmlns:sub="http://SubscriptionEngine.ibm.com";> SMART_API SMART_API ** 123 abc 99 WAP 111 abc 1 1 2011-10-27T16:02:11.389Z 2011-10-27T16:02:11.389Z http://www.w3.org/2001/XMLSchema-instance"/>http://www.w3.org/2001/XMLSchema-instance"/>http://www.w3.org/2001/XMLSchema-instance"/>http://www.w3.org/2001/XMLSchema-instance"/> Basically i do not want to use a cxf endpoint for soap requests. I want http endpoint itself. Also based on soap request my operation code should change dynamically. Please suggest. Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Handling-soap-request-in-http-endpoint-possible-tp5750524p5750709.html Sent from the Camel - Users mailing list archive at Nabble.com.
Hi I wanna use camel 's embedded in active mq
Hi ,
I have implemented camel with blueprint implementation.
Please provide some guide or tutorial. All i find are spring tutorials.
My Code is as follows:
Camel Context :
In between my transactions i want to send data to queue asynchronously.
Using other route i want to read messages from queue and process.
My Pom.xml:
org.apache.camel
camel-jms
${camelversion}
org.apache.activemq
activemq-camel
5.6.0
When i install my bundle in fuse a lot of extra bundles are installed. I dun
know why? Also my bundle is not get started.
Please help and suggest what am i doing wrong. What am i missing?
I dun wana run active mq separately, i want to use embedded activemq of
apapche camel.
Please help!!!
Regards,
Komal
--
View this message in context:
http://camel.465427.n5.nabble.com/Hi-I-wanna-use-camel-s-embedded-in-active-mq-tp5751012.html
Sent from the Camel - Users mailing list archive at Nabble.com.
activemq exception
Hi I am getting following exception while starting activemq. 15:27:06,185 | INFO | veMQ Broker: amq | KahaDBStore | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Stopping async queue tasks^M 15:27:06,185 | INFO | veMQ Broker: amq | KahaDBStore | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Stopping async topic tasks^M 15:27:06,185 | DEBUG | veMQ Broker: amq | ThreadPoolUtils | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Forcing shutdown of ExecutorService: org.apache.activemq.store.kahadb.KahaDBStore$StoreTaskExecutor@16a71e9^M 15:27:06,185 | DEBUG | veMQ Broker: amq | ThreadPoolUtils | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Forcing shutdown of ExecutorService: org.apache.activemq.store.kahadb.KahaDBStore$StoreTaskExecutor@15c977f^M 15:27:06,185 | INFO | veMQ Broker: amq | KahaDBStore | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Stopped KahaDB^M 15:27:06,185 | DEBUG | veMQ Broker: amq | MessageDatabase | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Checkpoint started.^M 15:27:06,350 | DEBUG | veMQ Broker: amq | MessageDatabase | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Checkpoint done.^M 15:27:06,664 | DEBUG | veMQ Broker: amq | ManagementContext| 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Unregistering MBean org.apache.activemq:type=Broker,brokerName=amq,Service=PersistenceAdapter,InstanceName=KahaDBPersistenceAdapter[D_\jboss-fuse-6.0.0.redhat-024\jboss-fuse-6.0.0.redhat-024\data\amq\kahadb]^M 15:27:06,667 | DEBUG | veMQ Broker: amq | ManagementContext| 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Unregistering MBean org.apache.activemq:type=Broker,brokerName=amq,service=Health^M 15:27:06,667 | DEBUG | veMQ Broker: amq | ManagementContext| 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Unregistering MBean org.apache.activemq:type=Broker,brokerName=amq^M 15:27:06,668 | DEBUG | veMQ Broker: amq | ThreadPoolUtils | 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Forcing shutdown of ExecutorService: java.util.concurrent.ThreadPoolExecutor@b5b633^M 15:27:06,668 | INFO | veMQ Broker: amq | BrokerService| 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Apache ActiveMQ 5.8.0.redhat-60024 (amq, ID:LTB0080116-64159-1399888241191-0:51) uptime 1.102 seconds^M 15:27:06,669 | INFO | veMQ Broker: amq | BrokerService| 114 - org.apache.activemq.activemq-osgi - 5.8.0.redhat-60024 | Apache ActiveMQ 5.8.0.redhat-60024 (amq, ID:LTB0080116-64159-1399888241191-0:51) is shutdown^M 15:27:06,669 | INFO | veMQ Broker: amq | ActiveMQServiceFactory | 128 - org.jboss.amq.mq-fabric - 6.0.0.redhat-024 | Broker amq failed to start. Will try again in 10 seconds^M 15:27:06,670 | INFO | veMQ Broker: amq | ActiveMQServiceFactory | 128 - org.jboss.amq.mq-fabric - 6.0.0.redhat-024 | Exception on start: java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616?maximumConnections=1000 due to: java.net.BindException: Address already in use: JVM_Bind^M java.io.IOException: Transport Connector could not be registered in JMX: Failed to bind to server socket: tcp://0.0.0.0:61616?maximumConnections=1000 due to: java.net.BindException: Address already in use: JVM_Bind^M at org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:27)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.apache.activemq.broker.BrokerService.registerConnectorMBean(BrokerService.java:1972)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.apache.activemq.broker.BrokerService.startTransportConnector(BrokerService.java:2434)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.apache.activemq.broker.BrokerService.startAllConnectors(BrokerService.java:2351)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.apache.activemq.broker.BrokerService.doStartBroker(BrokerService.java:655)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.apache.activemq.broker.BrokerService.startBroker(BrokerService.java:618)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.apache.activemq.broker.BrokerService.start(BrokerService.java:554)[114:org.apache.activemq.activemq-osgi:5.8.0.redhat-60024]^M at org.fusesource.mq.fabric.ActiveMQServiceFactory$ClusteredConfiguration$$anon$3.run(ActiveMQServiceFactory.scala:307)[128:org.jboss.amq.mq-fabric:6.0.0.redhat-024]^M Caused by: java.io.IOException: Failed to bind to server socket: tcp://0.0.0.0:61616?maximumConnections=1000 due to: jav
Re: Hi I wanna use camel 's embedded in active mq
Hi Claus, Thanks for the reply. I have successfully started activemq embedded in jboss-fuse. Now from my application which is camel based I want to send receive messages to that queue. For the same I have coded which I mentioned in my 1st post. When I install my application a lot of jasper, glassfish, etc bundles get downloaded. Also please guide me for sending messages to queue. As above written code of mine is not working. As i am using blueprint as a container. I find very less example online. Please guide.. Thanks Komal -- View this message in context: http://camel.465427.n5.nabble.com/Hi-I-wanna-use-camel-s-embedded-in-active-mq-tp5751012p5751529.html Sent from the Camel - Users mailing list archive at Nabble.com.
