Examples of net.grinder.message.console.AgentControllerProcessReportMessage

net.grinder.message.console.AgentControllerProcessReportMessage
Message for informing the console of agent process status. @author JunHo Yoon @since 3.0

     */
    public AgentControllerState getAgentControllerState() {
      if (m_agentReference == null) {
        return AgentControllerState.UNKNOWN;
      }
      AgentControllerProcessReportMessage agentProcessReport = m_agentReference.m_agentProcessReportMessage;
      return agentProcessReport == null ? AgentControllerState.UNKNOWN : agentProcessReport.getState();
    }

View Full Code Here


    public ConsoleCommunication(Connector connector) throws CommunicationException {
      final ClientReceiver receiver = ClientReceiver.connect(connector, new AgentAddress(m_agentIdentity));
      m_sender = ClientSender.connect(receiver);


      m_sender.send(new AgentControllerProcessReportMessage(AgentControllerState.STARTED, getSystemDataModel(),
          m_connectionPort, version));
      final MessageDispatchSender messageDispatcher = new MessageDispatchSender();
      m_agentControllerServerListener.registerMessageHandlers(messageDispatcher);


      m_messagePump = new MessagePump(receiver, messageDispatcher, 1);

View Full Code Here

        LOGGER.error("{}. This error is not critical if it doesn't occur much.", e.getMessage());
      }
    }


    public void sendCurrentState() throws CommunicationException {
      sendMessage(new AgentControllerProcessReportMessage(m_state, getSystemDataModel(), m_connectionPort, version));
    }

View Full Code Here

    }


    public void shutdown() {
      m_reportRunningTask.cancel();
      try {
        m_sender.send(new AgentControllerProcessReportMessage(AgentControllerState.FINISHED, null, 0, version));
      } catch (CommunicationException e) {
        // Fall through
        // Ignore - peer has probably shut down.
        noOp();
      } finally {

View Full Code Here

TOP

Related Classes of net.grinder.message.console.AgentControllerProcessReportMessage

net.grinder.AgentController$ConsoleCommunication

net.grinder.console.communication.AgentProcessControlImplementation$AgentStatus

net.grinder.communication.CommunicationException

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.