ActiveMQ (Java) - Überprüfung der Zeit, die eine Verbindung aktiv war (z. B. Verbraucher oder Hersteller)

Question

Ich verwende derzeit Apache ActiveMQ als JMS-Lösung, um verschiedene Nachrichten zwischen Clients zu senden. Ich möchte die Verfügbarkeit für bestimmte Kunden (d. H. Verbraucher oder Hersteller) überprüfen, aber ich habe bisher noch keinen Weg gefunden, dies zu tun. Ich habe die Advisory-Nachrichten und StatisticsPlugin für irgendwelche Informationen darüber, wie dies zu tun ist, aber nichts hilfreich gefunden.

Ich könnte versuchen, eine Uhr in meine Consumer- und Producer-Klassen einzubetten und ein spezielles Advisory-Ziel für das Senden von Nachrichten zu erstellen, um die Zeit aus diesen Klassen abzurufen; Dies scheint jedoch unpraktisch.

Kennt jemand eine bessere Lösung oder eine Möglichkeit, dies in ActiveMQ zu tun?

Answer 1

Warum Beratung ist nicht die Lösung? Sie können es wie folgt verwenden, indem Sie Nachrichten vom Thema ActiveMQ.Advisory.Connection zu einer Warteschlange leiten, um sie zu verarbeiten, wann Sie möchten, und die Betriebszeit zu berechnen.

dieses Snippet zu Ihrem activemq.xml hinzufügen

... 
    </broker> 

    <!-- configure the camel activemq component to use the current broker --> 

    <bean id="ActiveMQVMConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
     <property name="brokerURL" value="vm://localhost?create=false&amp;waitForStart=10000"/> 
     <property name="userName" value="${activemq.username}"/> 
     <property name="password" value="${activemq.password}"/> 
    </bean> 
    <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent" > 
     <property name="connectionFactory" ref="ActiveMQVMConnectionFactory"/> 
    </bean> 

    <camelContext id="camel" trace="false" xmlns="http://camel.apache.org/schema/spring"> 
     <route> 
      <from uri="activemq:topic:ActiveMQ.Advisory.Connection" /> 
      <to uri="activemq:queue:Advisory"/> 
     </route> 
    </camelContext>