Hi,
Who can help me solve this problem.
1. First, I have deploy MessageDrivenWroxBean
2. run client file. but it is exception still.
a. run: java -Djms.properties=%j2ee_home%\config\jms_client.properties -cp
.;%j2ee_home%\lib\j2ee.jar WroxQueueSender
b: exceptioin:
javax.naming.NoInitialContextException: Cannot instantiate class:
com.evermind.server.rmi.
RMIInitialContextFactory [Root exception is
java.lang.ClassNotFoundException: com.evermind
.server.rmi.RMIInitialContextFactory]
regards
emile
===================================================================
import javax.ejb.*;
import javax.jms.*;
import javax.naming.*;
public class MessageDrivenWroxBean
implements MessageDrivenBean, MessageListener {
private MessageDrivenContext ctx;
public void setMessageDrivenContext(MessageDrivenContext ctx) {
this.ctx = ctx;
}
public void ejbCreate () throws CreateException {
System.out.println("Message-Driven bean created");
}
public void onMessage(Message msg) {
System.out.println("Message received: ");
try {
if(msg instanceof TextMessage) {
System.out.println("TextMessage: "+((TextMessage)msg).getText());
} else if(msg instanceof ObjectMessage) {
System.out.println("ObjectMessage: " +
((ObjectMessage)msg).getObject());
} else if (msg instanceof StreamMessage) {
System.out.println("StreamMessage: " +
((StreamMessage)msg).readString());
} else if (msg instanceof BytesMessage) {
System.out.println("BytesMessage: "+((BytesMessage)msg).readUTF());
} else if (msg instanceof MapMessage) {
System.out.println("MapMessage: " +
((MapMessage)msg).getString("msg"));
}
} catch(Exception any) {
System.out.println("Exception: "+any.getMessage());
}
}
public void ejbRemove() {}
}
======================================================================
import javax.jms.*;
import javax.naming.*;
public class WroxQueueSender {
public static void main(String[] args) {
Queue queue = null;
QueueConnectionFactory queueConnectionFactory = null;
QueueConnection queueConnection = null;
try {
Context jndiContext = new InitialContext();
queueConnectionFactory
= (QueueConnectionFactory)jndiContext.lookup("jms/QueueConnectionFactory");
queue = (Queue)jndiContext.lookup("jms/WroxOrders");
} catch (NamingException nEx) {
System.out.println(nEx.toString()+"\nDoes the queue exist?");
System.exit(1);
}
try {
queueConnection = queueConnectionFactory.createQueueConnection();
queueConnection.start();
QueueSession queueSession = queueConnection.createQueueSession(
false,
Session.AUTO_ACKNOWLEDGE);
QueueSender queueSender = queueSession.createSender(queue);
TextMessage message = queueSession.createTextMessage();
message.setText("Please send me the new J2EE book on my account");
message.setStringProperty("Client","Rachel Davies");
queueSender.send(message);
System.out.println("Your book has been ordered");
} catch (JMSException jmsEx) {
System.out.print("Something went wrong with your book order, ");
System.out.println("please try again�� ");
System.out.println("Exception: " + jmsEx.toString());
} finally {
if (queueConnection != null) {
try {
queueConnection.close();
} catch (Exception any) {}
}
}
}
}
==========================================================================To
unsubscribe, send email to [EMAIL PROTECTED] and include in the body
of the message "signoff EJB-INTEREST". For general help, send email to
[EMAIL PROTECTED] and include in the body of the message "help".
