com.sleepycat.je.rep.impl
Class TextProtocol.MessageExchange

java.lang.Object
  extended by com.sleepycat.je.rep.impl.TextProtocol.MessageExchange
All Implemented Interfaces:
Runnable
Enclosing class:
TextProtocol

public class TextProtocol.MessageExchange
extends Object
implements Runnable

Use to parallelize message exchanges via Futures.


Field Summary
 Exception exception
           
 InetSocketAddress target
           
 
Constructor Summary
TextProtocol.MessageExchange(InetSocketAddress target, String serviceName, TextProtocol.RequestMessage request)
           
 
Method Summary
 TextProtocol.RequestMessage getRequestMessage()
           
 TextProtocol.ResponseMessage getResponseMessage()
           
 void run()
          Run a message exchange.
 void setResponseMessage(TextProtocol.ResponseMessage responseMessage)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

target

public final InetSocketAddress target

exception

public Exception exception
Constructor Detail

TextProtocol.MessageExchange

public TextProtocol.MessageExchange(InetSocketAddress target,
                                    String serviceName,
                                    TextProtocol.RequestMessage request)
Method Detail

run

public void run()
Run a message exchange. A successful exchange results in a response message being set. All failures result in the response message being null and an exception being set.

Specified by:
run in interface Runnable

setResponseMessage

public void setResponseMessage(TextProtocol.ResponseMessage responseMessage)

getResponseMessage

public TextProtocol.ResponseMessage getResponseMessage()

getRequestMessage

public TextProtocol.RequestMessage getRequestMessage()


Copyright (c) 2004-2010 Oracle. All rights reserved.