List of sendResponse() Examples

Examples of sendResponse()

ch.ethz.inf.vs.californium.network.Exchange.sendResponse()
Sends the specified response over the same endpoint as the request has arrived. @param response the response
com.hazelcast.client.ClientEndpoint.sendResponse()
com.hazelcast.spi.ResponseHandler.sendResponse()
com.willwinder.universalgcodesender.mockobjects.MockConnection.sendResponse()
gov.nist.javax.sip.ServerTransactionExt.sendResponse()
javax.sip.ServerTransaction.sendResponse()
sipit.net/show_bug.cgi?id=769"> http://bugs.sipit.net/show_bug.cgi?id=769 .
ACK Processing and final response retransmission:
If a Dialog is associated with the ServerTransaction then when the UAC sends the ACK ( the typical case for User Agents), the Application ( i.e. Listener ) will see a ServerTransaction corresponding to the ACK and the corresponding {@link Dialog} presented to it. The ACK will be presented to the Listener only once in this case. Retransmissions of the OK and filtering of ACK retransmission are the responsibility of the Dialog layer of this specification. However if no {@link Dialog} is associated with the INVITE Transaction, the ACK will be presentedto the Application with a null Dialog in the {@link RequestEvent} and there will be no Dialog associated with the ACK Transaction (i.e. {@link Transaction#getDialog()} returns null). In this case (when there is no Dialog associated with the original INVITE or ACK) the Application is responsible for retransmission of the OK for the INVITE if necessary (i.e. if it wants to manage its own dialog layer and function as a User Agent) and for dealing with retransmissions of the ACK. This requires that the three way handshake of an INVITE is managed by the UAS application and not the implementation of this specification.
Note that Responses created via {@link Dialog#createReliableProvisionalResponse(int)} should be sent using {@link Dialog#sendReliableProvisionalResponse(Response)} @param response the Response to send to the Request. @throws SipException if the SipProvider cannot send the Response for anyother reason. @throws InvalidArgumentException if the Response is created by{@link Dialog#createReliableProvisionalResponse(int)} andthe application attempts to use this method to send the response. @see Response
javax.sip.SipProvider.sendResponse()
Sends the Response statelessly, that is no transaction record is associated with this action. This method implies that the application is functioning as either a stateless proxy or a stateless UAS.
- Stateless proxy - A stateless proxy simply forwards every response it receives upstream and discards information about the response message once the message has been forwarded. A stateless proxy does not have any notion of a transaction.
- Stateless UAS - A stateless UAS does not maintain transaction state. It replies to requests normally, but discards any state that would ordinarily be retained by a UAS after a response has been sent. If a stateless UAS receives a retransmission of a request, it regenerates the response and resends it, just as if it were replying to the first instance of the request. A UAS cannot be stateless unless the request processing for that method would always result in the same response if the requests are identical. Stateless UAS's do not use a transaction layer; they receive requests directly from the transport layer and send responses directly to the transport layer.
@see Response @param response the Response to send statelessly. @throws SipException if the SipProvider cannot send the Response for any reason. @see Response
mongrel2.Mongrel2Handler.sendResponse()
Send a response to one or more requests. Convenience method for the sendResponse(Response, Request[]) method. @param response the response to send @param recipients one or more requests to receive the response. @throws IOException
org.apache.bookkeeper.proto.NIOServerFactory.Cnxn.sendResponse()
org.apache.qpid.restapi.HttpTransaction.sendResponse()
Send the content passed as a String as an HTTP response back to the client. @param status the HTTP status code e.g. 200 for OK. @param mimeType the mimeType of the response content e.g. text/plain, text/xml, image/jpeg etc. @param content the content of the response passed as a String.
org.cafesip.sipunit.SubscribeSession.sendResponse()
org.ice.http.HttpResponse.sendResponse()
org.nasutekds.server.api.ClientConnection.sendResponse()
Sends a response to the client based on the information in the provided operation. @param operation The operation for which to send the response.
voldemort.rest.DeleteResponseSender.sendResponse()
voldemort.rest.GetAllResponseSender.sendResponse()
Sends nested multipart response. Outer multipart wraps all the keys requested. Each key has a separate multipart for the versioned values.
voldemort.rest.GetMetadataResponseSender.sendResponse()
Sends a normal HTTP response containing the serialization information in a XML format
voldemort.rest.GetResponseSender.sendResponse()
Sends a multipart response. Each body part represents a versioned value of the given key. @throws IOException @throws MessagingException
voldemort.rest.GetVersionResponseSender.sendResponse()
voldemort.rest.PutResponseSender.sendResponse()

Examples of org.cafesip.sipunit.SubscribeSession.sendResponse()

    assertEquals(getAliceUri(), watcher.getStringValue());
    assertEquals(Status.ACTIVE, watcher.getStatus());
    
    
    tx = presenceSession.waitForNotify(); // 9
    presenceSession.sendResponse(Response.OK, tx); // 10
    
    
    subscribe = presenceSession.newSubsequentSubscribe(0); // 11
    presenceSession.sendRequest(subscribe, Response.OK); // 12

View Full Code Here

Examples of org.cafesip.sipunit.SubscribeSession.sendResponse()

    assertEquals(Event.TIMEOUT, watcher.getEvent());
    assertEquals(getAliceUri(), watcher.getStringValue());
    assertEquals(Status.TERMINATED, watcher.getStatus());
    
    tx = presenceSession.waitForNotify(); // 15
    presenceSession.sendResponse(Response.OK, tx); // 16
    
    subscribe = winfoSession.newSubsequentSubscribe(0); // 17
    winfoSession.sendRequest(subscribe, Response.OK); //18
    
    tx = winfoSession.waitForNotify(); // 19

View Full Code Here

Examples of org.cafesip.sipunit.SubscribeSession.sendResponse()

    SubscribeSession presenceSession = new SubscribeSession(getAlicePhone(), "presence");
    Request subscribe = presenceSession.newInitialSubscribe(100, getBobUri()); // 1
    presenceSession.sendRequest(subscribe, Response.OK); // 2


    ServerTransaction tx = presenceSession.waitForNotify(); // 3
    presenceSession.sendResponse(Response.OK, tx); // 4
    
    SubscribeSession winfoSession = new SubscribeSession(getBobPhone(), "presence.winfo"); // 5
    subscribe = winfoSession.newInitialSubscribe(0, getBobUri());
    winfoSession.sendRequest(subscribe, Response.OK); // 6

View Full Code Here

Examples of org.cafesip.sipunit.SubscribeSession.sendResponse()

    winfoSession.sendRequest(subscribe, Response.OK); // 6
    
    tx = winfoSession.waitForNotify(); // 7
    Request notify = tx.getRequest();
    //System.out.println(notify);
    winfoSession.sendResponse(Response.OK, tx); // 8 
    SubscriptionStateHeader subState = (SubscriptionStateHeader) notify.getHeader(SubscriptionStateHeader.NAME);
    assertEquals(SubscriptionStateHeader.TERMINATED.toLowerCase(), subState.getState().toLowerCase());
    assertEquals(WatcherInfoEventPackage.NAME, ((EventHeader) notify.getHeader(EventHeader.NAME)).getEventType());
    Watcherinfo watcherinfo = getWatcherinfo(notify);
    assertEquals(0, watcherinfo.getVersion().intValue());

View Full Code Here

Examples of org.cafesip.sipunit.SubscribeSession.sendResponse()

    Request subscribe = presenceSession.newInitialSubscribe(100, getBobUri()); // 3
    presenceSession.sendRequest(subscribe, Response.OK); // 4


    ServerTransaction tx = presenceSession.waitForNotify(); // 5
    //System.out.println("3:\n" + tx.getRequest());
    presenceSession.sendResponse(Response.OK, tx); // 6
    Presence presence = getPresence(tx.getRequest());
    assertEquals(Basic.OPEN, presence.getTupleArray()[0].getStatus().getBasic());
    
    
    SubscribeSession winfoSession = new SubscribeSession(getBobPhone(), "presence.winfo"); // 7

View Full Code Here

Examples of org.ice.http.HttpResponse.sendResponse()

        httpResponse.setStatus(500);
        httpResponse.setException(ex);
      }
    }
    
    httpResponse.sendResponse();
    httpResponse = null;
  }


  /**
   * Dispatch request to the specified module

View Full Code Here

Examples of org.nasutekds.server.api.ClientConnection.sendResponse()


      // Log the bind response.
      logBindResponse(this);


      // Send the bind response to the client.
      clientConnection.sendResponse(this);


      // If the bind processing is finished, then unset the "bind in progress"
      // flag to allow other operations to be processed on the connection.
      if (getResultCode() != ResultCode.SASL_BIND_IN_PROGRESS)
      {

View Full Code Here

Examples of voldemort.rest.DeleteResponseSender.sendResponse()

                            boolean isDeleted = this.storeClient.deleteWithCustomTimeout(this.requestObject);
                            if(isDeleted) {
                                DeleteResponseSender responseConstructor = new DeleteResponseSender(messageEvent,
                                                                                                    this.storeClient.getStoreName(),
                                                                                                    this.requestObject.getKey());
                                responseConstructor.sendResponse(this.coordinatorPerfStats,
                                                                 true,
                                                                 this.requestObject.getRequestOriginTimeInMs());


                                if(logger.isDebugEnabled()) {
                                    logger.debug("DELETE request successful !");

View Full Code Here

Examples of voldemort.rest.GetAllResponseSender.sendResponse()

                                                                    "Error when doing getall. Keys do not exist.");
                            } else {
                                GetAllResponseSender responseConstructor = new GetAllResponseSender(messageEvent,
                                                                                                    versionedResponses,
                                                                                                    this.storeClient.getStoreName());
                                responseConstructor.sendResponse(this.coordinatorPerfStats,
                                                                 true,
                                                                 this.requestObject.getRequestOriginTimeInMs());


                                if(logger.isDebugEnabled()) {
                                    logger.debug("GET ALL successful !");

View Full Code Here

Examples of voldemort.rest.GetAllResponseSender.sendResponse()


                            PutResponseSender responseConstructor = new PutResponseSender(messageEvent,
                                                                                          successfulPutVC,
                                                                                          this.storeClient.getStoreName(),
                                                                                          this.requestObject.getKey());
                            responseConstructor.sendResponse(this.coordinatorPerfStats,
                                                             true,
                                                             this.requestObject.getRequestOriginTimeInMs());


                            if(logger.isDebugEnabled()) {
                                logger.debug("PUT successful !");

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.