storm-jms

storm-jms copied to clipboard

The ack logic in JMS Spout says : ``` Message msg = this.pendingMessages.remove(msgId); JmsMessageID oldest = this.toCommit.first(); if(msgId.equals(oldest)) { ... } ``` Is this "if" check for Batch acknowledgment mode...

ghost

Incorrect handling of topology.message.timeout.secs

1

Attempting to set the topology.message.timeout.secs config value results in a class cast exception: ``` java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer at backtype.storm.contrib.jms.spout.JmsSpout.open(JmsSpout.java:160) ~[stormjar.jar:?] ``` (Note: this stack trace was...

DevInsanity

Getting following error when pushing the topology to storm

3

Exception in thread "main" org.springframework.beans.factory.parsing.BeanDefinitionParsingException: Configuration problem: Unable to locate Spring NamespaceHandler for XML schema namespace [http://activemq.apache.org/schema/core] Offending resource: class path resource [jms-activemq.xml]

piyushrai

Hello, Even in my code I set queueSpout.setJmsAcknowledgeMode(Session.AUTO_ACKNOWLEDGE); I can see in my logs the following WARNING b.s.c.j.s.JmsSpout [WARN] Couldn't acknowledge unknown JMS message ID ..... In the JmsSpout class...

NicoBiau

duplicated emitted messages after a fail recover

1

Hi, Reading the documentation of the method session.recover(), I think the recovery process after a failure causes messages inside within the topology (after spout), are discarded by jms queue and...

frascuchon

Hi there, Is it possible to make an official release of storm-jms targeting storm 0.9.5? My organisation requires that artifacts are built and hosted externally, as opposed to us making...

grantnd

examples can't succes submit to cluster

1

as title descrption , when submit with the jar "storm-jms-examples-0.1-SNAPSHOT-jar-with-dependencies.jar" , throw exception : "Exception in thread "main" org.springframework.beans.factory.parsing.BeanDefinitionParsingException: Configuration problem: Unable to locate Spring NamespaceHandler for XML schema namespace...

chenxubai

mvn clean install ERROR

2

[ERROR] Failed to execute goal on project storm-jms: Could not resolve dependencies for project com.github.ptgoetz:storm-jms:jar:0.8.2-SNAPSHOT: Could not find artifact storm:storm:jar:0.8.1 in central (http://repo1.maven.org/maven2) -> [Help 1]

isabella

JMS Spout ack() and fail() implementation

1

Hi, The JMS Spout implements the ack() and fail() mechanisms by JMS message acknowledgment and JMS session recovery. One very important fact that is usually misunderstood in JMS is that...

marjan-sterjev

Bumps [spring-beans](https://github.com/spring-projects/spring-framework) from 2.5.6 to 5.2.20.RELEASE. Release notes Sourced from spring-beans's releases. v5.2.20.RELEASE :star: New Features Restrict access to property paths on Class references #28262 Improve diagnostics in SpEL for...

dependabot[bot]