storm-jms
storm-jms copied to clipboard
ptgoetz
Storm JMS Integration
Getting a class cast on `Integer topologyTimeout = (Integer)conf.get("topology.message.timeout.secs");` in JmsSpout.java This should be similar to; `Integer topologyTimeout = Integer.parseInt(String.valueOf(conf.get("topology.message.timeout.secs")));`
I am getting the following error while calling `ack()` on `OutputCollector`. Can anybody help me to find a cause of this exception? ``` 2016-10-07 08:46:46.856 [Thread-19-JMS_QUEUE_SPOUT] WARN Message failed: org.apache.storm.jms.spout.JmsMessageID@77eb...
…spaceHandler for XML schema namespace issue, something that occurs when trying to run the example (and projects derived from that) on a cluster. Author: Christian Hollinger [email protected] Date: Thu Sep...
Change-Id: Iaf33656e3d09c00b972d8ac3abb6157b83d6f4bc
Patch includes support for jms message selectors. Additionally in case of a message ack failure we do a recovery. This is needed in particular for auto reconnect scenarios in conventional...
It looks like storm 0.8.2 uses a Long for the topology timeout, even if it's set to an Integer initially, so using a Number works for both.
Source code has been changed to use Apache Storm version 1.0.0.
In [JmsSpout.java](https://github.com/ptgoetz/storm-jms/blob/master/src/main/java/org/apache/storm/jms/spout/JmsSpout.java) `javax.jms.Session` instance is used by multiple threads what is errornous according to [Javadoc](https://docs.oracle.com/javaee/7/api/javax/jms/Session.html): > Once a connection has been started, any session with one or more registered message...
