add new repoHEADmaster

5 files changed, 118 insertions, 0 deletions

diff --git a/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogBean.java b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogBean.java
new file mode 100644
index 0000000..89364d9
--- /dev/null
+++ b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogBean.java
@@ -0,0 +1,22 @@
+package examples.messaging.dd;

+

+import javax.jms.*;

+

+public class LogBean implements MessageListener {

+    

+    public LogBean() {

+    }

+    

+    public void onMessage(Message msg) {

+        if (msg instanceof TextMessage) {

+            TextMessage tm = (TextMessage) msg;

+            try {

+                String text = tm.getText();

+                System.err.println("Received new message : " + text);

+            } catch (JMSException e) {

+                e.printStackTrace();

+            }

+        }

+    }

+    

+}
\ No newline at end of file
diff --git a/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogClient.java b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogClient.java
new file mode 100644
index 0000000..14b6008
--- /dev/null
+++ b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/LogClient.java
@@ -0,0 +1,34 @@
+package examples.messaging.dd;

+

+import javax.jms.Session;

+import javax.jms.TextMessage;

+import javax.jms.Topic;

+import javax.jms.TopicConnection;

+import javax.jms.TopicConnectionFactory;

+import javax.jms.TopicPublisher;

+import javax.jms.TopicSession;

+import javax.naming.InitialContext;

+

+public class LogClient {

+

+    public static void main(String[] args) throws Exception {

+        InitialContext ctx = new InitialContext(System.getProperties());

+

+        Topic topic = (Topic) ctx.lookup("jms/Topic");        

+        TopicConnectionFactory factory = 

+            (TopicConnectionFactory) ctx

+                .lookup("jms/TopicConnectionFactory");

+        TopicConnection connection = factory.createTopicConnection();

+        TopicSession session = connection.createTopicSession(false,

+                Session.AUTO_ACKNOWLEDGE);

+        

+        TopicPublisher publisher = session.createPublisher(topic);

+

+        // create and publish a message

+        TextMessage msg = session.createTextMessage();

+        msg.setText("This is a test message.");

+        publisher.publish(msg);

+

+        System.out.println("Message published. Please check application server's console to see the response from MDB.");

+    }

+}
\ No newline at end of file
diff --git a/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/META-INF/ejb-jar.xml b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/META-INF/ejb-jar.xml
new file mode 100644
index 0000000..92cee32
--- /dev/null
+++ b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/META-INF/ejb-jar.xml
@@ -0,0 +1,19 @@
+<?xml version="1.0" encoding="UTF-8" ?> 
+<ejb-jar>
+    <enterprise-beans>
+        <message-driven>
+            <ejb-name>LogBeanDD</ejb-name>
+            <ejb-class>examples.messaging.dd.LogBean</ejb-class> 
+            <messaging-type>javax.jms.MessageListener</messaging-type>
+            <transaction-type>Bean</transaction-type>
+            <message-destination-type>javax.jms.Topic</message-destination-type>
+            <!-- further details -->
+            <activation-config>
+  			  <activation-config-property>
+				<activation-config-property-name>destinationType</activation-config-property-name>
+				<activation-config-property-value>javax.jms.Topic</activation-config-property-value>
+			  </activation-config-property>
+			</activation-config>
+        </message-driven>
+    </enterprise-beans>
+</ejb-jar>
\ No newline at end of file
diff --git a/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/META-INF/sun-ejb-jar.xml b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/META-INF/sun-ejb-jar.xml
new file mode 100644
index 0000000..85caf26
--- /dev/null
+++ b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/META-INF/sun-ejb-jar.xml
@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>

+<sun-ejb-jar>

+  <enterprise-beans>

+    <name>LogBeanDD</name>

+    <ejb>

+      <ejb-name>LogBeanDD</ejb-name>

+      <jndi-name>jms/Topic</jndi-name>

+      <mdb-connection-factory>

+        <jndi-name>jms/TopicConnectionFactory</jndi-name>

+      </mdb-connection-factory>

+    </ejb>

+  </enterprise-beans>

+</sun-ejb-jar>

diff --git a/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/build.xml b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/build.xml
new file mode 100644
index 0000000..b6b0013
--- /dev/null
+++ b/Master/Reference Architectures and Patterns/EJB 3.0 Code/Gerald Examples/src/examples/messaging/dd/build.xml
@@ -0,0 +1,30 @@
+<?xml version="1.0"?>
+<!DOCTYPE project [ <!ENTITY include SYSTEM "../../../../etc/common.xml"> ]>
+	
+<project name="ejb3-examples-messaging-dd" default="deploy" 
+	basedir="../../../..">
+	
+	<!--		basic  settings          -->
+	<property name="src.dir" value="${basedir}/src"/>
+	<property name="build.dir" value="${basedir}/build"/>
+	<property name="build.classes.dir" value="${build.dir}/classes"/>
+	<property name="appname" value="MessageDrivenLogDD"/>
+	<property name="client.class" value="examples.messaging.dd.LogClient"/>
+	<property name="app.pkg" value="examples/messaging/dd"/>
+	<property name="package" value="${app.pkg}"/>
+	<property name="pack.dir" value="${src.dir}/${app.pkg}"/>
+	<property name="jar.pkg" value="${app.pkg}"/>
+
+	  <!--	Include common.xml	       -->
+	  &include;
+
+	
+	  <target name="jar" depends="compile_common, create_ejbjar_common"/>
+
+	  <target name="deploy" depends="jar">
+		  <copy file="${assemble.ejbjar}/${ejbjar}" 
+	      	todir="${deploy.dir}"/>
+	  </target>
+		
+</project>
+