Async Workshop

• Async Workshop
  • Zutaten
  • Python installation
  • Wichtige Befehle
  • Links
  • Doku
    • Python
    • Java
    • Javascript
  • hawtio
  • activemq
  • Aufgaben
    • mqtt
    • jms / amqp

Zutaten

• wlp

• activeMQ

• activeMQ ResourceAdapter

• hawtio

• eclipse

• maven

Python installation

sudo apt-get install python python-pip
sudo pip install paho-mqtt
sudo pip install python-qpid-proton #ampq client

Wichtige Befehle

activemq console
activemq start
activemq stop

Links

• activeMQ AdminGUI
• hawtio

Doku

• mqtt
• ampq 0.9.1 Konzept

Python

• paho
• ampq 1.0 qpid tutorial
• ampq 1.0 qpid doku

Java

• paho
• ampq 1.0 qpid
• jms

Javascript

• paho
• mqtt.js
• sample in jsfiddle
• hivemq demo

hawtio

• download entpacken
• nach activemq/webapps/hawtio verschieben
• jetty.xml anpassen
• in activemq/conf/login.conf folgendes hinzufügen

karaf {
    org.apache.activemq.jaas.PropertiesLoginModule required
        org.apache.activemq.jaas.properties.user="users.properties"
        org.apache.activemq.jaas.properties.group="groups.properties";
};

activemq

<destinationPolicy>
	<policyMap>
		<policyEntries>
			<policyEntry queue="asyncAppQueue">
				<deadLetterStrategy>
					<sharedDeadLetterStrategy processNonPersistent="true" enableAudit="false">
						<deadLetterQueue>
							<queue physicalName="asyncAppExceptionQueue" />
						</deadLetterQueue>
					</sharedDeadLetterStrategy>
				</deadLetterStrategy>
			</policyEntry>
		</policyEntries>
	</policyMap>
</destinationPolicy>

<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://activemq.apache.org/schema/core"
	xmlns:beans="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

Aufgaben

mqtt

• Teste Last Will mit mqtt

  • 2 Listener, Der erste hört auf Last Will Topic, der zweite stirbt. Hilfe gibt es hier

• Teste persistent / non persistent Nachrichtenversand

  • Starte Listener nach Nachrichtenversand / Listener läuft beim Nachrichtenversand

• Teste retained Nachrichten

  • Starte Listener nach Nachrichtenversand / Listener läuft beim Nachrichtenversand.
  • Wie ist das Verhalten im Zusammenspiel mit Non Persistenten Nachrichten? Hilfe gibt es hier

• Teste unterschiedliche QoS

• Teste clean Sessions

  • hier

• Teste das Fehlerverhalten beim Konsum (Exception werfen im onMessage)

  • Spiel mit den QoS Stufen und dem persistent Flag
  • Wo sind die Nachrichten gelandet, sind welche verloren gegangen?

• Teste den Konsum von Nachrichten mit subtopics.

  • Beispiel: main/sub/subsub/subsubsub subscribe Dich in unterschiedlichen Ebenen und schick Nachrichten in unterschiedliche Ebenen.
  • Welche Funktionen haben die Zeichen + und # im Topicstring? Hilfe gibt es hier

jms / amqp

• Teste persistent / non persistent Nachrichtenversand

  • Starte Listener nach Nachrichtenversand / Listener läuft beim Nachrichtenversand

• Teste den Konsum von Nachrichten mit jms / amqp und message selektoren.

  • Beispiel: Headerfeld alter auf 20 setzen, selector auf "alter > 20" setzen und subscriben.

• Teste das Fehlerverhalten beim Konsum (Exception werfen im onMessage)

  • Spiel mit dem persistent Flag. Wo sind die Nachrichten gelandet, sind welche verloren gegangen?