This article shows how to search ActiveMQ consumer events using the REST API.
Search ActiveMQ Consumer Events
GET /activemq/consumers/{nodeName}/{managerName}/{brokerName}/{consumerName}/events
Retrieves event details associated with a specific ActiveMQ consumer.
Example Request
curl -X 'GET' \ 'http://<hostname>:8019/rest/v1/activemq/consumers/CMACTIVEMQ/Activemq-server/DemoBroker/Consumer1/events?eventType=All&limit=2' \ -H 'accept: application/json' \ -H 'Authorization: Basic QWRtaW46YWRtaW4='
Query Parameters
| Parameter | Type | Description |
|---|---|---|
eventType |
string | Event type. Possible values: None, All, Manager, Alter, QMgr, Channel, Performance, Config, Command, Schedule, Bridge, Logger. |
timestamp |
integer | Event timestamp (Unix epoch). |
limit |
integer | Limit of returned objects. |
attributes |
string | Comma-separated list of attributes or sections to retrieve. |
validateAccessForUser |
string | Validate endpoint access for user. |
Response Codes
200 OK – Events retrieved successfully.
* – Returns
ErrorPojoif request fails.
Example Response
200 OK – Events retrieved successfully.
[
{
"wgsName": "MQM",
"type": "Channel",
"eventNo": 102,
"uri": "tcp://localhost:61616",
"general": {
"eventTimeStamp": "2025-09-29T11:40:12.123Z",
"nodeName": "CMACTIVEMQ",
"qmgrName": "QM1"
},
"diagnostic": {
"eventIdentifier": 501,
"userId": "admin",
"eventTime": 1695984012000,
"reasonQualifier": 2000,
"errorId": 0,
"origUserId": "system",
"objectType": "Queue",
"objectName": "TEST.QUEUE"
},
"extended": {
"clientConnectionName": "127.0.0.1",
"eventDescription": "Queue threshold exceeded",
"eventOrigin": "QMgr",
"eventQMgr": "QM1",
"command": 0,
"pcfCommand": 0,
"msgPutDate": "2025-09-29",
"msgPutTime": "11:40:00",
"acctToken": "xyz-123",
"applType": "JMS",
"applIdentity": "AppA",
"applName": "OrderProcessor",
"applOrigin": "Local",
"eventMsgSeq": 456
},
"channel": {
"channelType": "Sender",
"channelName": "CHL1",
"listenerName": "LISTENER1",
"serviceName": "SERVICE1",
"connectionName": "192.168.1.100",
"sslPeerName": "CN=client",
"sslHandshake": "successful"
},
"scheduler": {
"jobId": "job-123",
"status": "Submitted",
"jobTimeStamp": "2025-09-29T11:40:12.123Z",
"reason": 0,
"jobTags": "tag1"
}
},
{
"wgsName": "MQM",
"type": "Performance",
"eventNo": 103,
"uri": "tcp://localhost:61616",
"general": {
"eventTimeStamp": "2025-09-29T11:42:30.456Z",
"nodeName": "CMACTIVEMQ",
"qmgrName": "QM1"
},
"diagnostic": {
"eventIdentifier": 502,
"userId": "monitor",
"eventTime": 1695984150000,
"reasonQualifier": 0,
"errorId": 0,
"origUserId": "monitor",
"objectType": "Topic",
"objectName": "ORDERS.TOPIC"
},
"extended": {
"clientConnectionName": "192.168.1.105",
"eventDescription": "High message rate detected",
"eventOrigin": "Other",
"eventQMgr": "QM1",
"applType": "JMS",
"applIdentity": "AppB",
"applName": "NotificationService",
"applOrigin": "Remote",
"eventMsgSeq": 789
},
"perfm": {
"qName": "ORDERS.TOPIC",
"timeSinceReset": 3600,
"hiQDepth": 500,
"msgDeqCount": 300,
"msgEnqCount": 800
}
}
]