Skip to content

Commit 5ff1e0f

Browse files
breedx-splkbreedx-splk
committed
add missing files and nerf integration test until we can figure out docker container
1 parent c151f21 commit 5ff1e0f

File tree

4 files changed

+398
-0
lines changed

4 files changed

+398
-0
lines changed

‎ibm-mq-metrics/src/integrationTest/java/io/opentelemetry/ibm/mq/integration/tests/WMQMonitorIntegrationTest.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,12 +45,14 @@
4545
import org.junit.jupiter.api.AfterEach;
4646
import org.junit.jupiter.api.BeforeAll;
4747
import org.junit.jupiter.api.BeforeEach;
48+
import org.junit.jupiter.api.Disabled;
4849
import org.junit.jupiter.api.Test;
4950
import org.junit.jupiter.api.extension.RegisterExtension;
5051
import org.slf4j.Logger;
5152
import org.slf4j.LoggerFactory;
5253

5354
/** Integration Test for WMQMonitor */
55+
@Disabled
5456
class WMQMonitorIntegrationTest {
5557

5658
private static final Logger logger = LoggerFactory.getLogger(WMQMonitorIntegrationTest.class);

‎ibm-mq-metrics/src/integrationTest/resources/conf/test-config.yml‎

Lines changed: 197 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,197 @@
1+
2+
#This is the timeout on queue metrics and channel metrics threads.Default value is 20 seconds.
3+
#No need to change the default unless you know what you are doing.
4+
#queueMetricsCollectionTimeoutInSeconds: 40
5+
#channelMetricsCollectionTimeoutInSeconds: 40
6+
#topicMetricsCollectionTimeoutInSeconds: 40
7+
8+
queueManagers:
9+
- name: "QM1"
10+
host: "localhost"
11+
port: 1414
12+
13+
#The transport type for the queue manager connection, the default is "Bindings" for a binding type connection
14+
#For bindings type, connection WMQ extension (i.e machine agent) need to be on the same machine on which WebbsphereMQ server is running
15+
#For client type, connection change it to "Client".
16+
transportType: "Client"
17+
18+
#Channel name of the queue manager, channel should be server-conn type.
19+
#This field is not required in case of transportType: Bindings
20+
channelName: DEV.ADMIN.SVRCONN
21+
22+
#for user access level, please check "Access Permissions" section on the extensions page
23+
#comment out the username and password in case of transportType: Bindings.
24+
username: "admin"
25+
password: "passw0rd"
26+
27+
#PCF requests are always sent to SYSTEM.ADMIN.COMMAND.QUEUE. The PCF responses to these requests are sent to the default reply-to queue called
28+
#SYSTEM.DEFAULT.MODEL.QUEUE. However, you can override this behavior and send it to a temporary dynamic queue by changing the modelQueueName and replyQueuePrefix fields.
29+
#For more details around this https://www.ibm.com/support/knowledgecenter/SSFKSJ_7.5.0/com.ibm.mq.ref.adm.doc/q083240_.htm & https://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.adm.doc/q020010_.htm
30+
#modelQueueName: ""
31+
#replyQueuePrefix: ""
32+
33+
34+
#Sets the CCSID used in the message descriptor of request and response messages. The default value is MQC.MQCCSI_Q_MGR.
35+
#To set this, please use the integer value.
36+
#ccsid:
37+
38+
#Sets the encoding used in the message descriptor of request and response messages. The default value is MQC.MQENC_NATIVE.
39+
#To set this, please use the integer value.
40+
#encoding:
41+
42+
# IBM Cipher Suite e.g. "SSL_RSA_WITH_AES_128_CBC_SHA256"..
43+
# For translation to IBM Cipher http://www.ibm.com/support/knowledgecenter/SSFKSJ_8.0.0/com.ibm.mq.dev.doc/q113210_.htm
44+
# A cipher working for IBM Cloud MQ and Temurin JDK 8 is TLS_AES_128_GCM_SHA256
45+
#cipherSuite: "TLS_AES_128_GCM_SHA256"
46+
47+
48+
queueFilters:
49+
#Can provide complete queue name or generic names. A generic name is a character string followed by an asterisk (*),
50+
#for example ABC*, and it selects all objects having names that start with the selected character string.
51+
#An asterisk on its own matches all possible names.
52+
include: ["*"]
53+
exclude:
54+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
55+
- type: "STARTSWITH"
56+
#The name of the queue or queue name pattern as per queue filter, comma separated values
57+
values: ["SYSTEM","AMQ"]
58+
59+
60+
channelFilters:
61+
#Can provide complete channel name or generic names. A generic name is a character string followed by an asterisk (*),
62+
#for example ABC*, and it selects all objects having names that start with the selected character string.
63+
#An asterisk on its own matches all possible names.
64+
include: ["*"]
65+
exclude:
66+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
67+
- type: "STARTSWITH"
68+
#The name of the queue or queue name pattern as per queue filter, comma separated values
69+
values: ["SYSTEM"]
70+
71+
listenerFilters:
72+
#Can provide complete channel name or generic names. A generic name is a character string followed by an asterisk (*),
73+
#for example ABC*, and it selects all objects having names that start with the selected character string.
74+
#An asterisk on its own matches all possible names.
75+
include: ["*"]
76+
exclude:
77+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
78+
- type: "STARTSWITH"
79+
#The name of the queue or queue name pattern as per queue filter, comma separated values
80+
values: ["SYSTEM"]
81+
82+
topicFilters:
83+
# For topics, IBM MQ uses the topic wildcard characters ('#' and '+') and does not treat a trailing asterisk as a wildcard
84+
# https://www.ibm.com/support/knowledgecenter/en/SSFKSJ_7.5.0/com.ibm.mq.pla.doc/q005020_.htm
85+
include: ["#"]
86+
exclude:
87+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
88+
- type: "STARTSWITH"
89+
#The name of the queue or queue name pattern as per queue filter, comma separated values
90+
values: ["SYSTEM","$SYS"]
91+
92+
metrics:
93+
"mq.message.retry.count": # Number of message retries
94+
enabled: true
95+
"mq.status": # Channel status
96+
enabled: true
97+
"mq.max.sharing.conversations": # Maximum number of conversations permitted on this channel instance.
98+
enabled: true
99+
"mq.current.sharing.conversations": # Current number of conversations permitted on this channel instance.
100+
enabled: true
101+
"mq.byte.received": # Number of bytes received
102+
enabled: true
103+
"mq.byte.sent": # Number of bytes sent
104+
enabled: true
105+
"mq.buffers.received": # Buffers received
106+
enabled: true
107+
"mq.buffers.sent": # Buffers sent
108+
enabled: true
109+
"mq.message.count": # Message count
110+
enabled: true
111+
"mq.open.input.count": # Count of applications sending messages to the queue
112+
enabled: true
113+
"mq.open.output.count": # Count of applications consuming messages from the queue
114+
enabled: true
115+
"mq.high.queue.depth": # The current high queue depth
116+
enabled: true
117+
"mq.service.interval": # The queue service interval
118+
enabled: true
119+
"mq.queue.depth.full.event": # The number of full queue events
120+
enabled: true
121+
"mq.queue.depth.high.event": # The number of high queue events
122+
enabled: true
123+
"mq.queue.depth.low.event": # The number of low queue events
124+
enabled: true
125+
"mq.uncommitted.messages": # Number of uncommitted messages
126+
enabled: true
127+
"mq.oldest.msg.age": # Queue message oldest age
128+
enabled: true
129+
"mq.current.max.queue.filesize": # Current maximum queue file size
130+
enabled: true
131+
"mq.current.queue.filesize": # Current queue file size
132+
enabled: true
133+
"mq.instances.per.client": # Instances per client
134+
enabled: true
135+
"mq.message.deq.count": # Message dequeue count
136+
enabled: true
137+
"mq.message.enq.count": # Message enqueue count
138+
enabled: true
139+
"mq.queue.depth": # Current queue depth
140+
enabled: true
141+
"mq.service.interval.event": # Queue service interval event
142+
enabled: true
143+
"mq.reusable.log.size": # The amount of space occupied, in megabytes, by log extents available to be reused.
144+
enabled: true
145+
"mq.manager.active.channels": # The queue manager active maximum channels limit
146+
enabled: true
147+
"mq.restart.log.size": # Size of the log data required for restart recovery in megabytes.
148+
enabled: true
149+
"mq.max.queue.depth": # Maximum queue depth
150+
enabled: true
151+
"mq.onqtime.1": # Amount of time, in microseconds, that a message spent on the queue, over a short period
152+
enabled: true
153+
"mq.onqtime.2": # Amount of time, in microseconds, that a message spent on the queue, over a longer period
154+
enabled: true
155+
"mq.message.received.count": # Number of messages received
156+
enabled: true
157+
"mq.message.sent.count": # Number of messages sent
158+
enabled: true
159+
"mq.max.instances": # Max channel instances
160+
enabled: true
161+
"mq.connection.count": # Active connections count
162+
enabled: true
163+
"mq.manager.status": # Queue manager status
164+
enabled: true
165+
"mq.heartbeat": # Queue manager heartbeat
166+
enabled: true
167+
"mq.archive.log.size": # Queue manager archive log size
168+
enabled: true
169+
"mq.manager.max.active.channels": # Queue manager max active channels
170+
enabled: true
171+
"mq.manager.statistics.interval": # Queue manager statistics interval
172+
enabled: true
173+
"mq.publish.count": # Topic publication count
174+
enabled: true
175+
"mq.subscription.count": # Topic subscription count
176+
enabled: true
177+
"mq.listener.status": # Listener status
178+
enabled: true
179+
"mq.unauthorized.event": # Number of authentication error events
180+
enabled: true
181+
"mq.manager.max.handles": # Max open handles
182+
enabled: true
183+
184+
sslConnection:
185+
trustStorePath: ""
186+
trustStorePassword: ""
187+
188+
keyStorePath: ""
189+
keyStorePassword: ""
190+
191+
# Configure the OTLP exporter using system properties keys following the specification https://opentelemetry.io/docs/languages/java/configuration/
192+
otlpExporter:
193+
otel.exporter.otlp.endpoint: http://0.0.0.0:4318
194+
otel.exporter.otlp.protocol: http/protobuf
195+
otel.metric.export.interval: 5s
196+
otel.logs.exporter: none
197+
otel.traces.exporter: none

‎ibm-mq-metrics/src/integrationTest/resources/conf/test-queuemgr-config.yml‎

Lines changed: 170 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,170 @@
1+
queueManagers:
2+
- name: "QM1"
3+
host: "localhost"
4+
port: 1414
5+
6+
#The transport type for the queue manager connection, the default is "Bindings" for a binding type connection
7+
#For bindings type, connection WMQ extension (i.e machine agent) need to be on the same machine on which WebbsphereMQ server is running
8+
#For client type, connection change it to "Client".
9+
transportType: "Client"
10+
11+
#Channel name of the queue manager, channel should be server-conn type.
12+
#This field is not required in case of transportType: Bindings
13+
channelName: DEV.ADMIN.SVRCONN
14+
15+
#for user access level, please check "Access Permissions" section on the extensions page
16+
#comment out the username and password in case of transportType: Bindings.
17+
username: "admin"
18+
password: "passw0rd"
19+
20+
queueFilters:
21+
#Can provide complete queue name or generic names. A generic name is a character string followed by an asterisk (*),
22+
#for example ABC*, and it selects all objects having names that start with the selected character string.
23+
#An asterisk on its own matches all possible names.
24+
include: ["*"]
25+
exclude:
26+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
27+
- type: "STARTSWITH"
28+
#The name of the queue or queue name pattern as per queue filter, comma separated values
29+
values: ["SYSTEM","AMQ"]
30+
31+
32+
channelFilters:
33+
#Can provide complete channel name or generic names. A generic name is a character string followed by an asterisk (*),
34+
#for example ABC*, and it selects all objects having names that start with the selected character string.
35+
#An asterisk on its own matches all possible names.
36+
include: ["*"]
37+
exclude:
38+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
39+
- type: "STARTSWITH"
40+
#The name of the queue or queue name pattern as per queue filter, comma separated values
41+
values: ["SYSTEM"]
42+
43+
listenerFilters:
44+
#Can provide complete channel name or generic names. A generic name is a character string followed by an asterisk (*),
45+
#for example ABC*, and it selects all objects having names that start with the selected character string.
46+
#An asterisk on its own matches all possible names.
47+
include: ["*"]
48+
exclude:
49+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
50+
- type: "STARTSWITH"
51+
#The name of the queue or queue name pattern as per queue filter, comma separated values
52+
values: ["SYSTEM"]
53+
54+
topicFilters:
55+
# For topics, IBM MQ uses the topic wildcard characters ('#' and '+') and does not treat a trailing asterisk as a wildcard
56+
# https://www.ibm.com/support/knowledgecenter/en/SSFKSJ_7.5.0/com.ibm.mq.pla.doc/q005020_.htm
57+
include: ["#"]
58+
exclude:
59+
#type value: STARTSWITH, EQUALS, ENDSWITH, CONTAINS
60+
- type: "STARTSWITH"
61+
#The name of the queue or queue name pattern as per queue filter, comma separated values
62+
values: ["SYSTEM","$SYS"]
63+
64+
metrics:
65+
"mq.message.retry.count": # Number of message retries
66+
enabled: true
67+
"mq.status": # Channel status
68+
enabled: true
69+
"mq.max.sharing.conversations": # Maximum number of conversations permitted on this channel instance.
70+
enabled: true
71+
"mq.current.sharing.conversations": # Current number of conversations permitted on this channel instance.
72+
enabled: true
73+
"mq.byte.received": # Number of bytes received
74+
enabled: true
75+
"mq.byte.sent": # Number of bytes sent
76+
enabled: true
77+
"mq.buffers.received": # Buffers received
78+
enabled: true
79+
"mq.buffers.sent": # Buffers sent
80+
enabled: true
81+
"mq.message.count": # Message count
82+
enabled: true
83+
"mq.open.input.count": # Count of applications sending messages to the queue
84+
enabled: true
85+
"mq.open.output.count": # Count of applications consuming messages from the queue
86+
enabled: true
87+
"mq.high.queue.depth": # The current high queue depth
88+
enabled: true
89+
"mq.service.interval": # The queue service interval
90+
enabled: true
91+
"mq.queue.depth.full.event": # The number of full queue events
92+
enabled: true
93+
"mq.queue.depth.high.event": # The number of high queue events
94+
enabled: true
95+
"mq.queue.depth.low.event": # The number of low queue events
96+
enabled: true
97+
"mq.uncommitted.messages": # Number of uncommitted messages
98+
enabled: true
99+
"mq.oldest.msg.age": # Queue message oldest age
100+
enabled: true
101+
"mq.current.max.queue.filesize": # Current maximum queue file size
102+
enabled: true
103+
"mq.current.queue.filesize": # Current queue file size
104+
enabled: true
105+
"mq.instances.per.client": # Instances per client
106+
enabled: true
107+
"mq.message.deq.count": # Message dequeue count
108+
enabled: true
109+
"mq.message.enq.count": # Message enqueue count
110+
enabled: true
111+
"mq.queue.depth": # Current queue depth
112+
enabled: true
113+
"mq.service.interval.event": # Queue service interval event
114+
enabled: true
115+
"mq.reusable.log.size": # The amount of space occupied, in megabytes, by log extents available to be reused.
116+
enabled: true
117+
"mq.manager.active.channels": # The queue manager active maximum channels limit
118+
enabled: true
119+
"mq.restart.log.size": # Size of the log data required for restart recovery in megabytes.
120+
enabled: true
121+
"mq.max.queue.depth": # Maximum queue depth
122+
enabled: true
123+
"mq.onqtime.1": # Amount of time, in microseconds, that a message spent on the queue, over a short period
124+
enabled: true
125+
"mq.onqtime.2": # Amount of time, in microseconds, that a message spent on the queue, over a longer period
126+
enabled: true
127+
"mq.message.received.count": # Number of messages received
128+
enabled: true
129+
"mq.message.sent.count": # Number of messages sent
130+
enabled: true
131+
"mq.max.instances": # Max channel instances
132+
enabled: true
133+
"mq.connection.count": # Active connections count
134+
enabled: true
135+
"mq.manager.status": # Queue manager status
136+
enabled: true
137+
"mq.heartbeat": # Queue manager heartbeat
138+
enabled: true
139+
"mq.archive.log.size": # Queue manager archive log size
140+
enabled: true
141+
"mq.manager.max.active.channels": # Queue manager max active channels
142+
enabled: true
143+
"mq.manager.statistics.interval": # Queue manager statistics interval
144+
enabled: true
145+
"mq.publish.count": # Topic publication count
146+
enabled: true
147+
"mq.subscription.count": # Topic subscription count
148+
enabled: true
149+
"mq.listener.status": # Listener status
150+
enabled: true
151+
"mq.unauthorized.event": # Number of authentication error events
152+
enabled: true
153+
"mq.manager.max.handles": # Max open handles
154+
enabled: true
155+
156+
157+
sslConnection:
158+
trustStorePath: ""
159+
trustStorePassword: ""
160+
trustStoreEncryptedPassword: ""
161+
162+
keyStorePath: ""
163+
keyStorePassword: ""
164+
keyStoreEncryptedPassword: ""
165+
166+
# Configure the OTLP exporter using system properties keys following the specification https://opentelemetry.io/docs/languages/java/configuration/
167+
otlpExporter:
168+
otel.metric.export.interval: 5s
169+
otel.logs.exporter: none
170+
otel.traces.exporter: none

0 commit comments

Comments
 (0)