List of stopSending() Examples

Examples of stopSending()

org.apache.sandesha2.workers.Sender.stopSending()
org.rhq.enterprise.communications.command.client.ClientCommandSender.stopSending()
This stops all sending, both synchronous and asynchronous. Asynchronous commands are still allowed to be queued up, they just won't be sent. If processCurrentlyQueuedCommands is false, then any current commands in the queue will be dequeued - guaranteed commands will be persisted; if and when {@link #startSending()} is called, they will be re-queued (if the VM dies in the meantime, only the guaranteedcommands will be preserved upon the restart). Any commands currently being executed will be interrupted and, if they do not require guaranteed delivery, will be lost. If processCurrentlyQueuedCommands is true, then all commands in the queue will be processed - once the queue is empty and all commands sent, this method will return.
If this client was not already {@link #isSending() stopped}, this method returns true to indicate the client's mode has changed from started to stopped.

If this client is already {@link #isSending() stopped}, this method does nothing and returns false to indicate the mode hasn't changed - it is still in the stopped mode.

This method will not return until the the executor thread pool has completely shutdown.
@param process_currently_queued_commands if true, this will block and wait for all current commandsin the queue to be sent before returning @return true if this client was sending prior to this method being called (and hence this clientchanged modes); false if this client was not already sending and thus this method ended up being a no-op
org.rhq.enterprise.server.agentclient.AgentClient.stopSending()
Stops the agent client from sending messages. Any messages sent asynchronously with guaranteed delivery will be spooled and sent the next time an agent client is started.

Examples of org.apache.sandesha2.workers.Sender.stopSending()

  
  public static void stopSender(ConfigurationContext context) {
    Sender sender = (Sender) context.getProperty(Sandesha2Constants.SENDER);
    
    if (sender!=null) {
      sender.stopSending ();
    }
  }


  public static void startInvokerForTheSequence(ConfigurationContext context, String sequenceID) {

View Full Code Here

Examples of org.apache.sandesha2.workers.Sender.stopSending()

  
  public static void stopSender(ConfigurationContext context) {
    Sender sender = (Sender) context.getProperty(Sandesha2Constants.SENDER);
    
    if (sender!=null) {
      sender.stopSending ();
    }
  }


  public static void startInvokerForTheSequence(ConfigurationContext context, String sequenceID) {

View Full Code Here

Examples of org.rhq.enterprise.communications.command.client.ClientCommandSender.stopSending()

        } catch (Exception e) {
            LOG.debug(ServerI18NResourceKeys.PING_FAILED, endpoint, ThrowableUtil.getAllMessages(e, true));
            pinged = false;
        } finally {
            if (sender != null) {
                sender.stopSending(false);
            }
        }


        return pinged;
    }

View Full Code Here

Examples of org.rhq.enterprise.communications.command.client.ClientCommandSender.stopSending()

                    if (subcommand.equals(MSG.getMsg(AgentI18NResourceKeys.SENDER_START))) {
                        out.println(MSG.getMsg(AgentI18NResourceKeys.SENDER_STARTING));
                        sender.startSending();
                    } else if (subcommand.equals(MSG.getMsg(AgentI18NResourceKeys.SENDER_STOP))) {
                        out.println(MSG.getMsg(AgentI18NResourceKeys.SENDER_STOPPING));
                        sender.stopSending(true);
                    } else if (subcommand.equals(MSG.getMsg(AgentI18NResourceKeys.SENDER_METRICS))) {
                        ClientCommandSenderMetrics metrics = sender.getMetrics();


                        out.println(MSG.getMsg(AgentI18NResourceKeys.SENDER_METRICS_OUTPUT, metrics));
                    } else if (!subcommand.equals(MSG.getMsg(AgentI18NResourceKeys.SENDER_STATUS))) {

View Full Code Here

Examples of org.rhq.enterprise.server.agentclient.AgentClient.stopSending()

            int agent_port = agent.getPort();


            agent_client = m_knownAgentClients.remove(getEndpointKey(agent_address, agent_port));


            if (agent_client != null) {
                agent_client.stopSending();
            }


            // purge the spool file, if it exists
            File spool_file = null;

View Full Code Here

Examples of org.rhq.enterprise.server.agentclient.AgentClient.stopSending()

        synchronized (m_knownAgentClients) {
            client = m_knownAgentClients.remove(getEndpointKey(locator.getHost(), locator.getPort()));
        }


        if (client != null) {
            client.stopSending();
        }


        return;
    }

View Full Code Here

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.