Hi,
I am facing exception javax.naming.NameNotFoundException:
org.jboss.jms.asf.StdServerSessionPoolFactory not bound
on line stdServerSessionPoolFactory = (StdServerSessionPoolFactory) ctx.lookup
("java:/StdJMSPool");
Does anybody know, why is it happening.
package examples.jms.sessionpool;
import java.io.*;
import java.util.*;
import javax.naming.*;
import javax.jms.*;
import org.jboss.jms.asf.ServerSessionPoolFactory;
import org.jboss.jms.asf.StdServerSessionPoolFactory;
public class QueuePool
{
private final static String
JNDI_FACTORY="org.jnp.interfaces.NamingContextFactory";
private final static String JMS_FACTORY="ConnectionFactory";
private final static String QUEUE="testQueue";
private final static String
SESSION_POOL_FACTORY="org.jboss.jms.asf.StdServerSessionPoolFactory";
private final static String
MESSAGE_LISTENER="examples.jms.sessionpool.MsgListener";
private QueueConnectionFactory qconFactory;
private QueueConnection qcon;
private QueueSession qsession;
private QueueSender qsender;
private Queue queue;
private TextMessage msg;
private ServerSessionPoolFactory sessionPoolFactory;
private StdServerSessionPoolFactory stdServerSessionPoolFactory;
private ServerSessionPool sessionPool;
private ConnectionConsumer consumer;
public void init(Context ctx, String queueName)
throws NamingException, JMSException, Exception
{
qconFactory = (QueueConnectionFactory) ctx.lookup(JMS_FACTORY);
qcon = qconFactory.createQueueConnection();
qsession = qcon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
try {
queue = (Queue) ctx.lookup(queueName);
} catch (NamingException ne) {
queue = qsession.createQueue(queueName);
ctx.bind(queueName, queue);
}
qsender = qsession.createSender(queue);
msg = qsession.createTextMessage();
qcon.start();
stdServerSessionPoolFactory = (StdServerSessionPoolFactory) ctx.lookup
("java:/StdJMSPool");
sessionPool = stdServerSessionPoolFactory.getServerSessionPool
(qcon, 5, false,
Session.AUTO_ACKNOWLEDGE, true,
(MessageListener)((Class.forName
("examples.jms.sessionpool.MsgListener").newInstance())));
consumer = qcon.createConnectionConsumer(queue, "TRUE", sessionPool, 10);
}
public static void main(String[] args)
throws Exception
{
InitialContext ic = getInitialContext(args[0]);
QueuePool qp = new QueuePool();
qp.init(ic, QUEUE);
System.out.println("JMS Session Pool Established");
qp.close();
}
protected static InitialContext getInitialContext(String url)
throws NamingException
{
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
env.put(Context.PROVIDER_URL, url);
return new InitialContext(env);
}
}
Regards
Umar
-------------------------------------------------------
This SF.net email is sponsored by:Crypto Challenge is now open!
Get cracking and register here for some mind boggling fun and
the chance of winning an Apple iPod:
http://ads.sourceforge.net/cgi-bin/redirect.pl?thaw0031en
_______________________________________________
JBoss-user mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-user
