List of sendAndReceive() Examples

Examples of sendAndReceive()

br.com.visualmidia.core.server.Communicate.sendAndReceive()
ca.uhn.hl7v2.app.Initiator.sendAndReceive()
Sends a message to a responder system, receives the reply, and returns the reply as a Message object. This method is thread-safe - multiple threads can share an Initiator and call this method. Responses are returned to the calling thread on the basis of message ID.
com.aelitis.net.udp.uc.PRUDPPacketHandler.sendAndReceive()
Asynchronous send and receive @param request_packet @param destination_address @param receiver @throws PRUDPPacketHandlerException
org.apache.vinci.transport.BaseClient.sendAndReceive()
Takes a transportable object, sends it across the connection, then retrieves the response and returns it. @param in The query frame. @return A transportable representing the result, its specific type determined by the factoryprovided through BaseClient's constructor. @exception IOException thrown by the underlying socket IO (e.g. due to connection timeout). @exception ServiceException thrown if the server threw ServiceException or returned an ErrorFrame. @pre in != null @pre getHost() != null
org.apache.vinci.transport.VinciClient.sendAndReceive()
Convenience method for "one-shot"/single-query connections. Equivalent of manually creating a new VinciClient(), calling (non-static) sendAndReceive, and then closing the client. @throws IllegalStateException if the VNS host has not been specified. @pre in != null @pre service_name != null @pre factory != null
org.springframework.integration.core.MessagingTemplate.sendAndReceive()

Examples of org.apache.vinci.transport.VinciClient.sendAndReceive()

  public Transportable sendAndReceive(Transportable in, String service_name,
          TransportableFactory factory) throws IOException, ServiceException, ServiceDownException,
          VNSException {
    VinciClient tempClient = new VinciClient(service_name, factory, this);
    try {
      return tempClient.sendAndReceive(in);
    } finally {
      tempClient.close();
    }
  }

View Full Code Here

Examples of org.apache.vinci.transport.VinciClient.sendAndReceive()

  public Transportable sendAndReceive(Transportable in, String service_name,
          TransportableFactory factory, int socket_timeout) throws IOException, ServiceException {
    VinciClient tempClient = new VinciClient(service_name, factory, this);
    tempClient.setSocketTimeout(socket_timeout);
    try {
      return tempClient.sendAndReceive(in);
    } finally {
      tempClient.close();
    }
  }

View Full Code Here

Examples of org.apache.vinci.transport.VinciClient.sendAndReceive()

          TransportableFactory factory, int socket_timeout, int connect_timeout)
          throws IOException, ServiceException {
    VinciClient tempClient = new VinciClient(service_name, factory, this, connect_timeout);
    tempClient.setSocketTimeout(socket_timeout);
    try {
      return tempClient.sendAndReceive(in);
    } finally {
      tempClient.close();
    }
  }

View Full Code Here

Examples of org.springframework.integration.core.MessagingTemplate.sendAndReceive()

  public @ResponseBody String simple(@RequestBody String message) {
    
    Message<String> operation = MessageBuilder.withPayload(message).build();
    MessagingTemplate template = new MessagingTemplate();
    template.setReceiveTimeout(1000);
    Message response = template.sendAndReceive(inOperationChannel, operation);
    return response != null ? response.getPayload().toString() : null;
    
  }
}

View Full Code Here

0 1 2

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.