Connecting to remote ConnectionFactory and Queue
Hi,
I got a problem with lookup of a remote ConnectionFactory.
On my JBoss 7.2.0 I have this code deployed as an ejb.
package server;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
@MessageDriven
(
activationConfig =
{
@ActivationConfigProperty(propertyName="destination", propertyValue="queue/FibonacciQueue"),
@ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
@ActivationConfigProperty(propertyName="subscriptionDurability", propertyValue="NonDurable")
}
)
public class FibonacciBean implements MessageListener
{
@Override
public void onMessage(Message msg)
{
System.out.println(msg);
}
}
The server is also giving me greenlight that everything is deployed and my queues are existent.
17:52:52,916 INFO [org.hornetq.core.server] (MSC service thread 1-5) HQ221009: Server is now live
17:52:52,916 INFO [org.hornetq.core.server] (MSC service thread 1-5) HQ221003: HornetQ Server version 2.3.0.CR1 (buzzzzz!, 122) [81c1c181-a930-11e3-8454-fba40b6c1c76]
17:52:52,932 INFO [org.hornetq.core.server] (ServerService Thread Pool -- 58) HQ221005: trying to deploy queue jms.queue.Fibonacci
17:52:53,025 INFO [org.jboss.as.jacorb] (MSC service thread 1-6) JBAS016328: CORBA Naming Service started
17:52:53,041 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 58) JBAS011601: Bound messaging object to jndi name java:/queue/FibonacciQueue
17:52:53,041 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 58) JBAS011601: Bound messaging object to jndi name java:jboss/exported/queue/FibonacciQueue
17:52:53,057 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 60) JBAS011601: Bound messaging object to jndi name java:/ConnectionFactory
17:52:53,057 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-1) JBAS010406: Registered connection factory java:/JmsXA
17:52:53,057 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 59) JBAS011601: Bound messaging object to jndi name java:jboss/exported/jms/RemoteConnectionFactory
17:52:53,103 INFO [org.hornetq.ra] (MSC service thread 1-1) HornetQ resource adaptor started
17:52:53,103 INFO [org.jboss.as.connector.services.resourceadapters.ResourceAdapterActivatorService$ResourceAdapterActivator] (MSC service thread 1-1) IJ020002: Deployed: file://RaActivatorhornetq-ra
17:52:53,103 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-1) JBAS010401: Bound JCA ConnectionFactory [java:/JmsXA]
17:52:53,213 INFO [org.jboss.as.ejb3] (MSC service thread 1-7) JBAS014142: Started message driven bean 'FibonacciBean' with 'hornetq-ra' resource adapter
17:52:53,369 INFO [org.jboss.as.server] (ServerService Thread Pool -- 32) JBAS018559: Deployed "Rechner.jar" (runtime-name : "Rechner.jar")
17:52:53,384 INFO [org.jboss.as] (Controller Boot Thread) JBAS015961: Http management interface listening on http://127.0.0.1:9990/management
17:52:53,384 INFO [org.jboss.as] (Controller Boot Thread) JBAS015951: Admin console listening on http://127.0.0.1:9990
17:52:53,384 INFO [org.jboss.as] (Controller Boot Thread) JBAS015874: JBoss AS 7.2.0.Final "Janus" started in 4107ms - Started 194 of 255 services (60 services are passive or on-demand)
In my management webgui I also see all the queus and factories.
And now I try to connect with a client to the Server, but he can't find the factories or queues and I have no idea on how to get the proper jndi-name.
package client;
import java.util.Hashtable;
import java.util.Properties;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.rmi.PortableRemoteObject;
import org.jboss.ejb.client.EJBClientContext;
import org.jboss.ejb.client.PropertiesBasedEJBClientConfiguration;
import org.jboss.ejb.client.remoting.ConfigBasedEJBClientContextSelector;
public class Client
{
private final String factoryJNDILookup = "jms/RemoteConnectionFactory";
private final String queueJNDILookup = "queue/FibonacciQueue";
private ConnectionFactory connectionFactory;
private Queue queue;
public Client()
{
Properties jbossClientProps = new Properties();
jbossClientProps.setProperty("remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED", "false");
jbossClientProps.setProperty("remote.connections", "default");
jbossClientProps.setProperty("remote.connection.default.host", "localhost");
jbossClientProps.setProperty("remote.connection.default.port", "4447");
jbossClientProps.setProperty("remote.connection.default.username", "user");
jbossClientProps.setProperty("remote.connection.default.password", "pass");
jbossClientProps.setProperty("remote.connection.default.connect.options.org.xnio.Options.SASL_POLICY_NOPLAINTEXT", "false");
jbossClientProps.setProperty("remote.connection.default.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS", "true");
jbossClientProps.setProperty("remote.connection.default.connect.options.org.xnio.Options.SASL_DISALLOWED_MECHANISMS", "JBOSS-LOCAL-USER");
PropertiesBasedEJBClientConfiguration ejbcfg = new PropertiesBasedEJBClientConfiguration(jbossClientProps);
ConfigBasedEJBClientContextSelector ejbClientSelector = new ConfigBasedEJBClientContextSelector(ejbcfg);
EJBClientContext.setSelector(ejbClientSelector);
Hashtable<String, String> env = new Hashtable<String, String>();
env.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
try
{
InitialContext initialContext = new InitialContext(env);
Object connectionFactoryObjectReference = initialContext.lookup(factoryJNDILookup);
Object connectionFactoryObject = PortableRemoteObject.narrow(connectionFactoryObjectReference, ConnectionFactory.class);
this.connectionFactory = ConnectionFactory.class.cast(connectionFactoryObject);
Object queueReference = initialContext.lookup(queueJNDILookup);
Object queueObject = PortableRemoteObject.narrow(queueReference, Queue.class);
this.queue = Queue.class.cast(queueObject);
} catch (NamingException e)
{
e.printStackTrace();
}
}
public void start()
{
try
{
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer messageProducer = session.createProducer(queue);
TextMessage message = session.createTextMessage();
message.setText("This is a message, Hello");
messageProducer.send(message);
System.out.println("done");
} catch (Exception e)
{
e.printStackTrace();
}
}
public static void main(String args[])
{
Client client = new Client();
client.start();
}
}
And it all fails in Line 51 with:
javax.naming.NoInitialContextException: Need to specify class name in environment or system property, or as an applet parameter, or in an application resource file: java.naming.factory.initial
He is unable to find either the queue nore the factory.
Also tried it with: jboss/exported/jms/RemoteConnectionFactory ; ejb:/jboss/exported/jms/RemoteConnectionFactory!RemoteConnectionFactory ; RemoteConnectionFactory
Any help would be appreciated.
