Play Dependencies für JBoss ActiveMQ mit Zookeeper

Es gibt bereits ein gutes Tutorial, wie man eine MQ via Zookeeper anspricht, hier aber noch mal explizit für Play (1 und 2).

Schritt 1: Libraries hinzufügen

Play 1

Die Excludes waren für mein Setup nötig, das müssen sie aber nicht generell sein:

require:
    # ...
    - io.fabric8 -> fabric-groups 1.0.0.redhat-379:
        exclude:
            - org.ow2.asm -> *
    - io.fabric8 -> fabric-zookeeper 1.0.0.redhat-379:
        exclude:
            - org.ow2.asm -> *
    - org.jboss.amq -> mq-fabric 6.1.0.redhat-379
    - org.osgi -> org.osgi.core 5.0.0
    - org.osgi -> org.osgi.compendium 5.0.0

require:

# ...

- io.fabric8 -> fabric-groups 1.0.0.redhat-379:

exclude:

- org.ow2.asm -> *

- io.fabric8 -> fabric-zookeeper 1.0.0.redhat-379:

exclude:

- org.ow2.asm -> *

- org.jboss.amq -> mq-fabric 6.1.0.redhat-379

- org.osgi -> org.osgi.core 5.0.0

- org.osgi -> org.osgi.compendium 5.0.0

Damit das funktioniert, müssen die folgenden Repositories in den Ivy-Setting definiert werden:

<ibiblio name="jboss-earlyacces" m2compatible="true" root="https://repository.jboss.org/nexus/content/groups/ea/" />
<ibiblio name="jboss-releases" m2compatible="true" root="https://repository.jboss.org/nexus/content/repositories/fs-releases/" />

1 2	<ibiblio name="jboss-earlyacces" m2compatible="true" root="https://repository.jboss.org/nexus/content/groups/ea/" /> <ibiblio name="jboss-releases" m2compatible="true" root="https://repository.jboss.org/nexus/content/repositories/fs-releases/" />

Eine Anmerkung dazu: Das “Early Access” Repo ist meiner Einschätzung nach eigentlich nicht nötig; alle letztlich verwendeten Dependencies kommen aus dem “Releases” Repo. Aber: Offenbar gibt es irgendwelche transitiven Dependencies, die dort zu finden sind. Sie werden “später” durch andere transitive Dependecies “überschrieben”, aber sie müssen trotzdem aufgelöst werden können! Andernfalls funktioniert zwar auch alles, aber es gibt unschöne Warnings. Und ich habe einige Zeit darauf verwendet, das “Early Access” Repo durch force und exclude wegzukonfigurieren – ein Fass ohne Boden 🙂

Play 2

// has to be here to make resolvers work?
import Keys._

// ...

libraryDependencies ++= Seq(
  // ...
  "io.fabric8" % "fabric-groups" % "1.0.0.redhat-379",
  "io.fabric8" % "fabric-zookeeper" % "1.0.0.redhat-379",
  "org.jboss.amq" % "mq-fabric" % "6.1.0.redhat-379",
  "org.osgi" % "org.osgi.core" % "5.0.0",
  "org.osgi" % "org.osgi.compendium" % "5.0.0"
)

resolvers ++= Seq(
    // ...
    "jboss-earlyAccess" at "https://repository.jboss.org/nexus/content/groups/ea/",
    "jboss-releases" at "https://repository.jboss.org/nexus/content/repositories/fs-releases/"
)

// has to be here to make resolvers work?

import Keys._

// ...

libraryDependencies ++= Seq(

// ...

"io.fabric8" % "fabric-groups" % "1.0.0.redhat-379",

"io.fabric8" % "fabric-zookeeper" % "1.0.0.redhat-379",

"org.jboss.amq" % "mq-fabric" % "6.1.0.redhat-379",

"org.osgi" % "org.osgi.core" % "5.0.0",

"org.osgi" % "org.osgi.compendium" % "5.0.0"

)

resolvers ++= Seq(

// ...

"jboss-earlyAccess" at "https://repository.jboss.org/nexus/content/groups/ea/",

"jboss-releases" at "https://repository.jboss.org/nexus/content/repositories/fs-releases/"

)

Schritt 2: Konfiguration

messagequeue = {
  url="discovery:(fabric:my-group-name)",
  zookeeper.url="127.0.0.1:2181",
  username=foo,
  password=bar
}

messagequeue = {

url="discovery:(fabric:my-group-name)",

zookeeper.url="127.0.0.1:2181",

username=foo,

password=bar

}

Schritt 3: Im Code

private static final HOST_URL = String
  .format("failover:(%s)?nested.wireFormat.maxInactivityDuration=%d&maxReconnectAttempts=1&startupMaxReconnectAttempts=1",
  Play.application().configuration().getString("messagequeue.url"), TIMEOUT);
private static final String USERNAME = Play.application().configuration().getString("messagequeue.username");
private static final String PASSWORD = Play.application().configuration().getString("messagequeue.password");
private static String ZOOKEEPER_URL = Play.configuration.getProperty("messagequeue.zookeeper.url");

// ...

ActiveMQConnectionFactory factory = hasCredentials ?
  new ActiveMQConnectionFactory(USERNAME, PASSWORD, HOST_URL)
  : new ActiveMQConnectionFactory(HOST_URL);

Connection connection = factory.createConnection();

// ...

// magic!
System.setProperty("zookeeper.url", ZOOKEEPER_URL);

private static final HOST_URL = String

.format("failover:(%s)?nested.wireFormat.maxInactivityDuration=%d&maxReconnectAttempts=1&startupMaxReconnectAttempts=1",

Play.application().configuration().getString("messagequeue.url"), TIMEOUT);

private static final String USERNAME = Play.application().configuration().getString("messagequeue.username");

private static final String PASSWORD = Play.application().configuration().getString("messagequeue.password");

private static String ZOOKEEPER_URL = Play.configuration.getProperty("messagequeue.zookeeper.url");

// ...

ActiveMQConnectionFactory factory = hasCredentials ?

new ActiveMQConnectionFactory(USERNAME, PASSWORD, HOST_URL)

: new ActiveMQConnectionFactory(HOST_URL);

Connection connection = factory.createConnection();

// ...

// magic!

System.setProperty("zookeeper.url", ZOOKEEPER_URL);

HTH!

Apache Ant: Ja/nein-Dialog

Apache kennt von haus aus nur Input Dialoge (korrigiert mich), und damit kann man natürlich “j”/”n”-Eingaben bauen (siehe Examples). Schöner ist aber ein richtiger Ja/Nein-Dialog, wie Javascripts confirm. Außerdem gibt es if/else nur mit Ant contrib, das nicht zwingend überall installiert ist. Bitte nennt mir eine schönere Lösung als die folgende, aber damit geht’s – Confirm-Dialoge und if/else-Verzweigung abhängig von der User-Eingabe:

<target name="_set URLs and ports" depends="use Proxy, setURLs, setURLsAndProxy">
</target>

<target name="use Proxy">
  <script language="javascript">
    <![CDATA[
      importPackage(javax.swing);
      var answer = JOptionPane.showConfirmDialog(null, "Enable proxy? (Probably no)", "", JOptionPane.YES_NO_OPTION);
      project.setProperty("answer", answer);
    ]]>
  </script>
  <condition property="useProxy">
    <equals arg1="${answer}" arg2="0" />
  </condition>
</target>

<target name="setURLs" unless="useProxy">
  <echo message="set URLs" />
</target>

<target name="setURLsAndProxy" if="useProxy">
  <echo message="set URLs and proxy" />
</target>

</target>

<![CDATA[

importPackage(javax.swing);

var answer = JOptionPane.showConfirmDialog(null, "Enable proxy? (Probably no)", "", JOptionPane.YES_NO_OPTION);

project.setProperty("answer", answer);

]]>

</script>

</condition>

</target>

</target>

</target>

Die Targets “setURLs” und “setURLsAndProxy” werden nur abhängig von ${useProxy} ausgeführt, bzw nicht ausgeführt (if/unless).

Apache Ant: antcall für fileset

Dateien lassen sich in Ant (auch rekursiv) mit fileset finden. Allerdings kann man mit Bordmitteln nicht pro gefundenem File einen antcall absetzen. Das Internet schlägt Ant-Contrib vor, da gibt es “for” und “foreach”, aber das zum Laufen zu bekommen bin ich gerade zu blöd. Warum liefern die ihr ant-contrib-<version>.jar nicht mit aus??

Egal. Was mit Bordmitteln geht, ist Javascript (Danke, Björn!). Dann kann man Dateien mit JS auslesen, und an antcall übergeben. Zusammen sieht das so aus:

<target name="_handle logging">
    <script language="javascript">
        <![CDATA[
            importClass(java.io.File);

            // read files from ${project.dir}
            dir = project.getProperty("project.dir");
            fs = project.createDataType("fileset");
            fs.setDir( new File( dir ) );
            fs.setIncludes( "**/log4j.xml" );

            // iterate files:
            srcFiles = fs.getDirectoryScanner( project ).getIncludedFiles( );
            for ( i = 0; i < srcFiles.length; i++ ) {

                // create antcall task, pass current file, execute:
                antcall = project.createTask("antcall");
                antcall.init();
                antcall.setTarget("handle log4j.xml");
                param = antcall.createParam();
                param.setName("file");
                param.setValue(srcFiles[i]);
                antcall.execute();
            }
        ]]>
    </script>
</target>

<target name="handle log4j.xml">
    <echo message="processing file ${file}..." />
    <!-- ... -->
</target>

<![CDATA[

importClass(java.io.File);

// read files from ${project.dir}

dir = project.getProperty("project.dir");

fs = project.createDataType("fileset");

fs.setDir( new File( dir ) );

fs.setIncludes( "**/log4j.xml" );

// iterate files:

srcFiles = fs.getDirectoryScanner( project ).getIncludedFiles( );

for ( i = 0; i < srcFiles.length; i++ ) {

// create antcall task, pass current file, execute:

antcall = project.createTask("antcall");

antcall.init();

antcall.setTarget("handle log4j.xml");

param = antcall.createParam();

param.setName("file");

param.setValue(srcFiles[i]);

antcall.execute();

}

]]>

</script>

</target>

</target>

WSDL2Java: Axis2 in Eclipse Indigo

Wer das Problem hat, dass die Eclipse-Plugins in Version 1.6.1 nicht funktionieren, der möge eine ältere Version probieren. Ich bin über die Download-Seite der 1.6.0 auf FTP-Server (die HTTP gingen alle nicht mehr…) gekommen, die die 1.5.6 hosten. Das Problem ist übrigens seit mindestens November 2011 bekannt m(

Skype vs. XAMPP

skype

Wer einen XAMPP installiert hat, der Apache aber partout nicht starten will, sollte mal probieren, die Ports 80 und 443 im Skype zu deaktivieren. Gefunden auf Protecus.de… Skype 1, gute Programmierung 0.

crusy.net

♪ Commit ins Abenteuerland ♫

Tag Archives for Apache

Play Dependencies für JBoss ActiveMQ mit Zookeeper

Schritt 1: Libraries hinzufügen

Play 1

Play 2

Schritt 2: Konfiguration

Schritt 3: Im Code

Apache Ant: Ja/nein-Dialog

Apache Ant: antcall für fileset

WSDL2Java: Axis2 in Eclipse Indigo

Skype vs. XAMPP