Sending XML message to JMS queue

am working with a project in which I am trying to call a Servlet that will push XML message to a JMS queue running in my local machine, using java code. You can find the actual Servlet code below, which actually sends the message to the queue.

import java.io.IOException;

import java.io.PrintWriter;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.ObjectMessage;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueSender;

import javax.jms.QueueSession;

import javax.jms.TextMessage;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;





public class MessageSender

  extends HttpServlet

{

  private static final long serialVersionUID = 1L;

  static PrintWriter out;

  public static final String CNN_FACTORY = "jms/alert/connectionFactory";

  public static final String QUEUE_NAME = "jms/alert/amlScreenQueue";

  public static String currentQueueName;

  public static String JMSConnectionFactory;

  private QueueConnection qcon;

  private QueueSession qsession;

  private static QueueSender qsender;

  private Queue queue;

  private static ObjectMessage om;

  private static MessageProducer messageProducer;



  public MessageSender() {}



  public void service(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    try

    {

      String JMSQueueName = request.getParameter("JMSQueueName");

      currentQueueName = JMSQueueName;



      JMSConnectionFactory = request.getParameter("JMSConnectionFactory");

      out = response.getWriter();

      InitialContext ic = getInitialContext();

      init(ic, JMSQueueName);

      doPost(request, response);

    }

    catch (Exception e) {

      e.printStackTrace();

    }

  }



  public void init(Context ctx, String queueName)

    throws NamingException, JMSException

  {

    QueueConnectionFactory qconFactory = (QueueConnectionFactory)ctx.lookup(JMSConnectionFactory);

    this.qcon = qconFactory.createQueueConnection();

    this.qsession = this.qcon.createQueueSession(false, 1);

    queue = ((Queue)ctx.lookup(queueName));



    QueueConnection qcon = qconFactory.createQueueConnection();

    qcon.start();

    QueueSession qsession = qcon.createQueueSession(false, 1);

    qsender = qsession.createSender(queue);

  }





  protected void doPost(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    String textMessage = request.getParameter("textMessage");



    try

    {

      TextMessage msg = qsession.createTextMessage(textMessage);

      msg.setStringProperty("JMSXGroupID", "1");

      msg.setIntProperty("JMSXGroupSeq", 1);

      msg.setBooleanProperty("JMS_IBM_Last_Msg_In_Group", false);

      qsender.send(msg);

      out.println("Message sent to queue " + currentQueueName);

      out.println("");

      out.println(msg.getText());

    }

    catch (JMSException e)

    {

      e.printStackTrace();

      out.println(e.getErrorCode());

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

    finally

    {

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

  }



  private static InitialContext getInitialContext() throws NamingException

  {

    return new InitialContext();

  }

}

This is the java code that I am using to call the servlet,

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.HttpURLConnection;

import java.net.MalformedURLException;

import java.net.URISyntaxException;

import java.net.URL;

import java.net.URLConnection;

import java.nio.file.Files;

import java.nio.file.Paths;

import java.util.List;

import java.util.Map.Entry;



public class SendMessage {



    public static void main(String args) throws URISyntaxException{

        String line;

        StringBuffer buffer = new StringBuffer();

        String data = null;



        try 

        { 

            String filePath = "data/payload.xml";

            File dataFile = new File(filePath);

            if(dataFile.exists()){



                data = new String(Files.readAllBytes(Paths.get(filePath)));                



            }else{

                System.out.println("Not Available");

            }







            String localUrl = "http://localhost:8080/SimulationTool/MessageSender";

            String params = "JMSQueueName=jms/alert/amlScreenQueue&"

                    + "JMSConnectionFactory=jms/alert/connectionFactory&"

                    + "textMessage=" + data;



            System.out.println("PARAMS:::" + params);



            URL url = new URL(localUrl);



            System.out.println("URL FOUND:::" + url.toURI());



            URLConnection conn = url.openConnection();

            conn.setDoOutput(true);

            conn.connect();



            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            BufferedWriter out = new BufferedWriter( new OutputStreamWriter( conn.getOutputStream() ));

            out.write(params);

            out.flush();

            out.close();



            // Response code

            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            // Response values

            for (Entry<String, List<String>> header : ((HttpURLConnection)conn).getHeaderFields().entrySet()) {

                System.out.println(header.getKey() + "=" + header.getValue());

            }





            BufferedReader in = new BufferedReader( new InputStreamReader( conn.getInputStream() ) );                

            String response;

            while ( (response = in.readLine()) != null ) {

                System.out.println( response );

            }

            in.close();



        }

        catch ( MalformedURLException ex ) {

            ex.printStackTrace();

        }

        catch ( IOException ex ) {

            ex.printStackTrace();

        } 

    }



}

The problem is its failing with below exception,

Response Code:::200

    java.net.ProtocolException: Cannot write output after reading input.

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1312)

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1291)

        at servlettests.SendMessage.main(SendMessage.java:63)

Its shows response code as 200, so the connection was successful but it fails while getting the outputstream, which is being created to send message to the queue. Pls help me on resolving this issue.

asked Nov 21 '18 at 7:13

MaheshKathirvel

Did you look at this post and this here. And what is the code that is throwing the exception?

– prasad_
Nov 21 '18 at 7:23

Hi prasad. I checked that link and removed that line of code which checks the status before writing to the stream.. and its working fine.. thanks for your help.

– MaheshKathirvel
Nov 22 '18 at 6:42

add a comment |

import java.io.IOException;

import java.io.PrintWriter;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.ObjectMessage;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueSender;

import javax.jms.QueueSession;

import javax.jms.TextMessage;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;





public class MessageSender

  extends HttpServlet

{

  private static final long serialVersionUID = 1L;

  static PrintWriter out;

  public static final String CNN_FACTORY = "jms/alert/connectionFactory";

  public static final String QUEUE_NAME = "jms/alert/amlScreenQueue";

  public static String currentQueueName;

  public static String JMSConnectionFactory;

  private QueueConnection qcon;

  private QueueSession qsession;

  private static QueueSender qsender;

  private Queue queue;

  private static ObjectMessage om;

  private static MessageProducer messageProducer;



  public MessageSender() {}



  public void service(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    try

    {

      String JMSQueueName = request.getParameter("JMSQueueName");

      currentQueueName = JMSQueueName;



      JMSConnectionFactory = request.getParameter("JMSConnectionFactory");

      out = response.getWriter();

      InitialContext ic = getInitialContext();

      init(ic, JMSQueueName);

      doPost(request, response);

    }

    catch (Exception e) {

      e.printStackTrace();

    }

  }



  public void init(Context ctx, String queueName)

    throws NamingException, JMSException

  {

    QueueConnectionFactory qconFactory = (QueueConnectionFactory)ctx.lookup(JMSConnectionFactory);

    this.qcon = qconFactory.createQueueConnection();

    this.qsession = this.qcon.createQueueSession(false, 1);

    queue = ((Queue)ctx.lookup(queueName));



    QueueConnection qcon = qconFactory.createQueueConnection();

    qcon.start();

    QueueSession qsession = qcon.createQueueSession(false, 1);

    qsender = qsession.createSender(queue);

  }





  protected void doPost(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    String textMessage = request.getParameter("textMessage");



    try

    {

      TextMessage msg = qsession.createTextMessage(textMessage);

      msg.setStringProperty("JMSXGroupID", "1");

      msg.setIntProperty("JMSXGroupSeq", 1);

      msg.setBooleanProperty("JMS_IBM_Last_Msg_In_Group", false);

      qsender.send(msg);

      out.println("Message sent to queue " + currentQueueName);

      out.println("");

      out.println(msg.getText());

    }

    catch (JMSException e)

    {

      e.printStackTrace();

      out.println(e.getErrorCode());

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

    finally

    {

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

  }



  private static InitialContext getInitialContext() throws NamingException

  {

    return new InitialContext();

  }

}

This is the java code that I am using to call the servlet,

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.HttpURLConnection;

import java.net.MalformedURLException;

import java.net.URISyntaxException;

import java.net.URL;

import java.net.URLConnection;

import java.nio.file.Files;

import java.nio.file.Paths;

import java.util.List;

import java.util.Map.Entry;



public class SendMessage {



    public static void main(String args) throws URISyntaxException{

        String line;

        StringBuffer buffer = new StringBuffer();

        String data = null;



        try 

        { 

            String filePath = "data/payload.xml";

            File dataFile = new File(filePath);

            if(dataFile.exists()){



                data = new String(Files.readAllBytes(Paths.get(filePath)));                



            }else{

                System.out.println("Not Available");

            }







            String localUrl = "http://localhost:8080/SimulationTool/MessageSender";

            String params = "JMSQueueName=jms/alert/amlScreenQueue&"

                    + "JMSConnectionFactory=jms/alert/connectionFactory&"

                    + "textMessage=" + data;



            System.out.println("PARAMS:::" + params);



            URL url = new URL(localUrl);



            System.out.println("URL FOUND:::" + url.toURI());



            URLConnection conn = url.openConnection();

            conn.setDoOutput(true);

            conn.connect();



            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            BufferedWriter out = new BufferedWriter( new OutputStreamWriter( conn.getOutputStream() ));

            out.write(params);

            out.flush();

            out.close();



            // Response code

            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            // Response values

            for (Entry<String, List<String>> header : ((HttpURLConnection)conn).getHeaderFields().entrySet()) {

                System.out.println(header.getKey() + "=" + header.getValue());

            }





            BufferedReader in = new BufferedReader( new InputStreamReader( conn.getInputStream() ) );                

            String response;

            while ( (response = in.readLine()) != null ) {

                System.out.println( response );

            }

            in.close();



        }

        catch ( MalformedURLException ex ) {

            ex.printStackTrace();

        }

        catch ( IOException ex ) {

            ex.printStackTrace();

        } 

    }



}

The problem is its failing with below exception,

Response Code:::200

    java.net.ProtocolException: Cannot write output after reading input.

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1312)

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1291)

        at servlettests.SendMessage.main(SendMessage.java:63)

Its shows response code as 200, so the connection was successful but it fails while getting the outputstream, which is being created to send message to the queue. Pls help me on resolving this issue.

asked Nov 21 '18 at 7:13

MaheshKathirvel

Did you look at this post and this here. And what is the code that is throwing the exception?

– prasad_
Nov 21 '18 at 7:23

Hi prasad. I checked that link and removed that line of code which checks the status before writing to the stream.. and its working fine.. thanks for your help.

– MaheshKathirvel
Nov 22 '18 at 6:42

add a comment |

import java.io.IOException;

import java.io.PrintWriter;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.ObjectMessage;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueSender;

import javax.jms.QueueSession;

import javax.jms.TextMessage;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;





public class MessageSender

  extends HttpServlet

{

  private static final long serialVersionUID = 1L;

  static PrintWriter out;

  public static final String CNN_FACTORY = "jms/alert/connectionFactory";

  public static final String QUEUE_NAME = "jms/alert/amlScreenQueue";

  public static String currentQueueName;

  public static String JMSConnectionFactory;

  private QueueConnection qcon;

  private QueueSession qsession;

  private static QueueSender qsender;

  private Queue queue;

  private static ObjectMessage om;

  private static MessageProducer messageProducer;



  public MessageSender() {}



  public void service(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    try

    {

      String JMSQueueName = request.getParameter("JMSQueueName");

      currentQueueName = JMSQueueName;



      JMSConnectionFactory = request.getParameter("JMSConnectionFactory");

      out = response.getWriter();

      InitialContext ic = getInitialContext();

      init(ic, JMSQueueName);

      doPost(request, response);

    }

    catch (Exception e) {

      e.printStackTrace();

    }

  }



  public void init(Context ctx, String queueName)

    throws NamingException, JMSException

  {

    QueueConnectionFactory qconFactory = (QueueConnectionFactory)ctx.lookup(JMSConnectionFactory);

    this.qcon = qconFactory.createQueueConnection();

    this.qsession = this.qcon.createQueueSession(false, 1);

    queue = ((Queue)ctx.lookup(queueName));



    QueueConnection qcon = qconFactory.createQueueConnection();

    qcon.start();

    QueueSession qsession = qcon.createQueueSession(false, 1);

    qsender = qsession.createSender(queue);

  }





  protected void doPost(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    String textMessage = request.getParameter("textMessage");



    try

    {

      TextMessage msg = qsession.createTextMessage(textMessage);

      msg.setStringProperty("JMSXGroupID", "1");

      msg.setIntProperty("JMSXGroupSeq", 1);

      msg.setBooleanProperty("JMS_IBM_Last_Msg_In_Group", false);

      qsender.send(msg);

      out.println("Message sent to queue " + currentQueueName);

      out.println("");

      out.println(msg.getText());

    }

    catch (JMSException e)

    {

      e.printStackTrace();

      out.println(e.getErrorCode());

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

    finally

    {

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

  }



  private static InitialContext getInitialContext() throws NamingException

  {

    return new InitialContext();

  }

}

This is the java code that I am using to call the servlet,

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.HttpURLConnection;

import java.net.MalformedURLException;

import java.net.URISyntaxException;

import java.net.URL;

import java.net.URLConnection;

import java.nio.file.Files;

import java.nio.file.Paths;

import java.util.List;

import java.util.Map.Entry;



public class SendMessage {



    public static void main(String args) throws URISyntaxException{

        String line;

        StringBuffer buffer = new StringBuffer();

        String data = null;



        try 

        { 

            String filePath = "data/payload.xml";

            File dataFile = new File(filePath);

            if(dataFile.exists()){



                data = new String(Files.readAllBytes(Paths.get(filePath)));                



            }else{

                System.out.println("Not Available");

            }







            String localUrl = "http://localhost:8080/SimulationTool/MessageSender";

            String params = "JMSQueueName=jms/alert/amlScreenQueue&"

                    + "JMSConnectionFactory=jms/alert/connectionFactory&"

                    + "textMessage=" + data;



            System.out.println("PARAMS:::" + params);



            URL url = new URL(localUrl);



            System.out.println("URL FOUND:::" + url.toURI());



            URLConnection conn = url.openConnection();

            conn.setDoOutput(true);

            conn.connect();



            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            BufferedWriter out = new BufferedWriter( new OutputStreamWriter( conn.getOutputStream() ));

            out.write(params);

            out.flush();

            out.close();



            // Response code

            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            // Response values

            for (Entry<String, List<String>> header : ((HttpURLConnection)conn).getHeaderFields().entrySet()) {

                System.out.println(header.getKey() + "=" + header.getValue());

            }





            BufferedReader in = new BufferedReader( new InputStreamReader( conn.getInputStream() ) );                

            String response;

            while ( (response = in.readLine()) != null ) {

                System.out.println( response );

            }

            in.close();



        }

        catch ( MalformedURLException ex ) {

            ex.printStackTrace();

        }

        catch ( IOException ex ) {

            ex.printStackTrace();

        } 

    }



}

The problem is its failing with below exception,

Response Code:::200

    java.net.ProtocolException: Cannot write output after reading input.

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1312)

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1291)

        at servlettests.SendMessage.main(SendMessage.java:63)

Its shows response code as 200, so the connection was successful but it fails while getting the outputstream, which is being created to send message to the queue. Pls help me on resolving this issue.

asked Nov 21 '18 at 7:13

MaheshKathirvel

import java.io.IOException;

import java.io.PrintWriter;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.ObjectMessage;

import javax.jms.Queue;

import javax.jms.QueueConnection;

import javax.jms.QueueConnectionFactory;

import javax.jms.QueueSender;

import javax.jms.QueueSession;

import javax.jms.TextMessage;

import javax.naming.Context;

import javax.naming.InitialContext;

import javax.naming.NamingException;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServlet;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;





public class MessageSender

  extends HttpServlet

{

  private static final long serialVersionUID = 1L;

  static PrintWriter out;

  public static final String CNN_FACTORY = "jms/alert/connectionFactory";

  public static final String QUEUE_NAME = "jms/alert/amlScreenQueue";

  public static String currentQueueName;

  public static String JMSConnectionFactory;

  private QueueConnection qcon;

  private QueueSession qsession;

  private static QueueSender qsender;

  private Queue queue;

  private static ObjectMessage om;

  private static MessageProducer messageProducer;



  public MessageSender() {}



  public void service(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    try

    {

      String JMSQueueName = request.getParameter("JMSQueueName");

      currentQueueName = JMSQueueName;



      JMSConnectionFactory = request.getParameter("JMSConnectionFactory");

      out = response.getWriter();

      InitialContext ic = getInitialContext();

      init(ic, JMSQueueName);

      doPost(request, response);

    }

    catch (Exception e) {

      e.printStackTrace();

    }

  }



  public void init(Context ctx, String queueName)

    throws NamingException, JMSException

  {

    QueueConnectionFactory qconFactory = (QueueConnectionFactory)ctx.lookup(JMSConnectionFactory);

    this.qcon = qconFactory.createQueueConnection();

    this.qsession = this.qcon.createQueueSession(false, 1);

    queue = ((Queue)ctx.lookup(queueName));



    QueueConnection qcon = qconFactory.createQueueConnection();

    qcon.start();

    QueueSession qsession = qcon.createQueueSession(false, 1);

    qsender = qsession.createSender(queue);

  }





  protected void doPost(HttpServletRequest request, HttpServletResponse response)

    throws ServletException, IOException

  {

    String textMessage = request.getParameter("textMessage");



    try

    {

      TextMessage msg = qsession.createTextMessage(textMessage);

      msg.setStringProperty("JMSXGroupID", "1");

      msg.setIntProperty("JMSXGroupSeq", 1);

      msg.setBooleanProperty("JMS_IBM_Last_Msg_In_Group", false);

      qsender.send(msg);

      out.println("Message sent to queue " + currentQueueName);

      out.println("");

      out.println(msg.getText());

    }

    catch (JMSException e)

    {

      e.printStackTrace();

      out.println(e.getErrorCode());

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

    finally

    {

      try

      {

        qsender.close();

        qcon.close();

      }

      catch (JMSException e) {

        e.printStackTrace();

      }

    }

  }



  private static InitialContext getInitialContext() throws NamingException

  {

    return new InitialContext();

  }

}

This is the java code that I am using to call the servlet,

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.File;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.HttpURLConnection;

import java.net.MalformedURLException;

import java.net.URISyntaxException;

import java.net.URL;

import java.net.URLConnection;

import java.nio.file.Files;

import java.nio.file.Paths;

import java.util.List;

import java.util.Map.Entry;



public class SendMessage {



    public static void main(String args) throws URISyntaxException{

        String line;

        StringBuffer buffer = new StringBuffer();

        String data = null;



        try 

        { 

            String filePath = "data/payload.xml";

            File dataFile = new File(filePath);

            if(dataFile.exists()){



                data = new String(Files.readAllBytes(Paths.get(filePath)));                



            }else{

                System.out.println("Not Available");

            }







            String localUrl = "http://localhost:8080/SimulationTool/MessageSender";

            String params = "JMSQueueName=jms/alert/amlScreenQueue&"

                    + "JMSConnectionFactory=jms/alert/connectionFactory&"

                    + "textMessage=" + data;



            System.out.println("PARAMS:::" + params);



            URL url = new URL(localUrl);



            System.out.println("URL FOUND:::" + url.toURI());



            URLConnection conn = url.openConnection();

            conn.setDoOutput(true);

            conn.connect();



            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            BufferedWriter out = new BufferedWriter( new OutputStreamWriter( conn.getOutputStream() ));

            out.write(params);

            out.flush();

            out.close();



            // Response code

            System.out.println("Response Code:::" + ((HttpURLConnection)conn).getResponseCode());



            // Response values

            for (Entry<String, List<String>> header : ((HttpURLConnection)conn).getHeaderFields().entrySet()) {

                System.out.println(header.getKey() + "=" + header.getValue());

            }





            BufferedReader in = new BufferedReader( new InputStreamReader( conn.getInputStream() ) );                

            String response;

            while ( (response = in.readLine()) != null ) {

                System.out.println( response );

            }

            in.close();



        }

        catch ( MalformedURLException ex ) {

            ex.printStackTrace();

        }

        catch ( IOException ex ) {

            ex.printStackTrace();

        } 

    }



}

The problem is its failing with below exception,

Response Code:::200

    java.net.ProtocolException: Cannot write output after reading input.

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(HttpURLConnection.java:1312)

        at sun.net.www.protocol.http.HttpURLConnection.getOutputStream(HttpURLConnection.java:1291)

        at servlettests.SendMessage.main(SendMessage.java:63)

Its shows response code as 200, so the connection was successful but it fails while getting the outputstream, which is being created to send message to the queue. Pls help me on resolving this issue.

java servlets jms

asked Nov 21 '18 at 7:13

MaheshKathirvel

asked Nov 21 '18 at 7:13

MaheshKathirvel

asked Nov 21 '18 at 7:13

MaheshKathirvel

asked Nov 21 '18 at 7:13

MaheshKathirvel

asked Nov 21 '18 at 7:13

MaheshKathirvel

Did you look at this post and this here. And what is the code that is throwing the exception?

– prasad_
Nov 21 '18 at 7:23

Hi prasad. I checked that link and removed that line of code which checks the status before writing to the stream.. and its working fine.. thanks for your help.

– MaheshKathirvel
Nov 22 '18 at 6:42

add a comment |

Did you look at this post and this here. And what is the code that is throwing the exception?

– prasad_
Nov 21 '18 at 7:23

Hi prasad. I checked that link and removed that line of code which checks the status before writing to the stream.. and its working fine.. thanks for your help.

– MaheshKathirvel
Nov 22 '18 at 6:42

Did you look at this post and this here. And what is the code that is throwing the exception?

– prasad_
Nov 21 '18 at 7:23

Hi prasad. I checked that link and removed that line of code which checks the status before writing to the stream.. and its working fine.. thanks for your help.

– MaheshKathirvel
Nov 22 '18 at 6:42

add a comment |

0

active

oldest

votes

Your Answer

StackExchange.ifUsing("editor", function () {
StackExchange.using("externalEditor", function () {
StackExchange.using("snippets", function () {
StackExchange.snippets.init();
});
});
}, "code-snippets");

StackExchange.ready(function() {
var channelOptions = {
tags: "".split(" "),
id: "1"
};
initTagRenderer("".split(" "), "".split(" "), channelOptions);

StackExchange.using("externalEditor", function() {
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled) {
StackExchange.using("snippets", function() {
createEditor();
});
}
else {
createEditor();
}
});

function createEditor() {
StackExchange.prepareEditor({
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader: {
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
},
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
});

}
});

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

StackExchange.ready(
function () {
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53406940%2fsending-xml-message-to-jms-queue%23new-answer', 'question_page');
}
);

Post as a guest

Name

Required, but never shown

0

active

oldest

votes

0

active

oldest

votes

draft saved

draft discarded

Thanks for contributing an answer to Stack Overflow!

Please be sure to answer the question. Provide details and share your research!

But avoid …

Asking for help, clarification, or responding to other answers.

Making statements based on opinion; back them up with references or personal experience.

To learn more, see our tips on writing great answers.

draft saved

draft discarded

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Post as a guest

Name

Required, but never shown

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Sign up or log in

StackExchange.ready(function () {
StackExchange.helpers.onClickDraftSave('#login-link');
});

Post as a guest

Name

Required, but never shown

Name

Required, but never shown

Name

Required, but never shown

This page is only for reference, If you need detailed information, please check here

Search This Blog

Ufyukyu