Questions tagged [amq]

AMQ refers to Red Hat AMQ, the commercial messaging product based on Apache ActiveMQ.

AMQ is a lightweight, high performance, commercial messaging platform from Red Hat based on Apache ActiveMQ.

81 questions
8
votes
1 answer

How to send header message in JmsTemplate?

I am trying to insert message header into amq. There is no specific method in JMSTemplate for setting header in amq. when I set like this it will save in StringProperty instead of header. For saving into header how to pass data …
sudar
  • 1,446
  • 2
  • 14
  • 26
7
votes
1 answer

What is the difference between Red Hat AMQ and Apache ActiveMQ?

I am providing a design for a new project and I am trying to understand which JMS provider to use. Is there any difference between Red Hat AMQ and Apache ActiveMQ ?
coder
  • 231
  • 3
  • 11
4
votes
1 answer

set prefetch limit from stomp API

The AMQ docs note that the prefetch limit can be set when establishing a connection - is there a way to set the prefetch limit using stomp.py when instantiating a queue connection?
category
  • 2,113
  • 2
  • 22
  • 46
4
votes
1 answer

ActiveMQ 5.11 network of brokers and master/slave group config

In ActiveMQ /A-MQ 5.11, I want to build a broker topology of: 4 master/slave pairs (2 in Las Vegas, 2 in New York) network of brokers complete graph (each master connected to all other masters) Documentation says each broker should connect to other…
raffian
  • 31,267
  • 26
  • 103
  • 174
3
votes
1 answer

Migrate data from Kahadb to MKahadb

I am changing from KahaDB to MKahaDB. So, distributing some of my queues to separated destinations. But i would like to migrate old queues' data to the newly created destinations. Is there anyone knows, how can i do that?
2
votes
0 answers

Red Hat AMQ 7.1 - ActiveMQSecurityException throws during creation of a MessageConsumer

I'm configuring an AMQ broker for my Java application. Users and roles are defined in their respective configuration properties files. These users have specific permissions depending on the address they are trying to use. All of this is configured…
Kelper
  • 91
  • 2
  • 16
2
votes
1 answer

Execute fabric commands from Karaf terminal using ansible

In ansible how can we execute fabric commands in Karaf terminal. Actually in ansible we will execute shell commands, but there are some commands I need to execute with Karaf terminal. Is there any possibility to do. in generic, how to open other…
sasi
  • 4,192
  • 4
  • 28
  • 47
1
vote
0 answers

AMQ212054: Destination address=... is blocked. If the system is configured to block make sure you consume messages on this configuration

I am using Artemis 2.7.0.redhat-00056 (AMQ 5.11 I think) One of the camel routes was set up ages ago. It sends XML on a queue, which is then handled in a bean. So it uses JMS style code: producer = session.createProducer(destination); …
djb
  • 1,635
  • 3
  • 26
  • 49
1
vote
0 answers

How to replace the base Java image in public base image with customized version

We are using base image of RedHat AMQ registry.access.redhat.com/jboss-amq-6/amq63-openshift which is a public base we cannot change. We use that image in jib maven plugin and did some changes to create an app. However, the security department…
WesternGun
  • 11,303
  • 6
  • 88
  • 157
1
vote
1 answer

AMQ Error reading in simpleString, length=xxx is greater than readableBytes=yyy

I'm trying to work out how to fix this ActiveMQ Artemis error. Seems the occasional message is too big for SimpleString, and isn't sending, and it goes to the DLQ. java.lang.IndexOutOfBoundsException: Error reading in simpleString, length=1366648 is…
djb
  • 1,635
  • 3
  • 26
  • 49
1
vote
1 answer

How do I scale up JBoss AMQ 6.3 in openshift?

I have a default setup of JBoss AMQ in OpenShift and want to scale it up to two pods. How do I accomplish this? Just scaling it leads to the following: INFO | Using Persistence Adapter:…
Mantar
  • 2,710
  • 5
  • 23
  • 30
1
vote
1 answer

How to check if there are no message to consume in AMQ queue in stopmit node.js

I am using stompit package of node.js to connect to AMQ queue to subscribe message. I used ConnectFailover class to create connection and channelPool class to create pool. Problem I am facing is that once connection is made and if there is no…
Anil
  • 1,669
  • 5
  • 19
  • 44
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
0 answers

Push messages to AWS active mw from AWS lambda

The use case is to create a microservice-http-endpoint AWS lambda function which publishes message to Amazon ActiveMQ, I tried searching for the same but could not find an answer, is it possible to publish messages to AMQ from AWS lambda…
1
vote
1 answer

Does ActiveMQ Artemis / RedHat AMQ not set JMS Message ID correctly?

According to the JMS spec, I do not have to specify the message ID when sending. When I send a message via JMSProducer#send() or when I create a message via the hawt.io console, I can see the message ID being set to some internal sequential number…
Alexey
  • 1,354
  • 13
  • 30
1
2 3 4 5 6