OpenTracing instrumentation for JMS.
pom.xml
<dependency>
<groupId>io.opentracing.contrib</groupId>
<artifactId>opentracing-jms-1</artifactId>
<version>VERSION</version>
</dependency>pom.xml
<dependency>
<groupId>io.opentracing.contrib</groupId>
<artifactId>opentracing-jms-2</artifactId>
<version>VERSION</version>
</dependency>pom.xml
<dependency>
<groupId>io.opentracing.contrib</groupId>
<artifactId>opentracing-jms-spring</artifactId>
<version>VERSION</version>
</dependency>You most likely need to exclude spring-jms and spring-context dependencies and add own (to avoid jar hell):
<dependency>
<groupId>io.opentracing.contrib</groupId>
<artifactId>opentracing-jms-spring</artifactId>
<version>VERSION</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
</exclusion>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>required version</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>required version</version>
</dependency>// Instantiate tracer
Tracer tracer = ...
// Optionally register tracer with GlobalTracer:
GlobalTracer.register(tracer);// decorate JMS MessageProducer with TracingMessageProducer
TracingMessageProducer producer = new TracingMessageProducer(messageProducer, tracer);
// decorate JMS JMSProducer with TracingJMSProducer need Session
Session session = ...
TracingJMSProducer producer = new TracingJMSProducer(jmsProducer, session, tracer);
// or with JMSContext
JMSContext jmsContext = ...
TracingJMSProducer producer = new TracingJMSProducer(jmsProducer, jmsContext, tracer);
// decorate JMS MessageConsumer with TracingMessageConsumer
TracingMessageConsumer consumer = new TracingMessageConsumer(messageConsumer, tracer);
// decorate JMS MessageListener if used with TracingMessageListener
TracingMessageListener listener = new TracingMessageListener(messageListener, tracer);
consumer.setMessageListener(listener);
// send message
Message message = ...
producer.send(message);
// receive message
Message message = consumer.receive();// create TracingJmsTemplate which extends Spring JmsTemplate
JmsTemplate jmsTemplate = new TracingJmsTemplate(connectionFactory, tracer);
// send and receive messages as usual
jmsTemplate.send(...)
jmsTemplate.convertAndSend(...);
jmsTemplate.receive(...)
jmsTemplate.receiveAndConvert(...);
...If @JmsListener is used then it is required to import TracingJmsConfiguration e.g.
@Configuration
@Import(TracingJmsConfiguration.class)
@EnableJms
public class JmsConfiguration {
...
}Modules opentracing-jms-1 and opentracing-jms-2 have next Automatic-Module-Name accordingly:
- io.opentracing.contrib.jms1
- io.opentracing.contrib.jms2
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent