Subiendo el proyecto

.classpath

+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="ejbModule"/>
+	<classpathentry kind="con" path="org.eclipse.jst.j2ee.internal.module.container"/>
+	<classpathentry kind="lib" path="lib/commons-dbcp2-2.0.jar"/>
+	<classpathentry kind="lib" path="lib/commons-pool2-2.3.jar"/>
+	<classpathentry kind="lib" path="lib/postgresql-9.1-901-1.jdbc4.jar"/>
+	<classpathentry kind="con" path="org.eclipse.jst.server.core.container/org.jboss.ide.eclipse.as.core.server.runtime.runtimeTarget/JBoss EAP 6.1+ Runtime">
+		<attributes>
+			<attribute name="owner.project.facets" value="#system#;jst.ejb"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/java-7-openjdk-amd64">
+		<attributes>
+			<attribute name="owner.project.facets" value="java"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="build/classes"/>
+</classpath>

.gitignore

+/build/

.project

+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>CiudadanoJMS</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.wst.common.project.facet.core.builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.wst.validation.validationbuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.zeroturnaround.eclipse.rebelXmlBuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jem.workbench.JavaEMFNature</nature>
+		<nature>org.eclipse.wst.common.modulecore.ModuleCoreNature</nature>
+		<nature>org.eclipse.wst.common.project.facet.core.nature</nature>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.zeroturnaround.eclipse.jrebelNature</nature>
+	</natures>
+</projectDescription>

.settings/org.eclipse.jdt.core.prefs

+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+org.eclipse.jdt.core.compiler.compliance=1.6
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.source=1.6

.settings/org.eclipse.wst.common.component

+<?xml version="1.0" encoding="UTF-8"?><project-modules id="moduleCoreId" project-version="1.5.0">
+    <wb-module deploy-name="CiudadanoJMS">
+        <wb-resource deploy-path="/" source-path="/ejbModule" tag="defaultRootSource"/>
+        <dependent-module archiveName="jboss-logging.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-logging.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="hornetq-commons.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/hornetq-commons.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="jboss-jms-api_1.1_spec.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-jms-api_1.1_spec.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="postgresql-9.1-901-1.jdbc4.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/postgresql-9.1-901-1.jdbc4.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="jboss-remoting.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-remoting.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="json-io-2.2.29.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/json-io-2.2.29.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="commons-pool2-2.3.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/commons-pool2-2.3.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="httpcore-4.2.4.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/httpcore-4.2.4.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="slf4j-log4j12-1.5.8.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/slf4j-log4j12-1.5.8.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="commons-logging-1.2.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/commons-logging-1.2.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="slf4j-api-1.5.8.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/slf4j-api-1.5.8.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="jboss-ejb-client.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-ejb-client.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="httpclient-4.2.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/httpclient-4.2.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="junit-4.11.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/junit-4.11.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="netty.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/netty.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="hornetq-jms-client.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/hornetq-jms-client.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="jboss-marshalling.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-marshalling.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="jboss-remote-naming.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-remote-naming.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="javax.mail.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/javax.mail.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="jboss-marshalling-river.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/jboss-marshalling-river.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="hornetq-core-client.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/hornetq-core-client.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="commons-io-2.4.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/commons-io-2.4.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="commons-dbcp2-2.0.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/commons-dbcp2-2.0.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="commons-fileupload-1.3.1.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/commons-fileupload-1.3.1.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <dependent-module archiveName="commons-lang3-3.4.jar" deploy-path="/" handle="module:/classpath/lib/CiudadanoJMS/lib/commons-lang3-3.4.jar">
+            <dependency-type>uses</dependency-type>
+        </dependent-module>
+        <property name="java-output-path" value="/CiudadanoJMS/build/classes"/>
+    </wb-module>
+</project-modules>

.settings/org.eclipse.wst.common.project.facet.core.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<faceted-project>
+  <fixed facet="jst.ejb"/>
+  <fixed facet="java"/>
+  <installed facet="java" version="1.6"/>
+  <installed facet="jst.ejb" version="3.1"/>
+</faceted-project>

configurations/ciudadanoEJB.properties

+# database configuration
+
+DATABASE_URL=jdbc:postgresql://xx.xx.xx.xx:5432/bonita
+DATABASE_USER=xxxx
+DATABASE_PASSWORD=xxxx
+MAX_CONNECTION=20
+INITIAL_CONNECTION=1
+MAX_IDLE=10
+MIN_IDLE = 0
+REMOVE_ABANDONED = true
+REMOVE_ABANDONED_TIME = 10
+
+
+

ejbModule/META-INF/MANIFEST.MF

+Manifest-Version: 1.0
+

ejbModule/ve/gob/cnti/ciudadano/ejb/CiudadanoEJB.java

+package ve.gob.cnti.ciudadano.ejb;
+
+import java.util.Map;
+import java.util.logging.Logger;
+
+import javax.ejb.ActivationConfigProperty;
+import javax.ejb.MessageDriven;
+import javax.jms.MapMessage;
+import javax.jms.Message;
+import javax.jms.MessageListener;
+
+import ve.gob.cnti.ciudadano.jdbc.ConnectionJDBC;
+import ve.gob.cnti.ciudadano.jdbc.IConnectionJDBC;
+import ve.gob.cnti.ciudadano.utils.IMapMessageConverter;
+import ve.gob.cnti.ciudadano.utils.MapMessageConverter;
+
+
+/**
+ * Message-Driven Bean implementation class for: CiudadanoEJB
+ */
+@MessageDriven(
+		activationConfig = { @ActivationConfigProperty(
+				propertyName = "destination", propertyValue = "jms/queue/ciudadano"), @ActivationConfigProperty(
+				propertyName = "destinationType", propertyValue = "javax.jms.Queue")
+		}, 
+		mappedName = "jms/queue/ciudadano")
+public class CiudadanoEJB implements MessageListener {
+	private static final Logger log = Logger.getLogger(CiudadanoEJB.class.getName());
+    /**
+     * Default constructor. 
+     */
+    public CiudadanoEJB() {
+        // TODO Auto-generated constructor stub
+    }
+	
+	/**
+     * @see MessageListener#onMessage(Message)
+     */
+    public void onMessage(Message message) {
+        // TODO Auto-generated method stub
+    	log.info("mensaje recibido en el portal ciudadano");
+    	log.info("usando el ejb para ingresar las actividades en la bd del portal ciudadano");    	
+		MapMessage incoming = (MapMessage)message;
+		IConnectionJDBC connection=new ConnectionJDBC();		
+		IMapMessageConverter converterMessage=new MapMessageConverter();
+		Map<String,String> map=converterMessage.converMapMessageToMap(incoming);
+		connection.insertRecord(map); 
+		connection.closeConnection();
+    	
+        
+    }
+
+}

ejbModule/ve/gob/cnti/ciudadano/jdbc/ConnectionJDBC.java

+package ve.gob.cnti.ciudadano.jdbc;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.Map;
+import java.util.logging.Logger;
+
+import org.apache.commons.dbcp2.BasicDataSource;
+
+import ve.gob.cnti.ciudadano.utils.ConverDate;
+import ve.gob.cnti.ciudadano.utils.IConvertDate;
+import ve.gob.cnti.ciudadano.utils.PropertiesReader;
+
+
+/**
+ * Esta clase se encarga de extraer informacion de la tabla arch_process_instance_lastupdate, process_instance y data_instance
+ * para implementar esta clase utilice la clase CaseImpl.java
+ * @author Yamil Orozco
+ */
+
+public class ConnectionJDBC implements IConnectionJDBC {
+	
+	Connection cnn=null;
+	Statement ps = null;
+    ResultSet rs=null;
+    private static BasicDataSource basicDataSource=new BasicDataSource();   
+    PropertiesReader properties = new PropertiesReader();		
+    public String DATABASE_URL = properties.getProperty("DATABASE_URL");
+    public String DATABASE_USER = properties.getProperty("DATABASE_USER");
+    public String DATABASE_PASSWORD = properties.getProperty("DATABASE_PASSWORD");
+    public Integer MAX_CONNECTION = Integer.valueOf(properties.getProperty("MAX_CONNECTION"));
+    public Integer INITIAL_CONNECTION = Integer.valueOf(properties.getProperty("INITIAL_CONNECTION"));
+    public Integer MAX_IDLE = Integer.valueOf(properties.getProperty("MAX_IDLE"));
+    public Integer MIN_IDLE = Integer.valueOf(properties.getProperty("MIN_IDLE"));
+    public Boolean REMOVE_ABANDONED = Boolean.valueOf(properties.getProperty("REMOVE_ABANDONED"));
+    public Integer REMOVE_ABANDONED_TIME = Integer.valueOf(properties.getProperty("REMOVE_ABANDONED_TIME"));
+    private static final Logger log = Logger.getLogger(ConnectionJDBC.class.getName());
+    Boolean next=null;
+    
+    public ConnectionJDBC(){
+    	
+    	basicDataSource=new BasicDataSource();
+		basicDataSource.setDriverClassName("org.postgresql.Driver");
+		basicDataSource.setUrl(DATABASE_URL);
+		basicDataSource.setUsername(DATABASE_USER);
+		basicDataSource.setPassword(DATABASE_PASSWORD);
+		basicDataSource.setMaxTotal(MAX_CONNECTION);
+		basicDataSource.setInitialSize(INITIAL_CONNECTION);
+		basicDataSource.setValidationQuery("select 1");
+		basicDataSource.setRemoveAbandonedOnBorrow(REMOVE_ABANDONED);
+		basicDataSource.setRemoveAbandonedTimeout(REMOVE_ABANDONED_TIME);
+		basicDataSource.setMaxIdle(MAX_IDLE);
+		basicDataSource.setMinIdle(MIN_IDLE);
+    }
+  
+    
+	public void openConnection(){	
+	
+		/*basicDataSource.setDriverClassName("org.postgresql.Driver");
+		basicDataSource.setUrl(DATABASE_URL);
+		basicDataSource.setUsername(DATABASE_USER);
+		basicDataSource.setPassword(DATABASE_PASSWORD);
+		basicDataSource.setMaxTotal(MAX_CONNECTION);
+		basicDataSource.setInitialSize(INITIAL_CONNECTION);
+		basicDataSource.setValidationQuery("select 1");
+		
+		
+		try {
+			cnn =basicDataSource.getConnection();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}*/
+	}
+	
+	public void insertRecord(Map<String,String> variables){
+		IConvertDate converter=new ConverDate();
+		String query=null;	
+		log.info("ingresando el registro de la actividad");
+		try {
+			String status="En Proceso";
+			if("notificacion".equals(variables.get("taskName"))){
+				status="Finalizado";
+			}			
+			cnn =basicDataSource.getConnection();
+			ps=cnn.createStatement();
+			query="insert into arch_activities_instance_hist values ('"+
+			Long.parseLong(variables.get("id"))+"','"
+		    +variables.get("taskId")+"','"
+			+variables.get("processName")+"','"
+			+variables.get("processDescription")+"','"
+			+variables.get("taskName")+"','"
+			+variables.get("taskDescription")+"','"
+			+variables.get("cedula")+"','"			
+			+converter.getFormattedLongDateDate("yyyy-MM-dd",variables.get("lastupdate"))+"','"
+			+converter.getFormattedLongDateDate("yyyy-MM-dd",variables.get("f_solicitud"))+"','"
+			+variables.get("revision")+"','"
+			+status
+			+"') ";
+			ps.executeUpdate(query);			
+			
+			
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			this.closeConnection();
+		}	  
+		
+		try {
+			
+
+			if(ps!=null) ps.close();
+			if(cnn!=null) cnn.close();
+		} catch (SQLException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+		
+		
+		this.closeConnection();
+		
+		
+	}
+
+	public void closeConnection(){
+		
+		try {
+			/*ps.close();
+			cnn.close();	*/
+			basicDataSource.close();
+		} catch (SQLException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+	}
+
+
+	
+    
+	
+
+}

ejbModule/ve/gob/cnti/ciudadano/jdbc/IConnectionJDBC.java

+package ve.gob.cnti.ciudadano.jdbc;
+import java.util.Map;
+public interface IConnectionJDBC {
+	
+	
+	public void openConnection();	
+	public void insertRecord(Map<String,String> variables);
+	public void closeConnection();	
+}

ejbModule/ve/gob/cnti/ciudadano/resources/jdbc.properties

+DATABASE_URL=jdbc:postgresql://localhost:5432/bonita_calidad
+DATABASE_USER=postgres
+DATABASE_PASSWORD=123456
+MAX_CONNECTION=30
+INITIAL_CONNECTION=6
\ No newline at end of file

ejbModule/ve/gob/cnti/ciudadano/utils/ConverDate.java

+package ve.gob.cnti.ciudadano.utils;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Locale;
+import java.util.logging.Logger;
+
+
+public class ConverDate implements IConvertDate{
+	
+	private static final Logger log = Logger.getLogger(ConverDate.class.getName());
+	
+
+	
+	
+	public String getFormattedTimeStampDate(String pattern, String date) {
+		String fecha = null;
+		log.info("convirtiendo fecha");
+		date=date.replace("<?xml version=\"1.0\" ?><date>", "").replace("</date>", "").trim();
+		try {
+			DateFormat df = new SimpleDateFormat("yyyy-mm-dd HH:MM:ss",
+					Locale.ENGLISH);
+			Date dateObj = df.parse(date);
+			fecha = new SimpleDateFormat(pattern).format(dateObj);
+		} catch (ParseException e1) {
+			e1.printStackTrace();
+		}
+		return fecha;
+	}
+	
+	public String getFormattedLongDateDate(String pattern, String date) {
+		String fecha = null;
+		log.info("convirtiendo fecha");
+		date=date.replace("<?xml version=\"1.0\" ?><date>", "").replace("</date>", "").trim();
+		try {
+			DateFormat df = new SimpleDateFormat("EEE MMM dd kk:mm:ss z yyyy",
+					Locale.ENGLISH);
+			Date dateObj = df.parse(date);
+			fecha = new SimpleDateFormat(pattern).format(dateObj);
+		} catch (ParseException e1) {
+			e1.printStackTrace();
+		}
+		return fecha;
+	}
+	
+	
+
+	
+
+}

ejbModule/ve/gob/cnti/ciudadano/utils/IConvertDate.java

+package ve.gob.cnti.ciudadano.utils;
+
+
+public interface IConvertDate {
+
+	public String getFormattedTimeStampDate(String pattern, String date);
+	public String getFormattedLongDateDate(String pattern, String date);
+}

ejbModule/ve/gob/cnti/ciudadano/utils/IMapMessageConverter.java

+package ve.gob.cnti.ciudadano.utils;
+
+import java.util.Map;
+
+import javax.jms.MapMessage;
+
+public interface IMapMessageConverter {
+	public Map<String,String> converMapMessageToMap(MapMessage mapMessage);
+}

ejbModule/ve/gob/cnti/ciudadano/utils/MapMessageConverter.java

+package ve.gob.cnti.ciudadano.utils;
+
+import java.util.Enumeration;
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.jms.JMSException;
+import javax.jms.MapMessage;
+
+public class MapMessageConverter  implements IMapMessageConverter{
+	
+	
+	@SuppressWarnings("rawtypes")
+	public Map<String,String> converMapMessageToMap(MapMessage mapMessage){		
+		Enumeration mapNames;
+		Map<String,String> values=new HashMap<String,String>();
+		try {
+			mapNames = mapMessage.getMapNames();
+			String       eachName;
+			String       eachValue;
+			
+			while ( mapNames.hasMoreElements() )
+			{   eachName  = (String) mapNames.nextElement();
+		    	eachValue = (String) mapMessage.getObject(eachName);
+		    	values.put(eachName,eachValue);
+			}
+		} catch (JMSException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return values;
+	}
+	
+	
+
+}

ejbModule/ve/gob/cnti/ciudadano/utils/PropertiesReader.java

+package ve.gob.cnti.ciudadano.utils;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.Properties;
+import java.util.logging.Logger;
+public class PropertiesReader {
+	
+
+	
+	Properties props = new Properties(); 
+	private static final Logger log = Logger.getLogger(PropertiesReader.class.getName());
+	public PropertiesReader(){
+		log.info("Ubicacion del Archivo de configuracion="+System.getProperty("jboss.server.config.dir")+"/"+"receiverEJB.properties");	
+		FileInputStream inputStream = null;
+		String path=System.getProperty("jboss.server.config.dir")+"/"+"ciudadanoEJB.properties";
+		try {	 
+			inputStream = new FileInputStream(path);
+			props.load(inputStream);		
+			
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		
+	}
+	
+
+	public String getProperty(String key){		
+		//System.out.println("clave="+key+"resultado"+props.getProperty(key));
+		return props.getProperty(key);
+		
+	} 
+	
+	
+		
+
+}

schema/schema.sql

+CREATE TABLE arch_activities_instance_hist
+(
+  rootprocessinstanceid bigint NOT NULL,
+  taskid bigint NOT NULL,
+  processname character varying(75) NOT NULL,
+  processdescription character varying(255) NOT NULL,
+  taskname character varying(75),
+  taskdescription character varying(255) NOT NULL,
+  cedula character varying(20) NOT NULL,
+  lastdate date NOT NULL,
+  fechasolicitud date NOT NULL,
+  revision character varying(50),
+  status character varying(75) NOT NULL,
+  CONSTRAINT arch_activities_instance_hist_pkey PRIMARY KEY (rootprocessinstanceid, taskid)
+);
\ No newline at end of file