Stack Overflow
Stack Overflow

Questions tagged [virtual-topic]

13 questions
2
votes
1 answer

How to implement virtual topic functionality in ActiveMQ Artemis

ActiveMQ "Classic" has virtual topic functionality. This means that consumers can be created dynamically. How is this feature managed by ActiveMQ Artemis?
Liamkelly15
  • 89
  • 7
2
votes
1 answer

ActiveMQ - A message sent to multiple queues is getting stuck in queues if exception occurs in any queue

I'm am using Virtual Destinations to implement Publish Subscribe model in ActiveMQ 5.15.13. I've a virtual topic VirtualTopic and there are two queues bound to it. Each queue has it's own redelivery policy. Let's say Queue 1 will retry message 2…
Gagan Arora
  • 86
  • 5
2
votes
1 answer

Rabbit MQ virtual topics?

In Rabbit MQ is there an equivalent to Active MQ Virtual Topics? Or any other mechanism achieve queue semantics. Some topic subscribers need persistent messages delivered when they come back online, and load balancing. EDIT There are multiple…
saugata
  • 2,823
  • 1
  • 27
  • 39
1
vote
1 answer

Multiple queues receiving same message from virtual topic creates a deadletter entry for one queue only

I'm am using Virtual Destinations to implement Publish Subscribe model in ActiveMQ 5.15.13. I have a virtual topic VirtualTopic and there are two queues bound to it. Each queue has its own redelivery policy. Let's say Queue 1 will retry message 2…
Gagan Arora
  • 86
  • 5
1
vote
0 answers

How to dequeued messages from a Activemq queue?

I'm using the Virtual Topics concepts of Activemq 5.14.5 (https://activemq.apache.org/virtual-destinations) with MQTT protocol. ActiveMQ will pick up the messages written to the topic and write them to a queue (or multiple queues or topics). See the…
Antonio
  • 11
  • 1
1
vote
1 answer

Is there a Solace equivalent to ActiveMQ virtual topics?

Is there a Solace equivalent to ActiveMQ's virtual topics? Suppose you have two different components each consuming from the same Solace queue - component1 and component2. Suppose both are load balanced, giving you component1_instance1,…
JohnC
  • 698
  • 7
  • 12
1
vote
2 answers

AWS SNS-SQS Fanout Options when message order matters

We have our Active-MQ on-premise and I'm exploring options in AWS for managed messaging service. All of our applications use ActiveMQ's Virtual Topic feature. It appears that in AWS, Fanout can be achieved using SNS->SQS. But unfortunately, SNS…
Haran
  • 1,040
  • 2
  • 13
  • 26
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
0
votes
1 answer

Intercept messages against Virtual Topic before being sent to consumer queue in ActiveMQ

Is there any way to edit messages sent to a Virtual Topic before they are dispatched to consumer queue in ActiveMQ. I need to change the persistence property in the message before it is consumed by the queue. Is there any plugin or already built in…
0einstein0
  • 1
  • 1
0
votes
0 answers

AMQP ReceiverLink after accepting the message is not dequeueing the message in UI

I am publishing messages to a virtual topic and from there on to two queues. I am consuming the messages from one of the queue using ReceiverLink asynchronously. ReceiverLink receiverLink = new ReceiverLink( _session, "recevier_link-1",…
suganya murugesan
  • 5
  • 2
0
votes
1 answer

How to publish messages to a virtual topic in AMQP

I published messages to a topic in ActiveMQ using AMQP with the SenderLink API. I used the node address pointing to topic://topicname. For VirtualTopic I went through this documentation. Changing the configuration as noted and renaming the topic…
suganya murugesan
  • 5
  • 2
0
votes
2 answers

Handling wildcards in CompositeQueues - ActiveMQ xml configuration file

I would like to ask for advice regarding a topic I have with ActiveMQ. I am using ActiveMQ 5.15. I am trying to modify the xml configuration file for adding a virtual destination using CompositeQueues that forward to another queue/topic. From the…
Reubems
  • 51
  • 7
0
votes
2 answers

Routing to virtual destinations inside ActiveMQ broker

I have an activemq configuration wherein I have a virtual destination and a normal topic I want to route all the JMS messages to the destination(VirtualTopic.Notifications) to 2 queues(VirtualTopic.SMS, VirtualTopic.EMAIL) based on their JMSType in…
Sabya
  • 197
  • 4
  • 17