com.twitter.common.thrift.monitoring
Class TMonitoredProcessor

java.lang.Object
  extended by com.twitter.common.thrift.monitoring.TMonitoredProcessor
All Implemented Interfaces:
org.apache.thrift.TProcessor

public class TMonitoredProcessor
extends Object
implements org.apache.thrift.TProcessor

A TProcessor that joins a wrapped TProcessor with a monitor.


Constructor Summary
TMonitoredProcessor(org.apache.thrift.TProcessor wrapped, TMonitoredServerSocket monitoredServerSocket, RequestTracker<InetSocketAddress> monitor)
           
 
Method Summary
 boolean process(org.apache.thrift.protocol.TProtocol in, org.apache.thrift.protocol.TProtocol out)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TMonitoredProcessor

public TMonitoredProcessor(org.apache.thrift.TProcessor wrapped,
                           TMonitoredServerSocket monitoredServerSocket,
                           RequestTracker<InetSocketAddress> monitor)
Method Detail

process

public boolean process(org.apache.thrift.protocol.TProtocol in,
                       org.apache.thrift.protocol.TProtocol out)
                throws org.apache.thrift.TException
Specified by:
process in interface org.apache.thrift.TProcessor
Throws:
org.apache.thrift.TException