[dna-commits] DNA SVN: r249 - in branches/maeste: dna-repository and 11 other directories.
dna-commits at lists.jboss.org
dna-commits at lists.jboss.org
Sun Jun 8 16:47:13 EDT 2008
Author: maeste
Date: 2008-06-08 16:47:13 -0400 (Sun, 08 Jun 2008)
New Revision: 249
Added:
branches/maeste/sequencers/dna-sequencer-esbMessage/
branches/maeste/sequencers/dna-sequencer-esbMessage/.classpath
branches/maeste/sequencers/dna-sequencer-esbMessage/.project
branches/maeste/sequencers/dna-sequencer-esbMessage/pom.xml
branches/maeste/sequencers/dna-sequencer-esbMessage/src/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageMetaData.java
branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageSequencer.java
branches/maeste/sequencers/dna-sequencer-esbMessage/src/test/
branches/maeste/sequencers/dna-sequencer-esbMessage/src/test/java/
Modified:
branches/maeste/dna-repository/pom.xml
branches/maeste/pom.xml
Log:
[DNA-78 [DNA-109], [DNA-108 partial]] first implementation of ESBMessage Sequencer and metadata
Modified: branches/maeste/dna-repository/pom.xml
===================================================================
--- branches/maeste/dna-repository/pom.xml 2008-06-07 20:29:57 UTC (rev 248)
+++ branches/maeste/dna-repository/pom.xml 2008-06-08 20:47:13 UTC (rev 249)
@@ -1,4 +1,5 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+<?xml version="1.0" encoding="UTF-8"?>
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.jboss.dna</groupId>
@@ -80,6 +81,7 @@
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-all</artifactId>
+ <version>1.3</version>
<scope>test</scope>
</dependency>
<!--
Modified: branches/maeste/pom.xml
===================================================================
--- branches/maeste/pom.xml 2008-06-07 20:29:57 UTC (rev 248)
+++ branches/maeste/pom.xml 2008-06-08 20:47:13 UTC (rev 249)
@@ -61,6 +61,7 @@
<module>dna-maven-classloader</module>
<module>sequencers/dna-sequencer-images</module>
<module>sequencers/dna-sequencer-mp3</module>
+ <module>sequencers/dna-sequencer-esbMessage</module>
<module>connectors/dna-connector-jbosscache</module>
<module>dna-integration-tests</module>
</modules>
Added: branches/maeste/sequencers/dna-sequencer-esbMessage/.classpath
===================================================================
--- branches/maeste/sequencers/dna-sequencer-esbMessage/.classpath (rev 0)
+++ branches/maeste/sequencers/dna-sequencer-esbMessage/.classpath 2008-06-08 20:47:13 UTC (rev 249)
@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+ <classpathentry kind="src" path="src/main/java"/>
+ <classpathentry kind="src" path="src/main/resources"/>
+ <classpathentry kind="src" output="target/test-classes" path="src/test/java"/>
+ <classpathentry kind="src" output="target/test-classes" path="src/test/resources"/>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+ <classpathentry kind="con" path="org.maven.ide.eclipse.MAVEN2_CLASSPATH_CONTAINER"/>
+ <classpathentry kind="output" path="target/classes"/>
+</classpath>
Added: branches/maeste/sequencers/dna-sequencer-esbMessage/.project
===================================================================
--- branches/maeste/sequencers/dna-sequencer-esbMessage/.project (rev 0)
+++ branches/maeste/sequencers/dna-sequencer-esbMessage/.project 2008-06-08 20:47:13 UTC (rev 249)
@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+ <name>dna-sequencer-mp3</name>
+ <comment></comment>
+ <projects>
+ </projects>
+ <buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
+ <buildCommand>
+ <name>org.maven.ide.eclipse.maven2Builder</name>
+ <arguments>
+ </arguments>
+ </buildCommand>
+ </buildSpec>
+ <natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ <nature>org.maven.ide.eclipse.maven2Nature</nature>
+ </natures>
+</projectDescription>
Added: branches/maeste/sequencers/dna-sequencer-esbMessage/pom.xml
===================================================================
--- branches/maeste/sequencers/dna-sequencer-esbMessage/pom.xml (rev 0)
+++ branches/maeste/sequencers/dna-sequencer-esbMessage/pom.xml 2008-06-08 20:47:13 UTC (rev 249)
@@ -0,0 +1,35 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <artifactId>dna</artifactId>
+ <groupId>org.jboss.dna</groupId>
+ <version>0.2-SNAPSHOT</version>
+ <relativePath>../..</relativePath>
+ </parent>
+ <!-- The groupId and version values are inherited from parent -->
+ <artifactId>dna-sequencer-esbMessage</artifactId>
+ <packaging>jar</packaging>
+ <name>JBoss DNA ESB Message Sequencer</name>
+ <description>JBoss DNA Sequencer that processes ESB Message</description>
+ <url>http://labs.jboss.org/dna</url>
+ <dependencies>
+ <dependency>
+ <groupId>org.jboss.dna</groupId>
+ <artifactId>dna-common</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.jboss.dna</groupId>
+ <artifactId>dna-spi</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit-dep</artifactId>
+ <version>4.4</version>
+ </dependency>
+ <dependency>
+ <groupId>jbossesb-rosetta.jar</groupId>
+ <artifactId>jbossesb-rosetta-dep</artifactId>
+ <version>4.3</version>
+ </dependency>
+ </dependencies>
+</project>
\ No newline at end of file
Added: branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageMetaData.java
===================================================================
--- branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageMetaData.java (rev 0)
+++ branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageMetaData.java 2008-06-08 20:47:13 UTC (rev 249)
@@ -0,0 +1,169 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.dna.sequencer.esbMessage;
+
+import java.io.InputStream;
+import java.io.Serializable;
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
+import org.jboss.dna.common.util.StringUtil;
+import org.jboss.internal.soa.esb.util.Encoding;
+import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.util.Util;
+
+/**
+ * Utility for extracting metadata from MP3 files.
+ *
+ * @author Stefano Maestri
+ */
+public class ESBMessageMetaData {
+
+ private URI messageType;
+ private EPR to = null;
+ private EPR from = null;
+ private EPR faultTo = null;
+ private EPR replyTo = null;
+ private URI relatesTo = null;
+ private URI action = null;
+ private URI messageID = null;
+ private Map<String, Object> bodyMap = null;
+ private Map<String, Object> propertiesMap = null;
+ private Map<String, Object> attachmentsMap = null;
+ private URI faultCode = null;
+ private String faultReason;
+ private Throwable faultCause;
+
+ private ESBMessageMetaData() {
+
+ }
+
+ public static ESBMessageMetaData instance( InputStream stream ) {
+
+ ESBMessageMetaData me = null;
+ Message message = null;
+ try {
+ me = new ESBMessageMetaData();
+ message = Util.deserialize((Serializable)Encoding.decodeToObject(StringUtil.read(stream)));
+ } catch (Exception e) {
+ e.printStackTrace();
+ return null;
+ }
+
+ me.messageType = message.getType();
+ // Context not yet implemented in JBossESB
+ // message.getContext();
+
+ me.to = message.getHeader().getCall().getTo();
+ me.from = message.getHeader().getCall().getFrom();
+ me.faultTo = message.getHeader().getCall().getFaultTo();
+ me.replyTo = message.getHeader().getCall().getReplyTo();
+ me.relatesTo = message.getHeader().getCall().getRelatesTo();
+ me.action = message.getHeader().getCall().getAction();
+ me.messageID = message.getHeader().getCall().getMessageID();
+
+ if (message.getBody().getNames().length != 0) {
+ me.bodyMap = new HashMap<String, Object>();
+ }
+ for (String name : message.getBody().getNames()) {
+ me.bodyMap.put(name, message.getBody().get(name));
+ }
+
+ if (message.getProperties().getNames().length != 0) {
+ me.propertiesMap = new HashMap<String, Object>();
+ }
+ for (String name : message.getProperties().getNames()) {
+ me.propertiesMap.put(name, message.getProperties().getProperty(name));
+ }
+
+ if (message.getAttachment().getNames().length != 0) {
+ me.attachmentsMap = new HashMap<String, Object>();
+ }
+ for (String name : message.getAttachment().getNames()) {
+ me.attachmentsMap.put(name, message.getAttachment().get(name));
+ }
+
+ me.faultCause = message.getFault().getCause();
+ me.faultCode = message.getFault().getCode();
+ me.faultReason = message.getFault().getReason();
+
+ return me;
+
+ }
+
+ public URI getMessageType() {
+ return messageType;
+ }
+
+ public EPR getTo() {
+ return to;
+ }
+
+ public EPR getFrom() {
+ return from;
+ }
+
+ public EPR getFaultTo() {
+ return faultTo;
+ }
+
+ public EPR getReplyTo() {
+ return replyTo;
+ }
+
+ public URI getRelatesTo() {
+ return relatesTo;
+ }
+
+ public URI getAction() {
+ return action;
+ }
+
+ public URI getMessageID() {
+ return messageID;
+ }
+
+ public Map<String, Object> getBodyMap() {
+ return bodyMap;
+ }
+
+ public Map<String, Object> getPropertiesMap() {
+ return propertiesMap;
+ }
+
+ public Map<String, Object> getAttachmentsMap() {
+ return attachmentsMap;
+ }
+
+ public URI getFaultCode() {
+ return faultCode;
+ }
+
+ public String getFaultReason() {
+ return faultReason;
+ }
+
+ public Throwable getFaultCause() {
+ return faultCause;
+ }
+}
Added: branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageSequencer.java
===================================================================
--- branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageSequencer.java (rev 0)
+++ branches/maeste/sequencers/dna-sequencer-esbMessage/src/main/java/org/jboss/dna/sequencer/esbMessage/ESBMessageSequencer.java 2008-06-08 20:47:13 UTC (rev 249)
@@ -0,0 +1,70 @@
+/*
+ * JBoss, Home of Professional Open Source.
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * as indicated by the @author tags. See the copyright.txt file in the
+ * distribution for a full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.dna.sequencer.esbMessage;
+
+import java.io.InputStream;
+import org.jboss.dna.common.monitor.ProgressMonitor;
+import org.jboss.dna.spi.sequencers.SequencerOutput;
+import org.jboss.dna.spi.sequencers.StreamSequencer;
+
+/**
+ * A sequencer that processes the binary content of an MP3 audio file, extracts the metadata for the file, and then writes that
+ * audio metadata to the repository.
+ * <p>
+ * This sequencer produces data that corresponds to the following structure:
+ * <ul>
+ * <li><strong>mp3:metadata</strong> node of type <code>mp3:metadata</code>
+ * <ul>
+ * <li><strong>mp3:title</strong> - optional string property for the name of the audio file or recording</li>
+ * <li><strong>mp3:author</strong> - optional string property for the author of the recording</li>
+ * <li><strong>mp3:album</strong> - optional string property for the name of the album</li>
+ * <li><strong>mp3:year</strong> - optional integer property for the year the recording as created</li>
+ * <li><strong>mp3:comment</strong> - optional string property specifying a comment</li>
+ * </ul>
+ * </li>
+ * </ul>
+ * </p>
+ *
+ * @author Stefano Maestri
+ */
+public class ESBMessageSequencer implements StreamSequencer {
+
+ public static final String METADATA_NODE = "esbMessage:metadata";
+ public static final String ESB_MESSAGE_PRIMARY_TYPE = "jcr:primaryType";
+
+ public void sequence( InputStream stream,
+ SequencerOutput output,
+ ProgressMonitor progressMonitor ) {
+ ESBMessageMetaData metadata = ESBMessageMetaData.instance(stream);
+
+ if (metadata != null) {
+ // Place the image metadata into the output map ...
+ output.setProperty(METADATA_NODE, ESB_MESSAGE_PRIMARY_TYPE, "esbMessage:metadata");
+ // output.setProperty(METADATA_NODE, MP3_TITLE, metadata.getTitle());
+ // output.setProperty(METADATA_NODE, MP3_AUTHOR, metadata.getAuthor());
+ // output.setProperty(METADATA_NODE, MP3_ALBUM, metadata.getAlbum());
+ // output.setProperty(METADATA_NODE, MP3_YEAR, metadata.getYear());
+ // output.setProperty(METADATA_NODE, MP3_COMMENT, metadata.getComment());
+ }
+ }
+
+}
More information about the dna-commits
mailing list