Android + Apache MINA doesn't run messageSent() after session.write()

Question

What could be the problem with Apache MINA if it won't call messageSent() method after writing to active session? My code works perfectly in simple Java client but doesn't work in Android application.

TCPClient's code:

if (session != null && session.isConnected()) {
            throw new IllegalStateException("Already connected. Disconnect first.");
        }

        connector = new NioSocketConnector();
        connector.getSessionConfig().setUseReadOperation(true);

        try {
            SslFilter sslFilter = new SslFilter(ClientSslContextFactory.getInstance());
            sslFilter.setUseClientMode(true);
            connector.getFilterChain().addFirst("sslFilter", sslFilter);

            handler = new TCPHandler();
            connector.setHandler(handler);
            connector.getSessionConfig().setReadBufferSize(4096);

            // try to connect to server
            Log.d(TAG, "Connecting...");
            ConnectFuture future = connector.connect(new InetSocketAddress(Const.hostIP, Const.sessionPort));
            future.addListener(new IoFutureListener<IoFuture>() {

                public void operationComplete(IoFuture future) {
                    ConnectFuture connFuture = (ConnectFuture) future;
                    if(connFuture.isConnected()){
                        Log.d(TAG, "Assigning session...");
                        session = future.getSession();

                    } else {
                        Log.e(TAG, "Not connected...exiting");
                    }
                }
            });
            future.awaitUninterruptibly();
        } catch (RuntimeIoException e) {
            Log.e(TAG, "Failed to connect.");
            e.printStackTrace();
        } catch (IllegalArgumentException e) {
            Log.e(TAG, "Failed to connect. Illegal Argument! Terminating program!");
            e.printStackTrace();
        } catch (GeneralSecurityException e) {
            Log.e(TAG, "Failed to set SSL filter!");
            e.printStackTrace();
        }

TCPHandler's sending code:

@Override
    public void sessionOpened(IoSession session) throws Exception {
        super.sessionOpened(session);
        Log.d(TAG, "Session opened...");

        byte[] ba = ("stringasdfasdf\n").getBytes();
        IoBuffer buffer = IoBuffer.allocate(ba.length);
        buffer.put(ba);
        buffer.flip();
        session.write(buffer);
        Log.d(TAG, "TCP writing executed.");
    }

Yeung · Accepted Answer · 2018-12-12 03:45:17Z

1

I have the same issue and notice that it is important:

@Override
public void sessionCreated(IoSession session) throws Exception {
    Log.d(TAG, "sessionCreated");
    session.setAttribute(SslFilter.USE_NOTIFICATION);
}

Once session.setAttribute(SslFilter.USE_NOTIFICATION) is added. It works.

answered Dec 12, 2018 at 3:45

Yeung

2,3182 gold badges29 silver badges53 bronze badges

Sign up to request clarification or add additional context in comments.

Comments

tesla1984 · Accepted Answer · 2016-04-07 10:03:11Z

0

connector.connect can not run in the main thread in Android. Are you sure the session is open?

answered Apr 7, 2016 at 10:03

tesla1984

5412 silver badges8 bronze badges

Collectives™ on Stack Overflow

Android + Apache MINA doesn't run messageSent() after session.write()

2 Answers 2

Comments

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

Comments

Comments

Your Answer

Sign up or log in

Post as a guest

Related