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

org.rhq.enterprise.communications.command.client.ClientCommandSender.startSending()
This starts to send commands that are found in the queue and allows commands to be synchronously sent via {@link #send(Command)}. Commands are placed in the queue by {@link #sendAsynch(Command,CommandResponseCallback)}. This method also puts commands on the queue that it finds in the persistence command store (for those commands that failed but need to be delivered).
If this client was not already {@link #isSending() sending}, this method returns true to indicate the client's mode has changed from stopped to started.

If this client is already {@link #isSending() sending}, this method does nothing and returns false to indicate the mode hasn't changed - it is still in the sending mode.
@return true if this client was not sending prior to this method being called (and hence this clientchanged modes); false if this client was already sending and thus this method ended up being a no-op

        RemoteInputStream remoteStream = (RemoteInputStream) stream;
        ServiceContainer serviceContainer = ServerCommunicationsServiceUtil.getService().getServiceContainer();
        ClientCommandSenderConfiguration config = serviceContainer.getClientConfiguration();
        ClientCommandSender sender = serviceContainer.createClientCommandSender(remoteStream.getServerEndpoint(),
            config);
        sender.startSending();
        remoteStream.setClientCommandSender(sender);


        return stream;
    }

View Full Code Here

            client_config.enableQueueThrottling = false;
            client_config.enableSendThrottling = false;
            client_config.serverPollingIntervalMillis = -1;


            sender = getServiceContainer().createClientCommandSender(endpoint, client_config);
            sender.startSending();


            // create our own factory so we can customize the timeout
            ClientRemotePojoFactory factory = sender.getClientRemotePojoFactory();
            factory.setTimeout(timeoutMillis);
            Ping pinger = factory.getRemotePojo(Ping.class);

View Full Code Here

                ClientCommandSender sender = agent.getClientCommandSender();


                if (sender != null) {
                    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();

View Full Code Here

        // i don't think we ever do async calls to remote streams, but just in case,
        // we can't interleave them, so make sure we make calls serially
        config.maxConcurrent = 1;


        ClientCommandSender sender = getServiceContainer().createClientCommandSender(server_endpoint, config);
        sender.startSending();
        remote_stream.setClientCommandSender(sender);


        return;
    }

View Full Code Here

        // i don't think we ever do async calls to remote streams, but just in case,
        // we can't interleave them, so make sure we make calls serially
        config.maxConcurrent = 1;


        ClientCommandSender sender = getServiceContainer().createClientCommandSender(server_endpoint, config);
        sender.startSending();
        remote_stream.setClientCommandSender(sender);


        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.