JMS API for artemis on EKS cluster

[git-syeda]

Hi team,
We would like to know how to call artemis API url using JMS to perform admin operations. Also please help us with the complete set up on how to connect.

@brusdev please help us with the answer

[brusdev]

@git-syeda the simplest way to perform admin operations using JMS from inside the cluster is using an acceptor service, i.e. the service name that points to the acceptor my-acceptor of the broker 0 is broker-my-acceptor-0-svc

apiVersion: broker.amq.io/v1beta1
kind: ActiveMQArtemis
metadata:
  name: broker
spec:
  acceptors:
  - name: my-acceptor
    port: 61626

The simplest way to perform admin operations using JMS from outside the cluster is using an acceptor ingress, i.e. the ingress name that points to the acceptor my-acceptor of the broker 0 is broker-my-acceptor-0-svc-ing

apiVersion: broker.amq.io/v1beta1
kind: ActiveMQArtemis
metadata:
  name: broker
spec:
  acceptors:
  - name: my-acceptor
    port: 61626
    expose: true
    sslEnabled: true

For further details on setting up SSL connections with ArtemisCloud Operator, see https://artemiscloud.io/docs/tutorials/ssl_broker_setup/

For further details on using JMS to perform admin operations see the Apache ActiveMQ Artemis management example or send an email to [email protected]

[git-syeda]

Hi @brusdev , we already tried a simple java code in our eclipse set up, but we are not clear on how to implement that code using API. What will be the POST call api url and what should be the body we need to pass in to achieve this . Also how should we connect to amqp port while connecting the session. We have tried the jolokia api url which works fine, we are looking for similar url using JMS api. Could you please help in detail.

[brusdev]

Hi @git-syeda the broker acceptors support the following protocols: AMQP,CORE,HORNETQ,MQTT,OPENWIRE,STOMP and you can use a JMS client (i.e. Apache ActiveMQ Artemis JMS Client for CORE, Apache Qpid JMS Client for AMQP, ...) to connect to those acceptors. They don't expose a REST API over HTTP. Only the jolokia endpoint exposes a REST API over HTTP to perform admin operations.

[git-syeda]

Hi @brusdev , i could understand ingress part. we have the below section already added in our pod deployment yaml file.
acceptors:

• name: sslacceptor
  protocols: all
  port: 61617
  sslEnabled: true
  expose: true
  console:
  expose: true

I would like to know what are the next steps i need to apply. Like where should i create the java file? how should i run the commands to execute those operations on our cluster. If possible please let me know if we can connect over a call may be zoom?

[brusdev]

Hi @git-syeda, could you describe an example of operation that you need to execute in your cluster?

[gnaveen33]

Hi @brusdev ,

We need to perform below operations,

1. Create a queue
2. produce and consume the message from the queue.
3. clear the queue
4. delete the queue.

[brusdev]

@gnaveen33 for those operations you could use the auto-create-queues and auto-delete-queues address settings.