open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add debug logging to SpringTemplateJms1Test (#5087)

This commit is contained in:
Lauri Tulmin 2022-01-13 02:13:32 +02:00 committed by GitHub
parent f7da97bd9d
commit 0624b6561e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
instrumentation/jms-1.1/javaagent/src/jms2Test/groovy/SpringTemplateJms2Test.groovy
View File

@ -112,7 +112,6 @@ class SpringTemplateJms2Test extends AgentInstrumentationSpecification {
session -> template.getMessageConverter().toMessage("responded!", session) session -> template.getMessageConverter().toMessage("responded!", session)
} }
} }
// wait for thread to start, we expect the first span to be from receive
TextMessage receivedMessage = template.sendAndReceive(destination) { TextMessage receivedMessage = template.sendAndReceive(destination) {
session -> template.getMessageConverter().toMessage(messageText, session) session -> template.getMessageConverter().toMessage(messageText, session)
} }

7
instrumentation/jms-1.1/javaagent/src/test/groovy/SpringTemplateJms1Test.groovy
View File

@ -23,7 +23,7 @@ import static Jms1Test.consumerSpan
import static Jms1Test.producerSpan import static Jms1Test.producerSpan
class SpringTemplateJms1Test extends AgentInstrumentationSpecification { class SpringTemplateJms1Test extends AgentInstrumentationSpecification {
private static final Logger logger = LoggerFactory.getLogger(SpringTemplateJms1Test) private static final Logger logger = LoggerFactory.getLogger("io.opentelemetry.SpringTemplateJms1Test")
private static final GenericContainer broker = new GenericContainer("rmohr/activemq:latest") private static final GenericContainer broker = new GenericContainer("rmohr/activemq:latest")
.withExposedPorts(61616, 8161) .withExposedPorts(61616, 8161)
@ -78,10 +78,12 @@ class SpringTemplateJms1Test extends AgentInstrumentationSpecification {
setup: setup:
AtomicReference<String> msgId = new AtomicReference<>() AtomicReference<String> msgId = new AtomicReference<>()
Thread.start { Thread.start {
logger.info("calling receive")
TextMessage msg = template.receive(destination) TextMessage msg = template.receive(destination)
assert msg.text == messageText assert msg.text == messageText
msgId.set(msg.getJMSMessageID()) msgId.set(msg.getJMSMessageID())
logger.info("calling send")
template.send(msg.getJMSReplyTo()) { template.send(msg.getJMSReplyTo()) {
session -> template.getMessageConverter().toMessage("responded!", session) session -> template.getMessageConverter().toMessage("responded!", session)
} }
@ -89,13 +91,16 @@ class SpringTemplateJms1Test extends AgentInstrumentationSpecification {
def receivedMessage def receivedMessage
def stopwatch = Stopwatch.createStarted() def stopwatch = Stopwatch.createStarted()
while (receivedMessage == null && stopwatch.elapsed(TimeUnit.SECONDS) < 10) { while (receivedMessage == null && stopwatch.elapsed(TimeUnit.SECONDS) < 10) {
logger.info("calling sendAndReceive")
// sendAndReceive() returns null if template.receive() has not been called yet // sendAndReceive() returns null if template.receive() has not been called yet
receivedMessage = template.sendAndReceive(destination) { receivedMessage = template.sendAndReceive(destination) {
session -> template.getMessageConverter().toMessage(messageText, session) session -> template.getMessageConverter().toMessage(messageText, session)
} }
logger.info("received message " + receivedMessage)
} }
expect: expect:
receivedMessage != null
receivedMessage.text == "responded!" receivedMessage.text == "responded!"
assertTraces(4) { assertTraces(4) {
traces.sort(orderByRootSpanName( traces.sort(orderByRootSpanName(