src/java/org/apache/cassandra/net/MessagingService.java
/**
     * Send a message to a given endpoint. This method adheres to the fire and forget
     * style messaging.
     * @param message messages to be sent.
     * @param to endpoint to which the message needs to be sent
     */
Send a message to a given endpoint. This method adheres to the fire and forget
style messaging.
@param message messages to be sent.
@param to endpoint to which the message needs to be sent
Send a message to a given endpoint . This method adheres to the fire and forget style messaging . @param message messages to be sent . @param to endpoint to which the message needs to be sent
public void sendOneWay(Message message, String id, InetAddress to)
    {
        if (logger_.isTraceEnabled())
            logger_.trace(FBUtilities.getBroadcastAddress() + " sending " + message.getVerb() + " to " + id + "@" + to);
        if ( message.getFrom().equals(to) )
        {
            receive(message, id);
            return;
        }
        Message processedMessage = SinkManager.processClientMessage(message, id, to);
        if (processedMessage == null)
        {
            return;
        }
        OutboundTcpConnection connection = getConnection(to, processedMessage);
        connection.enqueue(processedMessage, id);
    }
public void sendOneWay ( Message message , String id , InetAddress to ) { if ( logger_ . isTraceEnabled ( ) ) logger_ . trace ( FBUtilities . getBroadcastAddress ( ) + " sending " + message . getVerb ( ) + " to " + id + "@" + to ) ; if ( message . getFrom ( ) . equals ( to ) ) { receive ( message , id ) ; return ; } Message processedMessage = SinkManager . processClientMessage ( message , id , to ) ; if ( processedMessage == null ) { return ; } OutboundTcpConnection connection = getConnection ( to , processedMessage ) ; connection . enqueue ( processedMessage , id ) ; }
Send a message to a given endpoint.
Send a message to a given endpoint .
// do local deliveries // message sinks are a testing hook // get pooled connection (really, connection queue) // write it