btapo / stompj Goto Github PK

What steps will reproduce the problem?
1. Connect to a broker
2. Subscribe and begin receiving messages
3. Cause the network connection to be lost

What is the expected output? What do you see instead?
The library should either handle the exception and try to reconnect until 
successful or pass the exception up to the main application.  Instead the 
application crashes because it fails to handle the exception.

What version of the product are you using? On what operating system?
0.5 on Android 2.3

Please provide any additional information below.

Exception:
FATAL EXCEPTION: Thread-11
pk.aamir.stompj.StompJRuntimeException: BufferedInputStream is closed
at pk.aamir.stompj.internal.FrameReceiver.getLine(FrameReceiver.java:82 at 
pk.aamir.stompj.internal.FrameReceiver.processInComingFrame(FrameReceiver.java:5
5) at pk.aamir.stompj.internal.FrameReceiver.run(FrameReceiver.java:50)
Caused by: java.io.IOException: BufferedInputStream is closed at 
java.io.BufferedInputStream.streamClosed(BufferedInputStream.java:116)
    at java.io.BufferedInputStream.read(BufferedInputStream.java:221)
    at pk.aamir.stompj.internal.FrameReceiver.getLine(FrameReceiver.java:71)
   ... 2 more

con = new Connection("url", 61613, "guest", "guest");
        try {
            System.out.println("Starting connection");
            ErrorMessage errmsg = con.connect();
            if (errmsg != null)
                System.out.println("Error? "+errmsg.getContentAsString());
        } catch (StompJException e) {
            // TODO Auto-generated catch block
            System.out.println("Couldn't connect with Java Stomp thing");
            e.printStackTrace();
        }




/////////////

Here are results :-(

Initializing connection
[INFO] [Launcher:/installer] org.red5.server.service.Installer - Installer 
service created
Starting connection
[ERROR] [Launcher:/app] org.red5.server.Scope - Could not start scope 
[WebScope@55f35e30 Depth = 1, Path = '/default', Name = 'app']. 
java.lang.NullPointerException

What steps will reproduce the problem?
call con.disconnect() function.

What is the expected output? What do you see instead?
expected output: no runtime exception.
when the con.disconnect is called, a runtime exception appears. Here is the 
trace:

Exception in thread "Thread-1" pk.aamir.stompj.StompJRuntimeException: socket 
closed
    at pk.aamir.stompj.internal.FrameReceiver.getLine(FrameReceiver.java:82)
    at pk.aamir.stompj.internal.FrameReceiver.processInComingFrame(FrameReceiver.java:55)
    at pk.aamir.stompj.internal.FrameReceiver.run(FrameReceiver.java:50)
Caused by: java.net.SocketException: socket closed
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.read(SocketInputStream.java:129)
    at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
    at java.io.BufferedInputStream.read(BufferedInputStream.java:237)
    at pk.aamir.stompj.internal.FrameReceiver.getLine(FrameReceiver.java:71)    at pk.aamir.stompj.internal.FrameReceiver.getLine(FrameReceiver.java:71)

do you plan to support jdk 1.4 in future?

I have failed to find any source code for the library in the subversion