Re: Can not connect to Message Bean from remote client : Null pointer

[TomeeUser]

Hi Romain,

I moved little further.

Now when I make connection client hangs and when I press CTRL-C I get
following message at server 

20130415 19:28:36  WARN   (Transport)
org.apache.activemq.broker.TransportConnection
[serviceTransportException]:Transport Connection to: tcp://127.0.0.1:60058
failed: java.net.SocketException: Connection reset

java -cp
C:\AppServers\tomee\lib\activemq-client-5.7.0.jar;C:\AppServers\tomee\lib\slf4j-api-1.7.2.jar;C:\AppServers\tomee\lib\slf4j-jdk14-1.7.2.jar;C:\experiments\TomEEAppClient\dist\TomEEAppClient.jar
tomeeappclient.Client3

Setting sys property
Apr 15, 2013 7:27:33 PM org.apache.openejb.client.EventLogger log
INFO:
RemoteInitialContextCreated{providerUri=http://127.0.0.1:8080/tomee/ejb}
20
Qname : LISTENER
Terminate batch job (Y/N)? y

Below is my client code:

package tomeeappclient;

import com.xerox.TomEE.headers.CalculatorRemote;
import java.util.Properties;
import javax.annotation.Resource;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.InitialContext;


public class Client3 
{
    static 
    {
         System.out.println("Setting sys property");
         System.setProperty("MyJmsConnectionFactory",
"connectionfactory:org.apache.activemq.ActiveMQConnectionFactory:tcp://localhost:61616");
         System.setProperty("AnswerQueue",
"queue:org.apache.activemq.command.ActiveMQQueue:LISTENER");
    }
    private ConnectionFactory connectionFactory;
    private Queue questionQueue;
    private Queue answerQueue;
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws Exception
    {
        Client3 client = new Client3();
        client.process();
    }
    private void process() throws Exception
    {
        
        Properties p = new Properties();
        p.put("java.naming.factory.initial",
"org.apache.openejb.client.RemoteInitialContextFactory");
        p.put("java.naming.provider.url",
"http://127.0.0.1:8080/tomee/ejb";);
        InitialContext ctx = new InitialContext(p);

        CalculatorRemote calc = (CalculatorRemote)
ctx.lookup("CalculatorBeanRemote");


        System.out.println( calc.add(10, 10) );
        
        connectionFactory = (ConnectionFactory)
ctx.lookup("java:MyJmsConnectionFactory");
        
        questionQueue = ( Queue ) ctx.lookup("java:AnswerQueue");
        
        System.out.println("Qname : "+ questionQueue.getQueueName());
        
        final Connection connection = connectionFactory.createConnection();
        
        Session         session   = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
        MessageProducer messageProducer =
session.createProducer(questionQueue);
        TextMessage message = session.createTextMessage();
        message.setText("Hello World!");
        messageProducer.send(message);
       
    }

    private void sendText(String text, MessageProducer questions, Session
session) throws JMSException 
    {
        questions.send(session.createTextMessage(text));
    }

    private String receiveText(MessageConsumer answers) throws JMSException 
    {
        return ((TextMessage) answers.receive(1000)).getText();
    }
    
}




--
View this message in context: 
http://openejb.979440.n4.nabble.com/Can-not-connect-to-Message-Bean-from-remote-client-Null-pointer-tp4662203p4662289.html
Sent from the OpenEJB User mailing list archive at Nabble.com.