Stack Overflow
Stack Overflow

Questions tagged [durable-subscription]

27 questions
5
votes
1 answer

JMS multiple durable subscription to one topic

I started JMS for a week now. I created JMS using Netbeans,maven and glassfish. I have one producer and one durable consumer and I wanted to add another durable consumer to the same topic(not queue). Is it possible to do so? because I want all the…
Chan Chun Weng
  • 876
  • 2
  • 16
  • 32
4
votes
2 answers

ActiveMQ - client already connected with same clientId error

We have a setup of JBoss EAP 7.0.0.GA connecting to ActivMQ apache-activemq-5.14.3. We are trying to setup a durable subscriber with the following configuration: @MessageDriven( name = "TestListener", activationConfig = { …
Dchucks
  • 1,189
  • 5
  • 22
  • 48
3
votes
1 answer

Durable Subscription ActiveMQ

I am trying to put in place durable subscriber for my messages so that they will get persist in topic even after server restart. But during configuration I am getting error related to xml: Here is my configuration xml:
mahendra kawde
  • 855
  • 4
  • 25
  • 44
2
votes
1 answer

Prime new topic subscribers with old messages in Apache Artemis

I'm configuring an Apache Artemis message-broker. The broker will accept big files and downstream consumers access the topic to process the latest files. Now I'm wondering how to make the latest files available for dev-runs. Because the messages…
sba
  • 1,829
  • 19
  • 27
2
votes
1 answer

JMS Durable subscription. Subscriber do not receive messages

Learning durable subscription. I tweaked the example given here. I have written two programs. In one I create topic and send message with PERSISTENCE mode. In other program I create durable subscribers for same topic and try to receive. I run first…
Kaushik Lele
  • 6,439
  • 13
  • 50
  • 76
2
votes
0 answers

Using ActiveMQ's js api, how do I specify a durable topic subscription?

I am using ActiveMQ's amq.js to subscribe to topics in my client-side js. I do so via a call like this: amq.addListener( clientID, "topic://topicName", updateListener ); ... but I would like to specify that this topic subscription be durable. How…
Eric
  • 1,414
  • 3
  • 16
  • 35
2
votes
1 answer

How can I handle a duplicate durable Stomp subscriber?

I have multiple Ruby processes that start up and try to connect to a topic via a durable subscriber using Stomp. The first process succeeds, and reads messages (yay). Subsequent processes fail, and repeatedly try to reconnect. How can my processes…
cmonkey
  • 4,256
  • 1
  • 26
  • 46
1
vote
2 answers

Use same JMS ClientID for multiple destinations/topics

I'm working on an new application that subscribes to two topics on a JBoss 4 and processes incoming messages. Actually I'm using two DefaultMessageListenerContainer with durable subscriptions for the connection. When I use the same ClientID for the…
Leme
  • 21
  • 2
1
vote
1 answer

Artemis durable subscription message storage

I am trying to understand how durable subscription works in ActiveMQ Artemis. Currently my biggest question is about the storage. I want to know if the messages are duplicated, which means for each consumer, the message is stored to disk or if the…
Artandor
  • 472
  • 6
  • 20
1
vote
1 answer

Apache ActiveMQ Artemis Durable Subscription TTL

I would like to configure a durable topic, but I want to configure how long Apache ActiveMQ Artemis will hold onto a message for an inactive durable subscriber to the topic. For example, something like "Save durable messages for up to 30 seconds for…
Ryan Pelletier
  • 616
  • 7
  • 20
1
vote
1 answer

How do durable subscribers work with JMS?

So I am creating concurrent consumers to a topic i.e. multiple listeners. I am configuring them to be durable. @Bean public DefaultMessageListenerContainer listenerContainers() { DefaultMessageListenerContainer container = new…
africandrogba
  • 334
  • 1
  • 3
  • 21
1
vote
1 answer

Orphaned SYSTEM.MANAGED.DURABLE.* queue in Websphere MQ

I have a queue 'SYSTEM.MANAGED.DURABLE.ABCD***109' getting messages all the time and no one to consume it. I tried to get its subscription but got the following result , dis sub(*) where (DEST LK 'SYSTEM.MANAGED.DURABLE.ABCD***109') AMQ8096: IBM…
Vignesh
  • 949
  • 2
  • 21
  • 38
1
vote
1 answer

Using durable subscribers with virtual topics in ActiveMQ and does Subscription Recovery Policy play any role?

I am a bit confused here on how to properly use ActiveMQ. What i'm trying to do I have system A which produces messages to a virtual topic. Then there's system B and C which both consume messages from the same virtual topic. There is a chance that…
Indrek Ots
  • 3,701
  • 1
  • 19
  • 24
1
vote
1 answer

Query regarding Spring message-driven-channel-adapter

I am using Spring's message-driven-channel-adapter. My component is consuming message from Tibco Topic and Publishing to RabbitMQ topic So The message flow is as follows: Tibco-> (subscribed by )Component (Published to)-> RabbitMQ The service…
user2595169
  • 147
  • 1
  • 14
0
votes
1 answer

Connection timeout error for ActiveMQ Python STOMP client

I am using the stomp.py 8.1.0 Python client to listen to Red Hat AMQ 7.4.1 (based on ActiveMQ Artemis), and I frequently get this error: received an error {cmd=ERROR,headers=[{'message': 'AMQ229014: Did not receive data from /xx.xxx.xx.xx:57182…
xymzh
  • 63
  • 5
1
2