com.sleepycat.je.rep.impl
Class TextProtocol.MessageExchange
java.lang.Object
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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
target
public final InetSocketAddress target
exception
public Exception exception
TextProtocol.MessageExchange
public TextProtocol.MessageExchange(InetSocketAddress target,
String serviceName,
TextProtocol.RequestMessage request)
run
public void run()
- Specified by:
run
in interface Runnable
messageExchange
public void messageExchange()
- 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.
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.