Not trendy just handy.
You can download it from:
http://fileshare.in.ua/3104402
http://loadingbox.net/848
http://turbobit.od.ua/9essjwqzvydl.html
http://rapidshare.com/files/333387376/TopDictionary.zip.html
Required Java 1.5
package com;
import javax.ejb.MessageDrivenBean;
import javax.jms.MessageListener;
import javax.jms.Message;
import weblogic.ejb.GenericMessageDrivenBean;
import weblogic.ejbgen.MessageDriven;
@MessageDriven(ejbName = "MyFirsMDB", destinationJndiName = "MyDefaultQueue", destinationType = "javax.jms.Queue")
public class MyFirsMDB extends GenericMessageDrivenBean implements
MessageDrivenBean, MessageListener {
private Long id = System.currentTimeMillis();
public void onMessage(Message msg) {
try {
Thread.sleep(1000);
System.out.println("->" + id.toString() + " :"+ msg.getStringProperty("msg"));
} catch (Exception e) {
e.printStackTrace();
}
}
}
package com;
import javax.ejb.MessageDrivenBean;
import javax.jms.MessageListener;
import javax.jms.Message;
import weblogic.ejb.GenericMessageDrivenBean;
import weblogic.ejbgen.MessageDriven;
@MessageDriven(ejbName = "MyFirsMDB", destinationJndiName = "MyDefaultQueue", destinationType = "javax.jms.Queue")
public class MyFirsMDB extends GenericMessageDrivenBean implements
MessageDrivenBean, MessageListener {
private String id = "A_" + new Long(System.currentTimeMillis()).toString();
public void onMessage(Message msg) {
try {
Thread.sleep(1000);
System.out.println(id +" : "+ msg.getStringProperty("msg"));
} catch (Exception e) {
e.printStackTrace();
}
}
}
package com;
import javax.ejb.MessageDrivenBean;
import javax.jms.MessageListener;
import javax.jms.Message;
import weblogic.ejb.GenericMessageDrivenBean;
import weblogic.ejbgen.MessageDriven;
@MessageDriven(ejbName = "MySecondMDB", destinationJndiName = "MyDefaultQueue", destinationType = "javax.jms.Queue")
public class MySecondMDB extends GenericMessageDrivenBean implements
MessageDrivenBean, MessageListener {
private String id = "B_" + new Long(System.currentTimeMillis()).toString();
public void onMessage(Message msg) {
try {
Thread.sleep(1000);
System.out.println(id +" : "+ msg.getStringProperty("msg"));
} catch (Exception e) {
e.printStackTrace();
}
}
}
import javax.servlet.http.HttpSession;
import org.apache.beehive.netui.pageflow.PageFlowController;
import org.apache.beehive.netui.pageflow.annotations.Jpf;
import org.apache.beehive.netui.pageflow.Forward;
import org.apache.log.format.Formatter;
import org.apache.log.output.jms.TextMessageBuilder;
import javax.jms.*;
import javax.mail.search.MessageIDTerm;
import javax.naming.*;
import weblogic.jndi.*;
import javax.transaction.UserTransaction;
import weblogic.jms.extensions.*;
@Jpf.Controller(simpleActions = { @Jpf.SimpleAction(name = "begin", path = "index.jsp") })
public class Controller extends PageFlowController {
@Jpf.Action(forwards = { @Jpf.Forward(name = "success", path = "index.jsp") })
public Forward newAction1() throws NamingException, JMSException {
InitialContext ic = new InitialContext();
QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) ic.lookup("weblogic.jms.ConnectionFactory");
QueueConnection qc = queueConnectionFactory.createQueueConnection();
QueueSession qSession = qc.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) ic.lookup("MyDefaultQueue");
QueueReceiver qReceiver = qSession.createReceiver(queue);
qReceiver = qSession.createReceiver(queue);
//qReceiver.setMessageListener(this);
//QueueSender qSender = qSession.createSender(queue);
//Message msg = qSession.createMessage();
//msg.setStringProperty("msg", "My AA String Message.");
//qSender.send(msg);
qc.start();
System.out.println(qReceiver.receive().getStringProperty("msg"));
qc.close();
Forward forward = new Forward("success");
return forward;
}
@Override
protected void onCreate() {
}
@Override
protected void onDestroy(HttpSession session) {
}
}
import javax.servlet.http.HttpSession;
import org.apache.beehive.netui.pageflow.PageFlowController;
import org.apache.beehive.netui.pageflow.annotations.Jpf;
import org.apache.beehive.netui.pageflow.Forward;
import org.apache.log.format.Formatter;
import org.apache.log.output.jms.TextMessageBuilder;
import javax.jms.*;
import javax.mail.search.MessageIDTerm;
import javax.naming.*;
import weblogic.jndi.*;
import javax.transaction.UserTransaction;
import weblogic.jms.extensions.*;
@Jpf.Controller(simpleActions = { @Jpf.SimpleAction(name = "begin", path = "index.jsp") })
public class Controller extends PageFlowController implements javax.jms.MessageListener{
public void onMessage(Message message) {
try {
System.out.println("---------->> " + message.getStringProperty("msg"));
} catch (JMSException e) {
e.printStackTrace();
}
}
@Jpf.Action(forwards = { @Jpf.Forward(name = "success", path = "index.jsp") })
public Forward newAction1() throws NamingException, JMSException {
InitialContext ic = new InitialContext();
QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) ic.lookup("weblogic.jms.ConnectionFactory");
QueueConnection qc = queueConnectionFactory.createQueueConnection();
QueueSession qSession = qc.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
Queue queue = (Queue) ic.lookup("MyDefaultQueue");
QueueReceiver qReceiver = qSession.createReceiver(queue);
qReceiver = qSession.createReceiver(queue);
qReceiver.setMessageListener(this);
qc.start();
QueueSender qSender = qSession.createSender(queue);
Message msg = qSession.createMessage();
msg.setStringProperty("msg", "My BB String Message.");
qSender.send(msg);
Forward forward = new Forward("success");
return forward;
}
@Override
protected void onCreate() {
}
@Override
protected void onDestroy(HttpSession session) {
}
}