Jakarta Messaging

Jakarta Messaging standardisiert asynchrone Kommunikation über Queues und Topics.

Fachliches Verständnis

Messaging entkoppelt Systeme zeitlich und technisch, ist aber kein Ersatz für saubere Fachereignisse und Idempotenz. In der Praxis ist wichtig, die Spezifikation nicht mit der konkreten Runtime zu verwechseln. Der Standard beschreibt die portablen APIs, die Implementierung entscheidet über Konfiguration, Performance, Betrieb und Support.

Technisches Beispiel

@ApplicationScoped
public class OrderEventPublisher {
    @Inject JMSContext context;
    @Resource(lookup = "java:/jms/topic/order-events") Topic topic;

    public void publish(OrderPlaced event) {
        ObjectMessage message = context.createObjectMessage(event);
        message.setStringProperty("eventType", "OrderPlaced");
        context.createProducer().send(topic, message);
    }
}

@MessageDriven(activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "java:/jms/topic/order-events")
})
public class BillingConsumer implements MessageListener {
    public void onMessage(Message message) { /* idempotent verarbeiten */ }
}

Enterprise-Fallen

• Nicht-idempotente Consumer.
• Nachrichtenformat ohne Versionierung.
• Synchrone Erwartungen über asynchrone Kanäle.

Legacy-Modernisierung

IBM MQ/JMS Legacy kann mit standardisierten Jakarta Messaging APIs gekapselt werden.