date:20140701

[jira] [Commented] (AMQ-1940) Negative queue size (reproducible)

2014-07-01 Thread Wolfram Schlich (JIRA)


[ 
https://issues.apache.org/jira/browse/AMQ-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14049673#comment-14049673
 ] 

Wolfram Schlich commented on AMQ-1940:
--

We also experience this currently with ActiveMQ 5.8.0.

> Negative queue size (reproducible)
> --
>
> Key: AMQ-1940
> URL: https://issues.apache.org/jira/browse/AMQ-1940
> Project: ActiveMQ
>  Issue Type: Bug
>  Components: Broker
>Affects Versions: 5.2.0
> Environment: Found on Windows but reproduced under Linux
>Reporter: Vadim Chekan
>Assignee: Rob Davies
>Priority: Critical
> Fix For: 5.3.0
>
> Attachments: Main.java, Picture 6.png, QueuePurgeTest.java.diff.txt
>
>
> When you "purge" queue from web admin console, it zeroes queue message
> counter. But if you have an active consumer at that time which
> pre-fetched messages than your consumer will keep sending ack as it
> process messages from its buffer. ActiveMQ will keep decrement counter
> upon receiving each ack. So when consumer is done queue will show
> MINUS.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Commented] (AMQ-1693) Nagitive Number Of Pending Messages

2014-07-01 Thread Wolfram Schlich (JIRA)


[ 
https://issues.apache.org/jira/browse/AMQ-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14049674#comment-14049674
 ] 

Wolfram Schlich commented on AMQ-1693:
--

We experience negative queue sizes in ActiveMQ 5.8.0.

> Nagitive Number Of Pending Messages 
> 
>
> Key: AMQ-1693
> URL: https://issues.apache.org/jira/browse/AMQ-1693
> Project: ActiveMQ
>  Issue Type: Bug
>Affects Versions: 5.1.0
>Reporter: xiaoxiong duan
>Assignee: Rob Davies
> Fix For: 5.3.0
>
> Attachments: nagitive Number Of Pending Messages.jpg, negative queue 
> size.png
>
>
> After purged messege from queue, ActiveMQ admin console gives Nagitive Number 
> Of Pending Messages 



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Created] (AMQ-5257) 5.10.0 cannot startup with leveldb

2014-07-01 Thread angus.aqlu (JIRA)

angus.aqlu created AMQ-5257:
---

 Summary: 5.10.0 cannot startup with leveldb
 Key: AMQ-5257
 URL: https://issues.apache.org/jira/browse/AMQ-5257
 Project: ActiveMQ
  Issue Type: Bug
  Components: activemq-leveldb-store, Message Store
Affects Versions: 5.10.0
 Environment: jdk: 1.7.0_60-b19
zookeeper: 3.4.6
centos: 6.5
Reporter: angus.aqlu


Are configured as follows：(I used this configuration in version of 5.9.1 is ok.)







startup log: 
[amq@lin-mongo-65-181 bin]$ ./activemq console
INFO: Using default configuration
(you can configure options in one of these file: /etc/default/activemq 
/home/amq/.activemqrc)

INFO: Invoke the following command to create a configuration file
./activemq setup [ /etc/default/activemq | /home/amq/.activemqrc ]

INFO: Using java '/usr/bin/java'
INFO: Starting in foreground, this is just for debugging purposes (stop process 
by pressing CTRL+C)
Java Runtime: Oracle Corporation 1.7.0_60 /usr/java/jdk1.7.0_60/jre
  Heap sizes: current=2010624k  free=1979104k  max=5592576k
JVM args: -Xms2G -Xmx6G -Djava.util.logging.config.file=logging.properties 
-Djava.security.auth.login.config=/home/amq/apache-activemq-5.10.0/conf/login.config
 -Dcom.sun.management.jmxremote.port=11099 
-Dcom.sun.management.jmxremote.password.file=/home/amq/apache-activemq-5.10.0/conf/jmx.password
 
-Dcom.sun.management.jmxremote.access.file=/home/amq/apache-activemq-5.10.0/conf/jmx.access
 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote 
-Djava.awt.headless=true -Djava.io.tmpdir=/home/amq/apache-activemq-5.10.0/tmp 
-Dactivemq.classpath=/home/amq/apache-activemq-5.10.0/conf; 
-Dactivemq.home=/home/amq/apache-activemq-5.10.0 
-Dactivemq.base=/home/amq/apache-activemq-5.10.0 
-Dactivemq.conf=/home/amq/apache-activemq-5.10.0/conf -Dactivemq.data=/amq_data
Extensions classpath:
  
[/home/amq/apache-activemq-5.10.0/lib,/home/amq/apache-activemq-5.10.0/lib/camel,/home/amq/apache-activemq-5.10.0/lib/optional,/home/amq/apache-activemq-5.10.0/lib/web,/home/amq/apache-activemq-5.10.0/lib/extra]
ACTIVEMQ_HOME: /home/amq/apache-activemq-5.10.0
ACTIVEMQ_BASE: /home/amq/apache-activemq-5.10.0
ACTIVEMQ_CONF: /home/amq/apache-activemq-5.10.0/conf
ACTIVEMQ_DATA: /amq_data
Loading message broker from: xbean:activemq.xml
 INFO |AbstractApplicationContext.java:510| Refreshing 
org.apache.activemq.xbean.XBeanBrokerFactory$1@781efa43: startup date [Wed Jul 
02 14:43:11 CST 2014]; root of context hierarchy
 INFO |BrokerService.java:636| Using Persistence Adapter: Replicated 
LevelDB[/amq_data/leveldb, 
192.168.65.183:2181,192.168.65.184:2181,192.168.65.185:2181//activemq/leveldb-stores]
 INFO |ZKClient.java:343| Starting StateChangeDispatcher
 INFO |Environment.java:100| Client 
environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT
 INFO |Environment.java:100| Client 
environment:host.name=lin-mongo-65-181.ofcardnis
 INFO |Environment.java:100| Client environment:java.version=1.7.0_60
 INFO |Environment.java:100| Client environment:java.vendor=Oracle Corporation
 INFO |Environment.java:100| Client 
environment:java.home=/usr/java/jdk1.7.0_60/jre
 INFO |Environment.java:100| Client 
environment:java.class.path=/home/amq/apache-activemq-5.10.0/bin/activemq.jar
 INFO |Environment.java:100| Client 
environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
 INFO |Environment.java:100| Client 
environment:java.io.tmpdir=/home/amq/apache-activemq-5.10.0/tmp
 INFO |Environment.java:100| Client environment:java.compiler=
 INFO |Environment.java:100| Client environment:os.name=Linux
 INFO |Environment.java:100| Client environment:os.arch=amd64
 INFO |Environment.java:100| Client environment:os.version=2.6.32-431.el6.x86_64
 INFO |Environment.java:100| Client environment:user.name=amq
 INFO |Environment.java:100| Client environment:user.home=/home/amq
 INFO |Environment.java:100| Client 
environment:user.dir=/home/amq/apache-activemq-5.10.0/bin
 INFO |ZooKeeper.java:438| Initiating client connection, 
connectString=192.168.65.183:2181,192.168.65.184:2181,192.168.65.185:2181 
sessionTimeout=2000 
watcher=org.apache.activemq.leveldb.replicated.groups.ZKClient@63a06d20
 WARN |ClientCnxn.java:949| SASL configuration failed: 
javax.security.auth.login.LoginException: No JAAS configuration section named 
'Client' was found in specified JAAS configuration file: 
'/home/amq/apache-activemq-5.10.0/conf/login.config'. Will continue connection 
to Zookeeper server without SASL authentication, if Zookeeper server allows it.
 INFO |ClientCnxn.java:966| Opening socket connection to server 
192.168.65.185/192.168.65.185:2181
 WARN |ZKClient.java:222| unprocessed event state: AuthFailed
 INFO |ClientCnxn.java:849| Socket connection established to 
192.168.65.185/192.168.65.185:2181, initiating session
 INFO |ClientCnxn

[jira] [Commented] (AMQ-2009) Problem with message dispatch after a while

2014-07-01 Thread Rural Hunter (JIRA)


[ 
https://issues.apache.org/jira/browse/AMQ-2009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14049668#comment-14049668
 ] 

Rural Hunter commented on AMQ-2009:
---

Me too with 5.9.0. I always see several messages(usually less than 5) stuck in 
the queue while there are active consumers. My consumers are implemented by 
MessageListener. This is not a problem only caused by 
multi-consumers/providers. I have seen this on a queue with only one provider 
and one consumer. For example, my latest case: the queue is enqueued with only 
3 messages total and 2 are consumed but one seems left in the queue forever. 
Sometimes the message can be consumed by restarting the consumer but sometime 
it doesn't help.

> Problem with message dispatch after a while
> ---
>
> Key: AMQ-2009
> URL: https://issues.apache.org/jira/browse/AMQ-2009
> Project: ActiveMQ
>  Issue Type: Bug
>  Components: Broker
>Affects Versions: 5.1.0, 5.2.0
>Reporter: Rajani Chennamaneni
>Assignee: Rob Davies
> Fix For: NEEDS_REVIEW
>
> Attachments: AMQ-2009Testcase2.zip, 
> DispatchMultipleConsumersTest.java, JConsole-screenshot.jpg, 
> consumertest.zip, testcase.zip
>
>
> Messages are not getting dispatched after a while (although it accepts new 
> incoming messages) until restart of the broker. This problem is described in 
> several posts.
> http://www.nabble.com/Pending-Messages-are-shown-in-ActiveMQ-td20241332.html
> http://www.nabble.com/Consumer-Listener-stop-receving-message-until-ActiveMQ-restart-td20355247.html
> http://www.nabble.com/Stuck-messages---Dispatch-issues-td20467949.html
> There was also an issue opened in Spring project for this thinking it was 
> Spring problem.
> http://jira.springframework.org/browse/SPR-5110
> I am not able to reproduce with Junit test case having BrokerService started 
> with in the test case. I guess I am not hitting the right stress conditions 
> this way. But when I run the test case against an externally running ActiveMQ 
> instance backed with oracle database persistence, it is reproducible most of 
> the times. This is not a every time failure situation, it takes more time 
> once than the other.
> I was able to hit this situation of stuck messages on queue using following 
> scenario most of the times:
> 1) Start 2 concurrent consumers for the queue using Spring's 
> DefaultMessageListenerContainer using cacheLevelName as CACHE_CONSUMER
> 2) Send messages using JMETER 2.3.2 to the queue on ActiveMQ stand alone 
> broker instance with 50 threads looping 20 times.
> 3) After a while, you will notice that Spring logs that no messages are being 
> received but the messages are shown jconsole of ActiveMQ and the database 
> backing it for persistence.
> But in 5.2 RC3, the problem is that it dispatches duplicate messages and does 
> not remove them from broker's database after acknowledge properly.
> Attached test case might help to reproduce when run against externally 
> running stand alone ActiveMQ broker. Another way to see the problem is that 
> try to load test using JMETER by sending messages to a queue with a camel 
> route that moves messages from this queue to another and you will notice that 
> it stops moving after while or copied duplicates in case of 5.2 RC3.
> Sorry about such a huge description but it is a real problem! A different 
> team at our company are having this issue in production with 5.1. They are 
> using it as an embedded broker with derby for persistence.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Created] (AMQNET-479) Connection timeout is not working when ActiveMQ service is Down

2014-07-01 Thread rajesh (JIRA)

rajesh created AMQNET-479:
-

 Summary: Connection timeout is not working when ActiveMQ service 
is Down
 Key: AMQNET-479
 URL: https://issues.apache.org/jira/browse/AMQNET-479
 Project: ActiveMQ .Net
  Issue Type: Bug
  Components: ActiveMQ, NMS
Affects Versions: 1.6.0
 Environment: DotNet Framework 4.0, Apache.Nms 1.6.0.3083
Apache.Nms.ActiveMQ 1.6.1.3210,1.6.2.3271
Reporter: rajesh
Assignee: Jim Gomes


Application/control is hanging when activeMQ is down while creating connection 
and publishing a message using Topic

unable to get the NmsConnectionException when activeMQ down





--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Resolved] (AMQ-5224) XA pooled connection factories are not recoverable

2014-07-01 Thread Timothy Bish (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Timothy Bish resolved AMQ-5224.
---

   Resolution: Fixed
Fix Version/s: 5.11.0

Marking this as resolved since no further feedback received since the patches 
were applied. 

> XA pooled connection factories are not recoverable
> --
>
> Key: AMQ-5224
> URL: https://issues.apache.org/jira/browse/AMQ-5224
> Project: ActiveMQ
>  Issue Type: Bug
>Affects Versions: 5.9.1, 5.10.0
>Reporter: Guillaume Nodet
> Fix For: 5.11.0
>
>
> PooledConnectionFactory#setConnectionFactory hides the XAConnectionFactory 
> interface which is used by the resource manager.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Resolved] (AMQ-5140) ArithmeticException: / by zero in HealthView.healthList() when using JMX-Health-Operations

2014-07-01 Thread Timothy Bish (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Timothy Bish resolved AMQ-5140.
---

Resolution: Fixed

Tested using this configuration against 5.10 and no issue.  Provide a JUnit 
test that fails against v5.10.0 or later if you can.

> ArithmeticException: / by zero in HealthView.healthList() when using 
> JMX-Health-Operations
> --
>
> Key: AMQ-5140
> URL: https://issues.apache.org/jira/browse/AMQ-5140
> Project: ActiveMQ
>  Issue Type: Bug
>  Components: Broker, JMX
>Affects Versions: 5.8.0
> Environment: ActiveMQ 5.8.0, hawtio 1.3.0
>Reporter: Tom M.
> Fix For: 5.10.0
>
> Attachments: activemq.schedulerSupport.xml
>
>
> Using hawtio, navigate to activeMQ, select Health in Tree, then Operations.
> Both operations Health() and Health list() lead to the exception, although in 
> the attributes section everything is fine!?
> Status: Good 
> {noformat}
> java.lang.ArithmeticException: / by zero
>   at 
> org.apache.activemq.broker.jmx.HealthView.healthList(HealthView.java:158)
>   at org.apache.activemq.broker.jmx.HealthView.health(HealthView.java:51)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
>   at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>   at java.lang.reflect.Method.invoke(Unknown Source)
>   at sun.reflect.misc.Trampoline.invoke(Unknown Source)
>   at sun.reflect.GeneratedMethodAccessor17.invoke(Unknown Source)
>   at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>   at java.lang.reflect.Method.invoke(Unknown Source)
>   at sun.reflect.misc.MethodUtil.invoke(Unknown Source)
>   at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.MBeanIntrospector.invokeM(Unknown Source)
>   at com.sun.jmx.mbeanserver.PerInterface.invoke(Unknown Source)
>   at com.sun.jmx.mbeanserver.MBeanSupport.invoke(Unknown Source)
>   at javax.management.StandardMBean.invoke(Unknown Source)
>   at 
> org.apache.activemq.broker.jmx.AnnotatedMBean.invoke(AnnotatedMBean.java:198)
>   at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(Unknown Source)
>   at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:98)
>   at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:40)
>   at 
> org.jolokia.handler.JsonRequestHandler.handleRequest(JsonRequestHandler.java:89)
>   at 
> org.jolokia.backend.MBeanServerExecutorLocal.handleRequest(MBeanServerExecutorLocal.java:109)
>   at 
> org.jolokia.backend.MBeanServerHandler.dispatchRequest(MBeanServerHandler.java:102)
>   at 
> org.jolokia.backend.LocalRequestDispatcher.dispatchRequest(LocalRequestDispatcher.java:98)
>   at 
> org.jolokia.backend.BackendManager.callRequestDispatcher(BackendManager.java:409)
>   at 
> org.jolokia.backend.BackendManager.handleRequest(BackendManager.java:158)
>   at 
> org.jolokia.http.HttpRequestHandler.executeRequest(HttpRequestHandler.java:197)
>   at 
> org.jolokia.http.HttpRequestHandler.handlePostRequest(HttpRequestHandler.java:137)
>   at org.jolokia.http.AgentServlet$2.handleRequest(AgentServlet.java:399)
>   at org.jolokia.http.AgentServlet.handle(AgentServlet.java:287)
>   at org.jolokia.http.AgentServlet.doPost(AgentServlet.java:256)
>   at javax.servlet.http.HttpServlet.service(HttpServlet.java:713)
>   at javax.servlet.http.HttpServlet.service(HttpServlet.java:806)
>   at 
> org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:652)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1329)
>   at io.hawt.web.AuthenticationFilter$2.run(AuthenticationFilter.java:143)
>   at java.security.AccessController.doPrivileged(Native Method)
>   at javax.security.auth.Subject.doAs(Unknown Source)
>   at 
> io.hawt.web.AuthenticationFilter.executeAs(AuthenticationFilter.java:140)
>   at 
> io.hawt.web.AuthenticationFilter.doFilter(AuthenticationFilter.java:108)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at io.hawt.web.CORSFilter.doFilter(CORSFilter.java:42)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at 
> org.ops4j.pax.web.service.internal.WelcomeFilesFilter.doFilter(WelcomeFilesFilter.java:193)
>   at 
> org.eclipse.jetty.servlet.Servl

[jira] [Resolved] (AMQ-5256) AMQP WARN Transport Connection failed: java.io.IOException

2014-07-01 Thread Gary Tully (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Gary Tully resolved AMQ-5256.
-

Resolution: Fixed

fix and test in http://git-wip-us.apache.org/repos/asf/activemq/commit/5aef16ad

> AMQP WARN  Transport Connection failed: java.io.IOException
> ---
>
> Key: AMQ-5256
> URL: https://issues.apache.org/jira/browse/AMQ-5256
> Project: ActiveMQ
>  Issue Type: Bug
>  Components: AMQP
>Affects Versions: 5.10.0
>Reporter: Gary Tully
>Assignee: Gary Tully
>  Labels: IOException, amqp, hang
> Fix For: 5.11.0
>
>
> concurrent AMQP connection, client hung on half closed connection, waiting 
> for response to open.{code}   java.lang.Thread.State: WAITING (on object 
> monitor)
>   at java.lang.Object.wait(Native Method)
>   - waiting on <7df15ba78> (a 
> org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
>   at java.lang.Object.wait(Object.java:485)
>   at 
> org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.open(ConnectionEndpoint.java:154)
>   - locked <7df15ba78> (a 
> org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
>   - locked <7df15ba78> (a 
> org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
>   at 
> org.apache.qpid.amqp_1_0.client.Connection.(Connection.java:284)
>   at 
> org.apache.qpid.amqp_1_0.client.Connection.(Connection.java:143)
>   at 
> org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl.connect(ConnectionImpl.java:115)
>   - locked <7df8bd048> (a java.lang.Object)
>   at 
> org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl.start(ConnectionImpl.java:284){code}
> Broker log contains:{code}
> [ActiveMQ Transport: tcp:///127.0.0.1:64496@64488] - WARN  
> Transport - Transport Connection to: tcp://127.0.0.1:64496 failed: 
> java.io.IOException{code}



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Created] (AMQ-5256) AMQP WARN Transport Connection failed: java.io.IOException

2014-07-01 Thread Gary Tully (JIRA)

Gary Tully created AMQ-5256:
---

 Summary: AMQP WARN  Transport Connection failed: 
java.io.IOException
 Key: AMQ-5256
 URL: https://issues.apache.org/jira/browse/AMQ-5256
 Project: ActiveMQ
  Issue Type: Bug
  Components: AMQP
Affects Versions: 5.10.0
Reporter: Gary Tully
Assignee: Gary Tully
 Fix For: 5.11.0


concurrent AMQP connection, client hung on half closed connection, waiting for 
response to open.{code}   java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waiting on <7df15ba78> (a 
org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
at java.lang.Object.wait(Object.java:485)
at 
org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.open(ConnectionEndpoint.java:154)
- locked <7df15ba78> (a 
org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
- locked <7df15ba78> (a 
org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
at 
org.apache.qpid.amqp_1_0.client.Connection.(Connection.java:284)
at 
org.apache.qpid.amqp_1_0.client.Connection.(Connection.java:143)
at 
org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl.connect(ConnectionImpl.java:115)
- locked <7df8bd048> (a java.lang.Object)
at 
org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl.start(ConnectionImpl.java:284){code}
Broker log contains:{code}
[ActiveMQ Transport: tcp:///127.0.0.1:64496@64488] - WARN  
Transport - Transport Connection to: tcp://127.0.0.1:64496 failed: 
java.io.IOException{code}




--
This message was sent by Atlassian JIRA
(v6.2#6252)

Re: Camel Routes

2014-07-01 Thread Ritwick

Thanks for your response Claus - yes, I have already added the query in the
Camel discussion forum at
http://camel.465427.n5.nabble.com/Issue-with-Camel-td5753081.html.
If you could take a look at it and respond, that will be great.

Thanks,
Ritwick.


On Tue, Jul 1, 2014 at 6:22 AM, Claus Ibsen [via ActiveMQ] <
ml-node+s2283324n4682696...@n4.nabble.com> wrote:

> Hi
>
> Yeah this is ActiveMQ forum so better ask at Camel forum / user mailing
> list
> http://camel.apache.org/discussion-forums.html
> http://camel.apache.org/mailing-lists.html
>
>
> On Mon, Jun 30, 2014 at 11:11 PM, Ritwick <[hidden email]
> > wrote:
>
> > Hi,
> > I am not sure if this is the correct Camel forum for this issue I am
> having.
> > However, I am unable to find an appropriate forum - so I am posting my
> > question here. It will be great if someone can either guide me to the
> > correct forum or better still rectify the issue I am facing.
> > Here is what I need to do - expose a restlet endpoint to accept data;
> use
> > this data as input to an external SOAP web service and send back the
> > response in JSON format back to the caller...
> > Here is what I have done...however, I am getting the following error
> while
> > Camel tries to call the Web Service...can anyone guide me here? Thanks.
> >
> > 2014-06-30 14:09:24,987 [tlet-1846031557] WARN  PhaseInterceptorChain
> > - Interceptor for
> > {http://www.webserviceX.NET/}CurrencyConvertor#{
> http://www.webserviceX.NET/}ConversionRate
> > has thrown exception, unwinding now
> > java.lang.ClassCastException: ClassCastException invoking
> > http://www.webservicex.net/CurrencyConvertor.asmx:
> > org.restlet.data.Parameter cannot be cast to java.lang.String
> >
> >
> > public class IntegrationTest extends CamelTestSupport {
> >
> > @org.junit.Test
> > public void integTest() throws Exception {
> > //trying to simulate the rest service call...
> >
> > template.sendBodyAndHeader("restlet:http://localhost:8080/convert/{data}?restletMethods=get";,
>
> > "Body does not matter here", "data",
> > "{\"FromCurrency\":\"AUD\",\"ToCurrency\":\"USD\"}");
> >
> > }
> >
> >
> > @Override
> > protected RouteBuilder createRouteBuilder() throws Exception {
> > return new RouteBuilder() {
> > @Override
> > public void configure() throws Exception {
> > System.out.println("In Counfigure");
> >
> > String cxfEndpoint =
> > "cxf://http://www.webservicex.net/CurrencyConvertor.asmx?";
> > +
> > "wsdlURL=http://www.webservicex.net/CurrencyConvertor.asmx?wsdl&";
> > + "serviceName={
> http://www.webserviceX.NET/}CurrencyConvertor&";
> > + "portName={
> http://www.webserviceX.NET/}CurrencyConvertorSoap&";
> > + "dataFormat=MESSAGE";
> >
> > XmlJsonDataFormat xmlJsonFormat = new
> XmlJsonDataFormat();
> > SoapJaxbDataFormat soap = new
> > SoapJaxbDataFormat("net.webservicex", new
> > ServiceInterfaceStrategy(CurrencyConvertorSoap.class, true));
> >
> > GsonDataFormat gson = new
> GsonDataFormat(ConversionRate.class);
> >
> gson.setFieldNamingPolicy(FieldNamingPolicy.UPPER_CAMEL_CASE);
> >
> > from("restlet:http://localhost:8080/convert/{data}?restletMethods=get";).routeId("Restlet")
>
> > .process(new Processor() {
> > @Override
> > public void process(Exchange
> exchange) throws Exception {
> > String data = (String)
> URLDecoder.decode((String)
> > exchange.getIn().getHeader("data"), "UTF-8");
> >
> System.out.println(data);
> > // get the mail body as
> a String
> >
> exchange.getIn().setBody(data);
> >
> Response.getCurrent().setStatus(Status.SUCCESS_OK);
> > }
> >
> > })
> > .unmarshal(gson)
> > .marshal(soap)
> > .log("${body}")
> > .to(cxfEndpoint)
> > .unmarshal(soap)
> > .marshal(xmlJsonFormat);
> > .log("${body}");
> > }
> > };
> > }
> > }
> >
> >
> >
> >
> > --
> > View this message in context:
> http://activemq.2283324.n4.nabble.com/Camel-Routes-tp4682675.html
> > Sent from the ActiveMQ - Dev 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
> hawtio: http://hawt.io/
> fabric8: h

[jira] [Reopened] (AMQ-5140) ArithmeticException: / by zero in HealthView.healthList() when using JMX-Health-Operations

2014-07-01 Thread Tom M. (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Tom M. reopened AMQ-5140:
-


I finally found the cause and how to reproduce this exception:

 --> call JMX-Operation health() and the 
exception occurs.

  --> everything is fine!

> ArithmeticException: / by zero in HealthView.healthList() when using 
> JMX-Health-Operations
> --
>
> Key: AMQ-5140
> URL: https://issues.apache.org/jira/browse/AMQ-5140
> Project: ActiveMQ
>  Issue Type: Bug
>  Components: Broker, JMX
>Affects Versions: 5.8.0
> Environment: ActiveMQ 5.8.0, hawtio 1.3.0
>Reporter: Tom M.
> Fix For: 5.10.0
>
> Attachments: activemq.schedulerSupport.xml
>
>
> Using hawtio, navigate to activeMQ, select Health in Tree, then Operations.
> Both operations Health() and Health list() lead to the exception, although in 
> the attributes section everything is fine!?
> Status: Good 
> {noformat}
> java.lang.ArithmeticException: / by zero
>   at 
> org.apache.activemq.broker.jmx.HealthView.healthList(HealthView.java:158)
>   at org.apache.activemq.broker.jmx.HealthView.health(HealthView.java:51)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
>   at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>   at java.lang.reflect.Method.invoke(Unknown Source)
>   at sun.reflect.misc.Trampoline.invoke(Unknown Source)
>   at sun.reflect.GeneratedMethodAccessor17.invoke(Unknown Source)
>   at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>   at java.lang.reflect.Method.invoke(Unknown Source)
>   at sun.reflect.misc.MethodUtil.invoke(Unknown Source)
>   at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.MBeanIntrospector.invokeM(Unknown Source)
>   at com.sun.jmx.mbeanserver.PerInterface.invoke(Unknown Source)
>   at com.sun.jmx.mbeanserver.MBeanSupport.invoke(Unknown Source)
>   at javax.management.StandardMBean.invoke(Unknown Source)
>   at 
> org.apache.activemq.broker.jmx.AnnotatedMBean.invoke(AnnotatedMBean.java:198)
>   at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(Unknown Source)
>   at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:98)
>   at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:40)
>   at 
> org.jolokia.handler.JsonRequestHandler.handleRequest(JsonRequestHandler.java:89)
>   at 
> org.jolokia.backend.MBeanServerExecutorLocal.handleRequest(MBeanServerExecutorLocal.java:109)
>   at 
> org.jolokia.backend.MBeanServerHandler.dispatchRequest(MBeanServerHandler.java:102)
>   at 
> org.jolokia.backend.LocalRequestDispatcher.dispatchRequest(LocalRequestDispatcher.java:98)
>   at 
> org.jolokia.backend.BackendManager.callRequestDispatcher(BackendManager.java:409)
>   at 
> org.jolokia.backend.BackendManager.handleRequest(BackendManager.java:158)
>   at 
> org.jolokia.http.HttpRequestHandler.executeRequest(HttpRequestHandler.java:197)
>   at 
> org.jolokia.http.HttpRequestHandler.handlePostRequest(HttpRequestHandler.java:137)
>   at org.jolokia.http.AgentServlet$2.handleRequest(AgentServlet.java:399)
>   at org.jolokia.http.AgentServlet.handle(AgentServlet.java:287)
>   at org.jolokia.http.AgentServlet.doPost(AgentServlet.java:256)
>   at javax.servlet.http.HttpServlet.service(HttpServlet.java:713)
>   at javax.servlet.http.HttpServlet.service(HttpServlet.java:806)
>   at 
> org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:652)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1329)
>   at io.hawt.web.AuthenticationFilter$2.run(AuthenticationFilter.java:143)
>   at java.security.AccessController.doPrivileged(Native Method)
>   at javax.security.auth.Subject.doAs(Unknown Source)
>   at 
> io.hawt.web.AuthenticationFilter.executeAs(AuthenticationFilter.java:140)
>   at 
> io.hawt.web.AuthenticationFilter.doFilter(AuthenticationFilter.java:108)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at io.hawt.web.CORSFilter.doFilter(CORSFilter.java:42)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at 
> org.ops4j.pax.web.service.internal.WelcomeFilesFilter.doFilter(WelcomeFilesFilter.java:193)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$Cac

[jira] [Updated] (AMQ-5140) ArithmeticException: / by zero in HealthView.healthList() when using JMX-Health-Operations

2014-07-01 Thread Tom M. (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Tom M. updated AMQ-5140:


Attachment: activemq.schedulerSupport.xml

> ArithmeticException: / by zero in HealthView.healthList() when using 
> JMX-Health-Operations
> --
>
> Key: AMQ-5140
> URL: https://issues.apache.org/jira/browse/AMQ-5140
> Project: ActiveMQ
>  Issue Type: Bug
>  Components: Broker, JMX
>Affects Versions: 5.8.0
> Environment: ActiveMQ 5.8.0, hawtio 1.3.0
>Reporter: Tom M.
> Fix For: 5.10.0
>
> Attachments: activemq.schedulerSupport.xml
>
>
> Using hawtio, navigate to activeMQ, select Health in Tree, then Operations.
> Both operations Health() and Health list() lead to the exception, although in 
> the attributes section everything is fine!?
> Status: Good 
> {noformat}
> java.lang.ArithmeticException: / by zero
>   at 
> org.apache.activemq.broker.jmx.HealthView.healthList(HealthView.java:158)
>   at org.apache.activemq.broker.jmx.HealthView.health(HealthView.java:51)
>   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>   at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
>   at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>   at java.lang.reflect.Method.invoke(Unknown Source)
>   at sun.reflect.misc.Trampoline.invoke(Unknown Source)
>   at sun.reflect.GeneratedMethodAccessor17.invoke(Unknown Source)
>   at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
>   at java.lang.reflect.Method.invoke(Unknown Source)
>   at sun.reflect.misc.MethodUtil.invoke(Unknown Source)
>   at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.StandardMBeanIntrospector.invokeM2(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.MBeanIntrospector.invokeM(Unknown Source)
>   at com.sun.jmx.mbeanserver.PerInterface.invoke(Unknown Source)
>   at com.sun.jmx.mbeanserver.MBeanSupport.invoke(Unknown Source)
>   at javax.management.StandardMBean.invoke(Unknown Source)
>   at 
> org.apache.activemq.broker.jmx.AnnotatedMBean.invoke(AnnotatedMBean.java:198)
>   at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(Unknown 
> Source)
>   at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(Unknown Source)
>   at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:98)
>   at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:40)
>   at 
> org.jolokia.handler.JsonRequestHandler.handleRequest(JsonRequestHandler.java:89)
>   at 
> org.jolokia.backend.MBeanServerExecutorLocal.handleRequest(MBeanServerExecutorLocal.java:109)
>   at 
> org.jolokia.backend.MBeanServerHandler.dispatchRequest(MBeanServerHandler.java:102)
>   at 
> org.jolokia.backend.LocalRequestDispatcher.dispatchRequest(LocalRequestDispatcher.java:98)
>   at 
> org.jolokia.backend.BackendManager.callRequestDispatcher(BackendManager.java:409)
>   at 
> org.jolokia.backend.BackendManager.handleRequest(BackendManager.java:158)
>   at 
> org.jolokia.http.HttpRequestHandler.executeRequest(HttpRequestHandler.java:197)
>   at 
> org.jolokia.http.HttpRequestHandler.handlePostRequest(HttpRequestHandler.java:137)
>   at org.jolokia.http.AgentServlet$2.handleRequest(AgentServlet.java:399)
>   at org.jolokia.http.AgentServlet.handle(AgentServlet.java:287)
>   at org.jolokia.http.AgentServlet.doPost(AgentServlet.java:256)
>   at javax.servlet.http.HttpServlet.service(HttpServlet.java:713)
>   at javax.servlet.http.HttpServlet.service(HttpServlet.java:806)
>   at 
> org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:652)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1329)
>   at io.hawt.web.AuthenticationFilter$2.run(AuthenticationFilter.java:143)
>   at java.security.AccessController.doPrivileged(Native Method)
>   at javax.security.auth.Subject.doAs(Unknown Source)
>   at 
> io.hawt.web.AuthenticationFilter.executeAs(AuthenticationFilter.java:140)
>   at 
> io.hawt.web.AuthenticationFilter.doFilter(AuthenticationFilter.java:108)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at io.hawt.web.CORSFilter.doFilter(CORSFilter.java:42)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at 
> org.ops4j.pax.web.service.internal.WelcomeFilesFilter.doFilter(WelcomeFilesFilter.java:193)
>   at 
> org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1300)
>   at 
> org.eclipse.jetty.servlet.ServletHandler.doHandle(

Re: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

2014-07-01 Thread Timothy Bish


On 07/01/2014 11:18 AM, Lyubov Romanchuk wrote:

But what is the purpose of checkForDuplicates? And which functionality will be 
disabled in case it's false.

Surprisingly it checks for duplicates and filter them out in cases where 
your client might receive a duplicate message from the broker such as 
failover disconnect / reconnect.



-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com]
Sent: Tuesday, July 01, 2014 6:08 PM
To: dev@activemq.apache.org
Subject: Re: [ActiveMQCPP 3.8.2|Linux] crash in 
activemq::core::ConnectionAudit::isDuplicate

On 07/01/2014 10:37 AM, Lyubov Romanchuk wrote:

Hi,

Thank you for the response.
1) It's very hard to support the test case for reproduction of this
issue because  I don't know the root cause of the core and we have too
complicated environment in order to try to simulate this behaviour
2) It seems like ConnectionAudit::isDuplicate is not thread safe but may be 
called from different threads.
3) And I'm not sure that I understand correctly the purposes of isDuplicate. 
Could you please explain what is it used for and if it's configurable?

Best regards,
Lyuba

-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com]
Sent: Tuesday, July 01, 2014 12:20 AM
To: dev@activemq.apache.org
Subject: Re: [ActiveMQCPP 3.8.2|Linux] crash in
activemq::core::ConnectionAudit::isDuplicate

On 06/29/2014 10:16 AM, Lyubov Romanchuk wrote:

Hi,
We use activemqcpp library from the version 3.8.2.
Sometimes there is a crash in activemq::core::ConnectionAudit::isDuplicate.
Could you please advise with this core - what may cause such crash, is it a 
known issue?

Here is the call stack from one of the cores:

* 1 Thread 32129  0x760417ab in
decaf::lang::PointerComparator::operator()
(this=0x874ce1c, left=..., right=...) at decaf/lang/Pointer.h:243
(gdb) bt
#0  0x760417ab in
decaf::lang::PointerComparator::operator()
(this=0x874ce1c, left=..., right=...) at decaf/lang/Pointer.h:243
#1  0x76108cad in
std::_Rb_tree,
std::pair const,
decaf::lang::Pointer >,
std::_Select1st
const, decaf::lang::Pointer > >,
decaf::lang::PointerComparator,
std::allocator
const, decaf::lang::Pointer > > >::find
(this=0x874ce14, __k=...) at
/packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_tree.h:669
#2  0x76100316 in 
decaf::util::StlMap, 
decaf::lang::Pointer, 
decaf::lang::PointerComparator >::containsKey (this=0x874ce10, key=...)
   at
/packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_map.h:345
#3  0x760fb57a in activemq::core::ConnectionAudit::isDuplicate
(this=0x874cdf4, dispatcher=0xc0a7e94, message=...) at
decaf/util/StlMap.h:794
#4  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate
(this=0x8a74408, dispatcher=0x32332d46, message=...) at
decaf/util/concurrent/atomic/AtomicRefCounter.h:46
#5  0x76141bb5 in
activemq::core::kernels::ActiveMQConsumerKernel::dispatch
(this=0xc0a7e88, dispatch=...) at
activemq/core/kernels/ActiveMQSessionKernel.h:330
#6  0x760e4b1b in activemq::core::ActiveMQSessionExecutor::dispatch
(this=0x32332d46, dispatch=...) at decaf/lang/Pointer.h:258
#7  0x760e4e92 in activemq::core::ActiveMQSessionExecutor::iterate
(this=0x5a5676a0) at activemq/core/ActiveMQSessionExecutor.cpp:181
#8  0x762659b6 in activemq::threads::DedicatedTaskRunner::run
(this=0x5a6935e0) at activemq/threads/DedicatedTaskRunner.cpp:141
#9  0x7646285e in decaf::lang::Thread::run (this=0x32332d46) at
decaf/lang/Thread.cpp:141
#10 0x76421c17 in (anonymous namespace)::runCallback (arg=0x5abb66e8)
at decaf/internal/util/concurrent/Threading.cpp:266
#11 0x76421b89 in (anonymous namespace)::threadEntryMethod
(arg=0x5abb66e8) at decaf/internal/util/concurrent/Threading.cpp:254
#12 0x757f145b in start_thread () from /lib/libpthread.so.0
#13 0x7566024e in clone () from /lib/libc.so.6
(gdb) t 10
[Switching to thread 10 (Thread 32093)]#0  0x756951b2 in
dl_iterate_phdr () from /lib/libc.so.6
(gdb) bt
#0  0x756951b2 in dl_iterate_phdr () from /lib/libc.so.6
#1  0x0849cd55 in _Unwind_Find_FDE ()
#2  0x0849a815 in ?? ()
#3  0x0849b0a8 in _Unwind_RaiseException ()
#4  0x75762309 in __cxa_throw () from /usr/lib/libstdc++.so.5
#5  0x760a6bb8 in activemq::core::ActiveMQMessageAudit::isDuplicate
(this=0xbbef390, msgId=...) at decaf/util/HashMap.h:971
#6  0x760faba1 in activemq::core::ConnectionAudit::isDuplicate
(this=0x874cdf4, dispatcher=0x4ff9473c, message=...) at
decaf/lang/Pointer.h:258
#7  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate
(this=0x8a74408, dispatcher=0xb726488, message=...) at
decaf/util/concurrent/atomic/AtomicRefCounter.h:46
#8  0x76141bb5 in
activemq::core::kernels::ActiveMQConsumerKernel::dispatch
(this=0x4ff94730, dispatch=...) at
activemq/core/kernels/ActiveMQSessionKernel.h:330
#9  0x760e4b1b in activemq::core::ActiveMQSessionExecutor::dispatch
(this=0xb726488, dispatch=...) at decaf/lang/Pointer.h:258
#10 0x760e4e92 in activemq::core::ActiveMQSessionExecutor::iterate
(this=0xb25f658) at activemq/core/ActiveMQSessionExecuto

RE: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

2014-07-01 Thread Lyubov Romanchuk

But what is the purpose of checkForDuplicates? And which functionality will be 
disabled in case it's false.


-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com] 
Sent: Tuesday, July 01, 2014 6:08 PM
To: dev@activemq.apache.org
Subject: Re: [ActiveMQCPP 3.8.2|Linux] crash in 
activemq::core::ConnectionAudit::isDuplicate

On 07/01/2014 10:37 AM, Lyubov Romanchuk wrote:
> Hi,
>
> Thank you for the response.
> 1) It's very hard to support the test case for reproduction of this 
> issue because  I don't know the root cause of the core and we have too 
> complicated environment in order to try to simulate this behaviour
> 2) It seems like ConnectionAudit::isDuplicate is not thread safe but may be 
> called from different threads.
> 3) And I'm not sure that I understand correctly the purposes of isDuplicate. 
> Could you please explain what is it used for and if it's configurable?
>
> Best regards,
> Lyuba
>
> -Original Message-
> From: Timothy Bish [mailto:tabish...@gmail.com]
> Sent: Tuesday, July 01, 2014 12:20 AM
> To: dev@activemq.apache.org
> Subject: Re: [ActiveMQCPP 3.8.2|Linux] crash in 
> activemq::core::ConnectionAudit::isDuplicate
>
> On 06/29/2014 10:16 AM, Lyubov Romanchuk wrote:
>> Hi,
>> We use activemqcpp library from the version 3.8.2.
>> Sometimes there is a crash in activemq::core::ConnectionAudit::isDuplicate.
>> Could you please advise with this core - what may cause such crash, is it a 
>> known issue?
>>
>> Here is the call stack from one of the cores:
>>
>> * 1 Thread 32129  0x760417ab in 
>> decaf::lang::PointerComparator> n, decaf::util::concurrent::atomic::AtomicRefCounter>::operator() 
>> (this=0x874ce1c, left=..., right=...) at decaf/lang/Pointer.h:243
>> (gdb) bt
>> #0  0x760417ab in 
>> decaf::lang::PointerComparator> n, decaf::util::concurrent::atomic::AtomicRefCounter>::operator() 
>> (this=0x874ce1c, left=..., right=...) at decaf/lang/Pointer.h:243
>> #1  0x76108cad in 
>> std::_Rb_tree> ation, decaf::util::concurrent::atomic::AtomicRefCounter>, 
>> std::pair> n, decaf::util::concurrent::atomic::AtomicRefCounter> const, 
>> decaf::lang::Pointer> decaf::util::concurrent::atomic::AtomicRefCounter> >, 
>> std::_Select1st> tiveMQDestination, decaf::util::concurrent::atomic::AtomicRefCounter> 
>> const, decaf::lang::Pointer> decaf::util::concurrent::atomic::AtomicRefCounter> > >, 
>> decaf::lang::PointerComparator> n, decaf::util::concurrent::atomic::AtomicRefCounter>, 
>> std::allocator> iveMQDestination, decaf::util::concurrent::atomic::AtomicRefCounter> 
>> const, decaf::lang::Pointer> decaf::util::concurrent::atomic::AtomicRefCounter> > > >::find 
>> (this=0x874ce14, __k=...) at 
>> /packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_tree.h:669
>> #2  0x76100316 in 
>> decaf::util::StlMap>  decaf::util::concurrent::atomic::AtomicRefCounter>, 
>> decaf::lang::Pointer> decaf::util::concurrent::atomic::AtomicRefCounter>, 
>> decaf::lang::PointerComparator> decaf::util::concurrent::atomic::AtomicRefCounter> >::containsKey 
>> (this=0x874ce10, key=...)
>>   at 
>> /packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_map.h:345
>> #3  0x760fb57a in activemq::core::ConnectionAudit::isDuplicate 
>> (this=0x874cdf4, dispatcher=0xc0a7e94, message=...) at 
>> decaf/util/StlMap.h:794
>> #4  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate 
>> (this=0x8a74408, dispatcher=0x32332d46, message=...) at 
>> decaf/util/concurrent/atomic/AtomicRefCounter.h:46
>> #5  0x76141bb5 in 
>> activemq::core::kernels::ActiveMQConsumerKernel::dispatch 
>> (this=0xc0a7e88, dispatch=...) at 
>> activemq/core/kernels/ActiveMQSessionKernel.h:330
>> #6  0x760e4b1b in activemq::core::ActiveMQSessionExecutor::dispatch 
>> (this=0x32332d46, dispatch=...) at decaf/lang/Pointer.h:258
>> #7  0x760e4e92 in activemq::core::ActiveMQSessionExecutor::iterate 
>> (this=0x5a5676a0) at activemq/core/ActiveMQSessionExecutor.cpp:181
>> #8  0x762659b6 in activemq::threads::DedicatedTaskRunner::run 
>> (this=0x5a6935e0) at activemq/threads/DedicatedTaskRunner.cpp:141
>> #9  0x7646285e in decaf::lang::Thread::run (this=0x32332d46) at 
>> decaf/lang/Thread.cpp:141
>> #10 0x76421c17 in (anonymous namespace)::runCallback (arg=0x5abb66e8) 
>> at decaf/internal/util/concurrent/Threading.cpp:266
>> #11 0x76421b89 in (anonymous namespace)::threadEntryMethod 
>> (arg=0x5abb66e8) at decaf/internal/util/concurrent/Threading.cpp:254
>> #12 0x757f145b in start_thread () from /lib/libpthread.so.0
>> #13 0x7566024e in clone () from /lib/libc.so.6
>> (gdb) t 10
>> [Switching to thread 10 (Thread 32093)]#0  0x756951b2 in 
>> dl_iterate_phdr () from /lib/libc.so.6
>> (gdb) bt
>> #0  0x756951b2 in dl_iterate_phdr () from /lib/libc.so.6
>> #1  0x0849cd55 in _Unwind_Find_FDE ()
>> #2  0x0849a815 in ?? ()
>> #3  0x0849b0a8 in _Unwind_RaiseException ()
>> #4  0x75762309 in __cxa_throw () from /usr/lib/libstdc++.so.5
>> #5  0x760a6bb8 in activemq::core::ActiveMQMessageAudit::isDuplicate 
>> (this=

[jira] [Closed] (AMQ-5254) Hangs the Application if activeMQ is down

2014-07-01 Thread Timothy Bish (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Timothy Bish closed AMQ-5254.
-

Resolution: Invalid

Use the user forum for help before opening an issue.  Also use the NMS Jira for 
.NET client issues if one is needed.  

> Hangs the Application if activeMQ is down
> -
>
> Key: AMQ-5254
> URL: https://issues.apache.org/jira/browse/AMQ-5254
> Project: ActiveMQ
>  Issue Type: Bug
>Affects Versions: 5.9.1
> Environment: .Net Framework 4.0, ActiveMQ 5.9.1, Apache.NMS.ActiveMQ 
> 1.6.1.3210, Apache.NMS 1.6.1.3083
>Reporter: Tamilmaran
>
> i am using Topic to publish the message
> while publishing if activeMQ is down, the application/ control hangs at 
> producer.Send() 
> The control is not coming out of it.
> It comes when ever activeMQ up again.
> i am using the below ActiveMQ URI
> activemq:failover://(ssl://localhost:61617?transport.serverName=someX)?transport.randomize=false&transport.startupMaxReconnectAttempts=0&transport.timeout=5000



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Closed] (AMQ-5255) Hangs the Application if activeMQ is down

2014-07-01 Thread Timothy Bish (JIRA)


 [ 
https://issues.apache.org/jira/browse/AMQ-5255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Timothy Bish closed AMQ-5255.
-

Resolution: Duplicate

> Hangs the Application if activeMQ is down
> -
>
> Key: AMQ-5255
> URL: https://issues.apache.org/jira/browse/AMQ-5255
> Project: ActiveMQ
>  Issue Type: Bug
>Affects Versions: 5.9.1
> Environment: .Net Framework 4.0, ActiveMQ 5.9.1, Apache.NMS.ActiveMQ 
> 1.6.1.3210, Apache.NMS 1.6.1.3083
>Reporter: Tamilmaran
>
> i am using Topic to publish the message
> while publishing if activeMQ is down, the application/ control hangs at 
> producer.Send() 
> The control is not coming out of it.
> It comes when ever activeMQ up again.
> i am using the below ActiveMQ URI
> activemq:failover://(ssl://localhost:61617?transport.serverName=someX)?transport.randomize=false&transport.startupMaxReconnectAttempts=0&transport.timeout=5000



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Re: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

2014-07-01 Thread Timothy Bish


On 07/01/2014 10:37 AM, Lyubov Romanchuk wrote:

Hi,

Thank you for the response.
1) It's very hard to support the test case for reproduction of this issue 
because  I don't know the root cause of the core and we have too complicated 
environment in order to try to simulate this behaviour
2) It seems like ConnectionAudit::isDuplicate is not thread safe but may be 
called from different threads.
3) And I'm not sure that I understand correctly the purposes of isDuplicate. 
Could you please explain what is it used for and if it's configurable?

Best regards,
Lyuba

-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com]
Sent: Tuesday, July 01, 2014 12:20 AM
To: dev@activemq.apache.org
Subject: Re: [ActiveMQCPP 3.8.2|Linux] crash in 
activemq::core::ConnectionAudit::isDuplicate

On 06/29/2014 10:16 AM, Lyubov Romanchuk wrote:

Hi,
We use activemqcpp library from the version 3.8.2.
Sometimes there is a crash in activemq::core::ConnectionAudit::isDuplicate.
Could you please advise with this core - what may cause such crash, is it a 
known issue?

Here is the call stack from one of the cores:

* 1 Thread 32129  0x760417ab in 
decaf::lang::PointerComparator::operator() (this=0x874ce1c, 
left=..., right=...) at decaf/lang/Pointer.h:243
(gdb) bt
#0  0x760417ab in 
decaf::lang::PointerComparator::operator() (this=0x874ce1c, 
left=..., right=...) at decaf/lang/Pointer.h:243
#1  0x76108cad in std::_Rb_tree, 
std::pair const, 
decaf::lang::Pointer >, 
std::_Select1st const, 
decaf::lang::Pointer > >, 
decaf::lang::PointerComparator, 
std::allocator const, 
decaf::lang::Pointer > > >::find (this=0x874ce14, __k=...) 
at /packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_tree.h:669
#2  0x76100316 in 
decaf::util::StlMap, 
decaf::lang::Pointer, 
decaf::lang::PointerComparator >::containsKey (this=0x874ce10, key=...)
  at /packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_map.h:345
#3  0x760fb57a in activemq::core::ConnectionAudit::isDuplicate (this=0x874cdf4, 
dispatcher=0xc0a7e94, message=...) at decaf/util/StlMap.h:794
#4  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate 
(this=0x8a74408, dispatcher=0x32332d46, message=...) at 
decaf/util/concurrent/atomic/AtomicRefCounter.h:46
#5  0x76141bb5 in activemq::core::kernels::ActiveMQConsumerKernel::dispatch 
(this=0xc0a7e88, dispatch=...) at 
activemq/core/kernels/ActiveMQSessionKernel.h:330
#6  0x760e4b1b in activemq::core::ActiveMQSessionExecutor::dispatch 
(this=0x32332d46, dispatch=...) at decaf/lang/Pointer.h:258
#7  0x760e4e92 in activemq::core::ActiveMQSessionExecutor::iterate 
(this=0x5a5676a0) at activemq/core/ActiveMQSessionExecutor.cpp:181
#8  0x762659b6 in activemq::threads::DedicatedTaskRunner::run (this=0x5a6935e0) 
at activemq/threads/DedicatedTaskRunner.cpp:141
#9  0x7646285e in decaf::lang::Thread::run (this=0x32332d46) at 
decaf/lang/Thread.cpp:141
#10 0x76421c17 in (anonymous namespace)::runCallback (arg=0x5abb66e8) at 
decaf/internal/util/concurrent/Threading.cpp:266
#11 0x76421b89 in (anonymous namespace)::threadEntryMethod (arg=0x5abb66e8) at 
decaf/internal/util/concurrent/Threading.cpp:254
#12 0x757f145b in start_thread () from /lib/libpthread.so.0
#13 0x7566024e in clone () from /lib/libc.so.6
(gdb) t 10
[Switching to thread 10 (Thread 32093)]#0  0x756951b2 in dl_iterate_phdr () 
from /lib/libc.so.6
(gdb) bt
#0  0x756951b2 in dl_iterate_phdr () from /lib/libc.so.6
#1  0x0849cd55 in _Unwind_Find_FDE ()
#2  0x0849a815 in ?? ()
#3  0x0849b0a8 in _Unwind_RaiseException ()
#4  0x75762309 in __cxa_throw () from /usr/lib/libstdc++.so.5
#5  0x760a6bb8 in activemq::core::ActiveMQMessageAudit::isDuplicate 
(this=0xbbef390, msgId=...) at decaf/util/HashMap.h:971
#6  0x760faba1 in activemq::core::ConnectionAudit::isDuplicate (this=0x874cdf4, 
dispatcher=0x4ff9473c, message=...) at decaf/lang/Pointer.h:258
#7  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate 
(this=0x8a74408, dispatcher=0xb726488, message=...) at 
decaf/util/concurrent/atomic/AtomicRefCounter.h:46
#8  0x76141bb5 in activemq::core::kernels::ActiveMQConsumerKernel::dispatch 
(this=0x4ff94730, dispatch=...) at 
activemq/core/kernels/ActiveMQSessionKernel.h:330
#9  0x760e4b1b in activemq::core::ActiveMQSessionExecutor::dispatch 
(this=0xb726488, dispatch=...) at decaf/lang/Pointer.h:258
#10 0x760e4e92 in activemq::core::ActiveMQSessionExecutor::iterate 
(this=0xb25f658) at activemq/core/ActiveMQSessionExecutor.cpp:181
#11 0x762659b6 in activemq::threads::DedicatedTaskRunner::run (this=0xc073290) 
at activemq/threads/DedicatedTaskRunner.cpp:141
#12 0x7646285e in decaf::lang::Thread::run (this=0xb726488) at 
decaf/lang/Thread.cpp:141
#13 0x76421c17 in (anonymous namespace)::runCallback (arg=0xb6ab2c8) at 
decaf/internal/util/concurrent/Threading.cpp:266
#14 0x76421b89 in (anonymous namespace)::threadEntryMethod (arg=0xb6ab2c8) at 
decaf/internal/util/concurrent/Threading.cpp:254
#15 0x757f145b in start_thread () from /lib/libpthread.so.0
#16

[jira] [Created] (AMQ-5255) Hangs the Application if activeMQ is down

2014-07-01 Thread Tamilmaran (JIRA)

Tamilmaran created AMQ-5255:
---

 Summary: Hangs the Application if activeMQ is down
 Key: AMQ-5255
 URL: https://issues.apache.org/jira/browse/AMQ-5255
 Project: ActiveMQ
  Issue Type: Bug
Affects Versions: 5.9.1
 Environment: .Net Framework 4.0, ActiveMQ 5.9.1, Apache.NMS.ActiveMQ 
1.6.1.3210, Apache.NMS 1.6.1.3083
Reporter: Tamilmaran


i am using Topic to publish the message
while publishing if activeMQ is down, the application/ control hangs at 
producer.Send() 
The control is not coming out of it.
It comes when ever activeMQ up again.

i am using the below ActiveMQ URI

activemq:failover://(ssl://localhost:61617?transport.serverName=someX)?transport.randomize=false&transport.startupMaxReconnectAttempts=0&transport.timeout=5000



--
This message was sent by Atlassian JIRA
(v6.2#6252)

[jira] [Created] (AMQ-5254) Hangs the Application if activeMQ is down

2014-07-01 Thread Tamilmaran (JIRA)

Tamilmaran created AMQ-5254:
---

 Summary: Hangs the Application if activeMQ is down
 Key: AMQ-5254
 URL: https://issues.apache.org/jira/browse/AMQ-5254
 Project: ActiveMQ
  Issue Type: Bug
Affects Versions: 5.9.1
 Environment: .Net Framework 4.0, ActiveMQ 5.9.1, Apache.NMS.ActiveMQ 
1.6.1.3210, Apache.NMS 1.6.1.3083
Reporter: Tamilmaran


i am using Topic to publish the message
while publishing if activeMQ is down, the application/ control hangs at 
producer.Send() 
The control is not coming out of it.
It comes when ever activeMQ up again.

i am using the below ActiveMQ URI

activemq:failover://(ssl://localhost:61617?transport.serverName=someX)?transport.randomize=false&transport.startupMaxReconnectAttempts=0&transport.timeout=5000



--
This message was sent by Atlassian JIRA
(v6.2#6252)

RE: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

2014-07-01 Thread Lyubov Romanchuk

Hi,

Thank you for the response.
1) It's very hard to support the test case for reproduction of this issue 
because  I don't know the root cause of the core and we have too complicated 
environment in order to try to simulate this behaviour
2) It seems like ConnectionAudit::isDuplicate is not thread safe but may be 
called from different threads. 
3) And I'm not sure that I understand correctly the purposes of isDuplicate. 
Could you please explain what is it used for and if it's configurable?

Best regards,
Lyuba

-Original Message-
From: Timothy Bish [mailto:tabish...@gmail.com] 
Sent: Tuesday, July 01, 2014 12:20 AM
To: dev@activemq.apache.org
Subject: Re: [ActiveMQCPP 3.8.2|Linux] crash in 
activemq::core::ConnectionAudit::isDuplicate

On 06/29/2014 10:16 AM, Lyubov Romanchuk wrote:
> Hi,
> We use activemqcpp library from the version 3.8.2.
> Sometimes there is a crash in activemq::core::ConnectionAudit::isDuplicate.
> Could you please advise with this core - what may cause such crash, is it a 
> known issue?
>
> Here is the call stack from one of the cores:
>
> * 1 Thread 32129  0x760417ab in 
> decaf::lang::PointerComparator decaf::util::concurrent::atomic::AtomicRefCounter>::operator() 
> (this=0x874ce1c, left=..., right=...) at decaf/lang/Pointer.h:243
> (gdb) bt
> #0  0x760417ab in 
> decaf::lang::PointerComparator decaf::util::concurrent::atomic::AtomicRefCounter>::operator() 
> (this=0x874ce1c, left=..., right=...) at decaf/lang/Pointer.h:243
> #1  0x76108cad in 
> std::_Rb_tree decaf::util::concurrent::atomic::AtomicRefCounter>, 
> std::pair decaf::util::concurrent::atomic::AtomicRefCounter> const, 
> decaf::lang::Pointer decaf::util::concurrent::atomic::AtomicRefCounter> >, 
> std::_Select1st  decaf::util::concurrent::atomic::AtomicRefCounter> const, 
> decaf::lang::Pointer decaf::util::concurrent::atomic::AtomicRefCounter> > >, 
> decaf::lang::PointerComparator decaf::util::concurrent::atomic::AtomicRefCounter>, 
> std::allocator  decaf::util::concurrent::atomic::AtomicRefCounter> const, 
> decaf::lang::Pointer decaf::util::concurrent::atomic::AtomicRefCounter> > > >::find 
> (this=0x874ce14, __k=...) at 
> /packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_tree.h:669
> #2  0x76100316 in 
> decaf::util::StlMap  decaf::util::concurrent::atomic::AtomicRefCounter>, 
> decaf::lang::Pointer decaf::util::concurrent::atomic::AtomicRefCounter>, 
> decaf::lang::PointerComparator decaf::util::concurrent::atomic::AtomicRefCounter> >::containsKey 
> (this=0x874ce10, key=...)
>  at /packages/gnu-3.2.3-20.linux30/include/c++/3.2.3/bits/stl_map.h:345
> #3  0x760fb57a in activemq::core::ConnectionAudit::isDuplicate 
> (this=0x874cdf4, dispatcher=0xc0a7e94, message=...) at decaf/util/StlMap.h:794
> #4  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate 
> (this=0x8a74408, dispatcher=0x32332d46, message=...) at 
> decaf/util/concurrent/atomic/AtomicRefCounter.h:46
> #5  0x76141bb5 in activemq::core::kernels::ActiveMQConsumerKernel::dispatch 
> (this=0xc0a7e88, dispatch=...) at 
> activemq/core/kernels/ActiveMQSessionKernel.h:330
> #6  0x760e4b1b in activemq::core::ActiveMQSessionExecutor::dispatch 
> (this=0x32332d46, dispatch=...) at decaf/lang/Pointer.h:258
> #7  0x760e4e92 in activemq::core::ActiveMQSessionExecutor::iterate 
> (this=0x5a5676a0) at activemq/core/ActiveMQSessionExecutor.cpp:181
> #8  0x762659b6 in activemq::threads::DedicatedTaskRunner::run 
> (this=0x5a6935e0) at activemq/threads/DedicatedTaskRunner.cpp:141
> #9  0x7646285e in decaf::lang::Thread::run (this=0x32332d46) at 
> decaf/lang/Thread.cpp:141
> #10 0x76421c17 in (anonymous namespace)::runCallback (arg=0x5abb66e8) at 
> decaf/internal/util/concurrent/Threading.cpp:266
> #11 0x76421b89 in (anonymous namespace)::threadEntryMethod (arg=0x5abb66e8) 
> at decaf/internal/util/concurrent/Threading.cpp:254
> #12 0x757f145b in start_thread () from /lib/libpthread.so.0
> #13 0x7566024e in clone () from /lib/libc.so.6
> (gdb) t 10
> [Switching to thread 10 (Thread 32093)]#0  0x756951b2 in dl_iterate_phdr () 
> from /lib/libc.so.6
> (gdb) bt
> #0  0x756951b2 in dl_iterate_phdr () from /lib/libc.so.6
> #1  0x0849cd55 in _Unwind_Find_FDE ()
> #2  0x0849a815 in ?? ()
> #3  0x0849b0a8 in _Unwind_RaiseException ()
> #4  0x75762309 in __cxa_throw () from /usr/lib/libstdc++.so.5
> #5  0x760a6bb8 in activemq::core::ActiveMQMessageAudit::isDuplicate 
> (this=0xbbef390, msgId=...) at decaf/util/HashMap.h:971
> #6  0x760faba1 in activemq::core::ConnectionAudit::isDuplicate 
> (this=0x874cdf4, dispatcher=0x4ff9473c, message=...) at 
> decaf/lang/Pointer.h:258
> #7  0x7603605c in activemq::core::ActiveMQConnection::isDuplicate 
> (this=0x8a74408, dispatcher=0xb726488, message=...) at 
> decaf/util/concurrent/atomic/AtomicRefCounter.h:46
> #8  0x76141bb5 in activemq::core::kernels::ActiveMQConsumerKernel::dispatch 
> (this=0x4ff94730, dispatch=...) at 
> activemq/core/kernels/ActiveMQSessionKernel.h:330
> #9  0x760e4b1b in activem

Re: Javadocs for 5.10.0?

2014-07-01 Thread Dejan Bosanac

Hi Raul,

I’ve got some errors trying to create them during the release and postponed
them. I’ll create them in the next few days.

Regards
--
Dejan Bosanac
--
Red Hat, Inc.
dbosa...@redhat.com
Twitter: @dejanb
Blog: http://sensatic.net
ActiveMQ in Action: http://www.manning.com/snyder/


On Tue, Jul 1, 2014 at 2:37 PM, Raul Kripalani  wrote:

> Hello teams,
>
> It seems like the Javadocs for 5.10.0 haven't been published nor linked to
> from the cover page?
>
> http://activemq.apache.org/maven/5.9.0/apidocs/index.html seems to be the
> latest working Javadocs...
>
> Thanks,
>
> *Raúl Kripalani*
> Apache Camel PMC Member & Committer | Enterprise Architect, Open Source
> Integration specialist
> http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani
> http://blog.raulkr.net | twitter: @raulvk
>

Re: Camel Routes

2014-07-01 Thread Claus Ibsen

Hi

Yeah this is ActiveMQ forum so better ask at Camel forum / user mailing list
http://camel.apache.org/discussion-forums.html
http://camel.apache.org/mailing-lists.html

On Mon, Jun 30, 2014 at 11:11 PM, Ritwick  wrote:
> Hi,
> I am not sure if this is the correct Camel forum for this issue I am having.
> However, I am unable to find an appropriate forum - so I am posting my
> question here. It will be great if someone can either guide me to the
> correct forum or better still rectify the issue I am facing.
> Here is what I need to do - expose a restlet endpoint to accept data; use
> this data as input to an external SOAP web service and send back the
> response in JSON format back to the caller...
> Here is what I have done...however, I am getting the following error while
> Camel tries to call the Web Service...can anyone guide me here? Thanks.
>
> 2014-06-30 14:09:24,987 [tlet-1846031557] WARN  PhaseInterceptorChain
> - Interceptor for
> {http://www.webserviceX.NET/}CurrencyConvertor#{http://www.webserviceX.NET/}ConversionRate
> has thrown exception, unwinding now
> java.lang.ClassCastException: ClassCastException invoking
> http://www.webservicex.net/CurrencyConvertor.asmx:
> org.restlet.data.Parameter cannot be cast to java.lang.String
>
>
> public class IntegrationTest extends CamelTestSupport {
>
> @org.junit.Test
> public void integTest() throws Exception {
> //trying to simulate the rest service call...
>
> template.sendBodyAndHeader("restlet:http://localhost:8080/convert/{data}?restletMethods=get";,
> "Body does not matter here", "data",
> "{\"FromCurrency\":\"AUD\",\"ToCurrency\":\"USD\"}");
>
> }
>
>
> @Override
> protected RouteBuilder createRouteBuilder() throws Exception {
> return new RouteBuilder() {
> @Override
> public void configure() throws Exception {
> System.out.println("In Counfigure");
>
> String cxfEndpoint =
> "cxf://http://www.webservicex.net/CurrencyConvertor.asmx?";
> +
> "wsdlURL=http://www.webservicex.net/CurrencyConvertor.asmx?wsdl&";
> + 
> "serviceName={http://www.webserviceX.NET/}CurrencyConvertor&";
> + 
> "portName={http://www.webserviceX.NET/}CurrencyConvertorSoap&";
> + "dataFormat=MESSAGE";
>
> XmlJsonDataFormat xmlJsonFormat = new 
> XmlJsonDataFormat();
> SoapJaxbDataFormat soap = new
> SoapJaxbDataFormat("net.webservicex", new
> ServiceInterfaceStrategy(CurrencyConvertorSoap.class, true));
>
> GsonDataFormat gson = new 
> GsonDataFormat(ConversionRate.class);
> 
> gson.setFieldNamingPolicy(FieldNamingPolicy.UPPER_CAMEL_CASE);
>
> from("restlet:http://localhost:8080/convert/{data}?restletMethods=get";).routeId("Restlet")
> .process(new Processor() {
> @Override
> public void process(Exchange 
> exchange) throws Exception {
> String data = (String) 
> URLDecoder.decode((String)
> exchange.getIn().getHeader("data"), "UTF-8");
> System.out.println(data);
> // get the mail body as a 
> String
> 
> exchange.getIn().setBody(data);
> 
> Response.getCurrent().setStatus(Status.SUCCESS_OK);
> }
>
> })
> .unmarshal(gson)
> .marshal(soap)
> .log("${body}")
> .to(cxfEndpoint)
> .unmarshal(soap)
> .marshal(xmlJsonFormat);
> .log("${body}");
> }
> };
> }
> }
>
>
>
>
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Camel-Routes-tp4682675.html
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/

Javadocs for 5.10.0?

2014-07-01 Thread Raul Kripalani

Hello teams,

It seems like the Javadocs for 5.10.0 haven't been published nor linked to
from the cover page?

http://activemq.apache.org/maven/5.9.0/apidocs/index.html seems to be the
latest working Javadocs...

Thanks,

*Raúl Kripalani*
Apache Camel PMC Member & Committer | Enterprise Architect, Open Source
Integration specialist
http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani
http://blog.raulkr.net | twitter: @raulvk

Camel Routes

2014-07-01 Thread Ritwick

Hi,
I am not sure if this is the correct Camel forum for this issue I am having.
However, I am unable to find an appropriate forum - so I am posting my
question here. It will be great if someone can either guide me to the
correct forum or better still rectify the issue I am facing.
Here is what I need to do - expose a restlet endpoint to accept data; use
this data as input to an external SOAP web service and send back the
response in JSON format back to the caller...
Here is what I have done...however, I am getting the following error while
Camel tries to call the Web Service...can anyone guide me here? Thanks.

2014-06-30 14:09:24,987 [tlet-1846031557] WARN  PhaseInterceptorChain 
- Interceptor for
{http://www.webserviceX.NET/}CurrencyConvertor#{http://www.webserviceX.NET/}ConversionRate
has thrown exception, unwinding now
java.lang.ClassCastException: ClassCastException invoking
http://www.webservicex.net/CurrencyConvertor.asmx:
org.restlet.data.Parameter cannot be cast to java.lang.String


public class IntegrationTest extends CamelTestSupport {

@org.junit.Test
public void integTest() throws Exception {
//trying to simulate the rest service call...
  
template.sendBodyAndHeader("restlet:http://localhost:8080/convert/{data}?restletMethods=get";,
"Body does not matter here", "data",
"{\"FromCurrency\":\"AUD\",\"ToCurrency\":\"USD\"}");

}


@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
System.out.println("In Counfigure");

String cxfEndpoint =
"cxf://http://www.webservicex.net/CurrencyConvertor.asmx?";
+
"wsdlURL=http://www.webservicex.net/CurrencyConvertor.asmx?wsdl&";
+ 
"serviceName={http://www.webserviceX.NET/}CurrencyConvertor&";
+ 
"portName={http://www.webserviceX.NET/}CurrencyConvertorSoap&";
+ "dataFormat=MESSAGE";

XmlJsonDataFormat xmlJsonFormat = new 
XmlJsonDataFormat();
SoapJaxbDataFormat soap = new
SoapJaxbDataFormat("net.webservicex", new
ServiceInterfaceStrategy(CurrencyConvertorSoap.class, true));

GsonDataFormat gson = new 
GsonDataFormat(ConversionRate.class);

gson.setFieldNamingPolicy(FieldNamingPolicy.UPPER_CAMEL_CASE);

from("restlet:http://localhost:8080/convert/{data}?restletMethods=get";).routeId("Restlet")
.process(new Processor() {
@Override
public void process(Exchange exchange) 
throws Exception {
String data = (String) 
URLDecoder.decode((String)
exchange.getIn().getHeader("data"), "UTF-8");
System.out.println(data);
// get the mail body as a String
exchange.getIn().setBody(data);

Response.getCurrent().setStatus(Status.SUCCESS_OK);
}

})
.unmarshal(gson)
.marshal(soap)
.log("${body}")
.to(cxfEndpoint)
.unmarshal(soap)
.marshal(xmlJsonFormat);
.log("${body}");
}
};
}
}




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Camel-Routes-tp4682675.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

[GitHub] activemq pull request: Escape message properties tooltip in web co...

2014-07-01 Thread lightoze

GitHub user lightoze opened a pull request:

https://github.com/apache/activemq/pull/30

Escape message properties tooltip in web console



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/lightoze/activemq patch-1

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/activemq/pull/30.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #30


commit 86a25eae98469b5cbd380a4001315f4025d319a6
Author: Vladimir Kulev 
Date:   2014-07-01T10:17:40Z

Escape message properties tooltip




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---

[jira] [Commented] (AMQ-1940) Negative queue size (reproducible)

[jira] [Commented] (AMQ-1693) Nagitive Number Of Pending Messages

[jira] [Created] (AMQ-5257) 5.10.0 cannot startup with leveldb

[jira] [Commented] (AMQ-2009) Problem with message dispatch after a while

[jira] [Created] (AMQNET-479) Connection timeout is not working when ActiveMQ service is Down

[jira] [Resolved] (AMQ-5224) XA pooled connection factories are not recoverable

[jira] [Resolved] (AMQ-5140) ArithmeticException: / by zero in HealthView.healthList() when using JMX-Health-Operations

[jira] [Resolved] (AMQ-5256) AMQP WARN Transport Connection failed: java.io.IOException

[jira] [Created] (AMQ-5256) AMQP WARN Transport Connection failed: java.io.IOException

Re: Camel Routes

[jira] [Reopened] (AMQ-5140) ArithmeticException: / by zero in HealthView.healthList() when using JMX-Health-Operations

[jira] [Updated] (AMQ-5140) ArithmeticException: / by zero in HealthView.healthList() when using JMX-Health-Operations

Re: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

RE: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

[jira] [Closed] (AMQ-5254) Hangs the Application if activeMQ is down

[jira] [Closed] (AMQ-5255) Hangs the Application if activeMQ is down

Re: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

[jira] [Created] (AMQ-5255) Hangs the Application if activeMQ is down

[jira] [Created] (AMQ-5254) Hangs the Application if activeMQ is down

RE: [ActiveMQCPP 3.8.2|Linux] crash in activemq::core::ConnectionAudit::isDuplicate

Re: Javadocs for 5.10.0?

Re: Camel Routes

Javadocs for 5.10.0?

Camel Routes

[GitHub] activemq pull request: Escape message properties tooltip in web co...

25 matches

Site Navigation

Mail list logo

Footer information