Examples of DisconnectMessage

asia.stampy.client.message.disconnect.DisconnectMessage
The Class DisconnectMessage.
clueless.messaging.DisconnectMessage
Extension of suggestion message from client -> server to differentiate to the server which type of theory is being passed @author Chris
com.corundumstudio.socketio.store.pubsub.DisconnectMessage
com.twitter.hbc.twitter4j.message.DisconnectMessage
org.ethereum.net.p2p.DisconnectMessage
Wrapper around an Ethereum Disconnect message on the network @see org.ethereum.net.p2p.P2pMessageCodes#DISCONNECT
org.hornetq.core.protocol.core.impl.wireformat.DisconnectMessage
org.xulfactory.gliese.message.DisconnectMessage
@author sirot

Examples of org.hornetq.core.protocol.core.impl.wireformat.DisconnectMessage

      {
         final byte type = packet.getType();


         if (type == PacketImpl.DISCONNECT)
         {
            final DisconnectMessage msg = (DisconnectMessage)packet;


            SimpleString nodeID = msg.getNodeID();


            if (ClientSessionFactoryImpl.log.isTraceEnabled())
            {
               ClientSessionFactoryImpl.log.trace("Disconnect being called on client:" + msg +
                                                  " server locator = " +
                                                  serverLocator +
                                                  " notifying node " +
                                                  nodeID +
                                                  " as down", new Exception("trace"));
            }


            if (nodeID != null)
            {
               serverLocator.notifyNodeDown(System.currentTimeMillis(), msg.getNodeID().toString());
            }


            closeExecutor.execute(new Runnable()
            {
               // Must be executed on new thread since cannot block the netty thread for a long time and fail can

View Full Code Here

Examples of org.hornetq.core.protocol.core.impl.wireformat.DisconnectMessage

      {
         final byte type = packet.getType();


         if (type == PacketImpl.DISCONNECT)
         {
            final DisconnectMessage msg = (DisconnectMessage) packet;


            SimpleString nodeID = msg.getNodeID();


            if (HornetQClientLogger.LOGGER.isTraceEnabled())
            {
               HornetQClientLogger.LOGGER.trace("Disconnect being called on client:" + msg +
                                                   " server locator = " +
                                                   serverLocator +
                                                   " notifying node " +
                                                   nodeID +
                                                   " as down", new Exception("trace"));
            }


            if (nodeID != null)
            {
               serverLocator.notifyNodeDown(System.currentTimeMillis(), msg.getNodeID().toString());
            }


            closeExecutor.execute(new CloseRunnable(conn));
         }
         else if (type == PacketImpl.CLUSTER_TOPOLOGY)

View Full Code Here

Examples of org.xulfactory.gliese.message.DisconnectMessage

      } catch (SSHException se) {
        close();
        throw se;
      }
      if (m.getID() == DisconnectMessage.ID) {
        DisconnectMessage msg = (DisconnectMessage)m;
        GlieseLogger.LOGGER.info("Disconnect message received: " + msg);
        close();
        throw new SSHException(String.format(
          "%s (reason code=%d)", msg.getMessage(),
          msg.getReasonCode()));
      } else if (m.getID() == DebugMessage.ID) {
        DebugMessage msg = (DebugMessage)m;
        if (msg.isAlwaysDisplay()) {
          GlieseLogger.LOGGER.info("Debug message: " + msg.getMessage());
        } else {
          GlieseLogger.LOGGER.debug("Debug message: " + msg.getMessage());
        }
      } else {
        break;
      }
    } while (true);

View Full Code Here

0 1 2 3 4 5

TOP

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.