pulsar-jms
pulsar-jms copied to clipboard
datastax
DataStax Starlight for JMS, a JMS API for Apache Pulsar ®
JMS Traces is a configurable pulsar interceptor that logs a variety of internal events. Traces are sent to the regular SLF4J logger with the logger name “jms-tracing-\”. See jmsTracingEventList’s description...
From an observability perspective it would be very useful to have some system jms properties that represent the compression algorithm used for each message. We could implement this by adding...
```java org.opentest4j.AssertionFailedError: Expected :foo2 Actual :foo3 at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55) at org.junit.jupiter.api.AssertionUtils.failNotEqual(AssertionUtils.java:62) at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:182) at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:177) at org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:1124) at com.datastax.oss.pulsar.jms.TransactionsTest.emulatedTransactionsAsyncSendTest(TransactionsTest.java:791) at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) at java.base/java.lang.reflect.Method.invoke(Method.java:578) at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688) at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)...
This PR fixes [CVE-2023-46604](https://nvd.nist.gov/vuln/detail/CVE-2023-46604) By upgrading activemq-version to [5.16.7](https://activemq.apache.org/news/cve-2023-46604)
https://github.com/datastax/pulsar-jms/blob/dacf5a8977effdb67c9b438ac6b11bdb3dd2d1ea/pulsar-jms/src/main/java/com/datastax/oss/pulsar/jms/PulsarMessageProducer.java#L354
Currently we bundle only jar files with javax.jms, but modern applications starts to require Jakarta JMS (the next version of the spec)
`QueueBrowser` connects to Pulsar using a `Reader`. A reader looks like a normal consumer from the pulsar protocol perspective. It is associated with a subscription name, which is later used...
