Skip to content

Commit 42d0968

Browse files
committed
chore: fixes
1 parent 75cd883 commit 42d0968

2 files changed

Lines changed: 17 additions & 14 deletions

File tree

docker-compose-base.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ services:
163163
MSSQL_SA_PASSWORD: stanCanHazMsSQL1
164164

165165
rabbitmq:
166-
image: public.ecr.aws/docker/library/rabbitmq:3.13.7-alpine
166+
image: public.ecr.aws/docker/library/rabbitmq:3.13.0
167167
pull_policy: if_not_present
168168
ports:
169169
- 5671:5671

packages/collector/test/integration/currencies/messaging/amqplib/consumerPromises.js

Lines changed: 16 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -52,12 +52,14 @@ amqp
5252
})
5353
.then(() =>
5454
channel.consume(queueForExchangeName, msg => {
55-
expect(msg.properties.headers['X-INSTANA-L']).to.not.exist;
56-
expect(msg.properties.headers['X-INSTANA-S']).to.not.exist;
57-
expect(msg.properties.headers['X-INSTANA-T']).to.not.exist;
58-
expect(msg.properties.headers['x-instana-l']).to.not.exist;
59-
expect(msg.properties.headers['x-instana-s']).to.not.exist;
60-
expect(msg.properties.headers['x-instana-t']).to.not.exist;
55+
if (msg.properties.headers) {
56+
expect(msg.properties.headers['X-INSTANA-L']).to.not.exist;
57+
expect(msg.properties.headers['X-INSTANA-S']).to.not.exist;
58+
expect(msg.properties.headers['X-INSTANA-T']).to.not.exist;
59+
expect(msg.properties.headers['x-instana-l']).to.not.exist;
60+
expect(msg.properties.headers['x-instana-s']).to.not.exist;
61+
expect(msg.properties.headers['x-instana-t']).to.not.exist;
62+
}
6163

6264
if (msg !== null) {
6365
log(msg.content.toString());
@@ -85,13 +87,14 @@ amqp
8587
)
8688
.then(() =>
8789
channel.consume(queueName, msg => {
88-
console.log(msg);
89-
expect(msg.properties.headers['X-INSTANA-L']).to.not.exist;
90-
expect(msg.properties.headers['X-INSTANA-S']).to.not.exist;
91-
expect(msg.properties.headers['X-INSTANA-T']).to.not.exist;
92-
expect(msg.properties.headers['x-instana-l']).to.not.exist;
93-
expect(msg.properties.headers['x-instana-s']).to.not.exist;
94-
expect(msg.properties.headers['x-instana-t']).to.not.exist;
90+
if (msg.properties.headers) {
91+
expect(msg.properties.headers['X-INSTANA-L']).to.not.exist;
92+
expect(msg.properties.headers['X-INSTANA-S']).to.not.exist;
93+
expect(msg.properties.headers['X-INSTANA-T']).to.not.exist;
94+
expect(msg.properties.headers['x-instana-l']).to.not.exist;
95+
expect(msg.properties.headers['x-instana-s']).to.not.exist;
96+
expect(msg.properties.headers['x-instana-t']).to.not.exist;
97+
}
9598

9699
if (msg !== null) {
97100
log(msg.content.toString());

0 commit comments

Comments
 (0)