com.facebook.swift.service

Class ThriftServiceProcessorCustom

java.lang.Object

com.facebook.swift.service.ThriftServiceProcessor

com.facebook.swift.service.ThriftServiceProcessorCustom

All Implemented Interfaces:

com.facebook.nifty.processor.NiftyProcessor

@ThreadSafe
public class ThriftServiceProcessorCustom
extends com.facebook.swift.service.ThriftServiceProcessor

ThriftServiceProcessor子类，代码基本都是从父类复制过来， 只是在构造方法ThriftServiceProcessorCustom(ThriftCodecManager, List, List)中 用ThriftMethodProcessorCustom替换了ThriftMethodProcessor

Author:

guyadong

Constructor Summary

Constructors

Constructor and Description
ThriftServiceProcessorCustom(com.facebook.swift.codec.ThriftCodecManager codecManager, java.util.List<? extends com.facebook.swift.service.ThriftEventHandler> eventHandlers, java.util.List<?> services)
ThriftServiceProcessorCustom(com.facebook.swift.codec.ThriftCodecManager codecManager, java.util.List<? extends com.facebook.swift.service.ThriftEventHandler> eventHandlers, java.lang.Object... services)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,com.facebook.swift.service.ThriftMethodProcessor>	getMethods()
com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean>	process(org.apache.thrift.protocol.TProtocol in, org.apache.thrift.protocol.TProtocol out, com.facebook.nifty.core.RequestContext requestContext)
static org.apache.thrift.TApplicationException	writeApplicationException(org.apache.thrift.protocol.TProtocol outputProtocol, java.lang.String methodName, int sequenceId, int errorCode, java.lang.String errorMessage, java.lang.Throwable cause)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThriftServiceProcessorCustom

public ThriftServiceProcessorCustom(com.facebook.swift.codec.ThriftCodecManager codecManager,
                                    java.util.List<? extends com.facebook.swift.service.ThriftEventHandler> eventHandlers,
                                    java.lang.Object... services)

Parameters:

eventHandlers - event handlers to attach to services

services - the services to expose; services must be thread safe

ThriftServiceProcessorCustom

public ThriftServiceProcessorCustom(com.facebook.swift.codec.ThriftCodecManager codecManager,
                                    java.util.List<? extends com.facebook.swift.service.ThriftEventHandler> eventHandlers,
                                    java.util.List<?> services)

Method Detail

getMethods

public java.util.Map<java.lang.String,com.facebook.swift.service.ThriftMethodProcessor> getMethods()

Overrides:

getMethods in class com.facebook.swift.service.ThriftServiceProcessor

process

public com.google.common.util.concurrent.ListenableFuture<java.lang.Boolean> process(org.apache.thrift.protocol.TProtocol in,
                                                                                     org.apache.thrift.protocol.TProtocol out,
                                                                                     com.facebook.nifty.core.RequestContext requestContext)
                                                                              throws org.apache.thrift.TException

Specified by:

process in interface com.facebook.nifty.processor.NiftyProcessor

Overrides:

process in class com.facebook.swift.service.ThriftServiceProcessor

Throws:

org.apache.thrift.TException

writeApplicationException

public static org.apache.thrift.TApplicationException writeApplicationException(org.apache.thrift.protocol.TProtocol outputProtocol,
                                                                                java.lang.String methodName,
                                                                                int sequenceId,
                                                                                int errorCode,
                                                                                java.lang.String errorMessage,
                                                                                java.lang.Throwable cause)
                                                                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException