Package org.apache.mina.core.future

Examples of org.apache.mina.core.future.CloseFuture.addListener()

63
64
65
66
67
68
69
70
71
72
73
    public void addSession(AbstractIoSession session) {
        sessions.add(session);
        CloseFuture closeFuture = session.getCloseFuture();
       
        // isn't service reponsability to remove the session nicely ?
        closeFuture.addListener(sessionCloseListener);
    }

    /**
     * remove a session from the list of session being checked.
     * @param session
View Full Code Here
547
548
549
550
551
552
553
554
555
556
557
        // Get the close future for this session
        CloseFuture closeFuture = connectionFuture.getSession().getCloseFuture();

        // Add a listener to close the session in the session.
        closeFuture.addListener( new IoFutureListener<IoFuture>()
        {
            public void operationComplete( IoFuture future )
            {
                // Process all the waiting operations and cancel them
                LOG.debug( "received a NoD, closing everything" );
View Full Code Here
562
563
564
565
566
567
568
569
570
571
572
        // Get the close future for this session
        CloseFuture closeFuture = connectionFuture.getSession().getCloseFuture();

        // Add a listener to close the session in the session.
        closeFuture.addListener( new IoFutureListener<IoFuture>()
        {
            public void operationComplete( IoFuture future )
            {
                // Process all the waiting operations and cancel them
                LOG.debug( "received a NoD, closing everything" );
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
        disposeSession( session );
    }

    private void disposeSession( IoSession session ) {
        CloseFuture cf  = session.getCloseFuture();
        cf.addListener( new IoFutureListener() {
            public void operationComplete(IoFuture future) {
                if ( future.getSession().isConnected() ) {
                    future.getSession().close( false );
                }
            }
View Full Code Here
597
598
599
600
601
602
603
604
605
606
607
        // Get the close future for this session
        CloseFuture closeFuture = connectionFuture.getSession().getCloseFuture();

        // Add a listener to close the session in the session.
        closeFuture.addListener( new IoFutureListener<IoFuture>()
        {
            public void operationComplete( IoFuture future )
            {
                // Process all the waiting operations and cancel them
                LOG.debug( "received a NoD, closing everything" );
View Full Code Here
565
566
567
568
569
570
571
572
573
574
575
        // Get the close future for this session
        CloseFuture closeFuture = connectionFuture.getSession().getCloseFuture();

        // Add a listener to close the session in the session.
        closeFuture.addListener( new IoFutureListener<IoFuture>()
        {
            public void operationComplete( IoFuture future )
            {
                // Process all the waiting operations and cancel them
                LOG.debug( "received a NoD, closing everything" );
View Full Code Here
261
262
263
264
265
266
267
268
269
270
271
              ((IoBuffer) obj).free();
            }
          }
        }
      };
      future.addListener(listener);
    }
  }

  /**
   * Setter for handler.
View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
            log.debug("Connection is not yet closed");
          }
          future.removeListener(this);
        }
      };
      future.addListener(listener);
    }
    log.debug("Connection state: {}", getState());
    if (getStateCode() != RTMP.STATE_DISCONNECTED) {
      handler.connectionClosed(this);
    }
View Full Code Here
569
570
571
572
573
574
575
576
577
578
579
        // Get the close future for this session
        CloseFuture closeFuture = connectionFuture.getSession().getCloseFuture();

        // Add a listener to close the session in the session.
        closeFuture.addListener( new IoFutureListener<IoFuture>()
        {
            public void operationComplete( IoFuture future )
            {
                // Process all the waiting operations and cancel them
                LOG.debug( "received a NoD, closing everything" );
View Full Code Here
590
591
592
593
594
595
596
597
598
599
600
        // Get the close future for this session
        CloseFuture closeFuture = connectionFuture.getSession().getCloseFuture();

        // Add a listener to close the session in the session.
        closeFuture.addListener( new IoFutureListener<IoFuture>()
        {
            public void operationComplete( IoFuture future )
            {
                // Process all the waiting operations and cancel them
                LOG.debug( "received a NoD, closing everything" );
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.