/**
* Autogenerated by Thrift Compiler (0.9.2)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package com.gbcom.thrift.idl;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
import org.apache.thrift.scheme.TupleScheme;
import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
import org.apache.thrift.async.AsyncMethodCallback;
import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.util.HashMap;
import java.util.EnumMap;
import java.util.Set;
import java.util.HashSet;
import java.util.EnumSet;
import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-1-9")
public class JwifiRPCService {
public interface Iface {
public String dispatch(String obj, String type, String params) throws org.apache.thrift.TException;
public String asyncDispatch(String obj, String type, String params) throws org.apache.thrift.TException;
public String gather(String obj, String guide) throws org.apache.thrift.TException;
public String forceOffline(String obj, String params) throws org.apache.thrift.TException;
public String reboot(String obj) throws org.apache.thrift.TException;
}
public interface AsyncIface {
public void dispatch(String obj, String type, String params, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void asyncDispatch(String obj, String type, String params, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void gather(String obj, String guide, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void forceOffline(String obj, String params, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void reboot(String obj, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
}
public static class Client extends org.apache.thrift.TServiceClient implements Iface {
public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
public Factory() {}
public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
return new Client(prot);
}
public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
return new Client(iprot, oprot);
}
}
public Client(org.apache.thrift.protocol.TProtocol prot)
{
super(prot, prot);
}
public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
super(iprot, oprot);
}
public String dispatch(String obj, String type, String params) throws org.apache.thrift.TException
{
send_dispatch(obj, type, params);
return recv_dispatch();
}
public void send_dispatch(String obj, String type, String params) throws org.apache.thrift.TException
{
dispatch_args args = new dispatch_args();
args.setObj(obj);
args.setType(type);
args.setParams(params);
sendBase("dispatch", args);
}
public String recv_dispatch() throws org.apache.thrift.TException
{
dispatch_result result = new dispatch_result();
receiveBase(result, "dispatch");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "dispatch failed: unknown result");
}
public String asyncDispatch(String obj, String type, String params) throws org.apache.thrift.TException
{
send_asyncDispatch(obj, type, params);
return recv_asyncDispatch();
}
public void send_asyncDispatch(String obj, String type, String params) throws org.apache.thrift.TException
{
asyncDispatch_args args = new asyncDispatch_args();
args.setObj(obj);
args.setType(type);
args.setParams(params);
sendBase("asyncDispatch", args);
}
public String recv_asyncDispatch() throws org.apache.thrift.TException
{
asyncDispatch_result result = new asyncDispatch_result();
receiveBase(result, "asyncDispatch");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "asyncDispatch failed: unknown result");
}
public String gather(String obj, String guide) throws org.apache.thrift.TException
{
send_gather(obj, guide);
return recv_gather();
}
public void send_gather(String obj, String guide) throws org.apache.thrift.TException
{
gather_args args = new gather_args();
args.setObj(obj);
args.setGuide(guide);
sendBase("gather", args);
}
public String recv_gather() throws org.apache.thrift.TException
{
gather_result result = new gather_result();
receiveBase(result, "gather");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "gather failed: unknown result");
}
public String forceOffline(String obj, String params) throws org.apache.thrift.TException
{
send_forceOffline(obj, params);
return recv_forceOffline();
}
public void send_forceOffline(String obj, String params) throws org.apache.thrift.TException
{
forceOffline_args args = new forceOffline_args();
args.setObj(obj);
args.setParams(params);
sendBase("forceOffline", args);
}
public String recv_forceOffline() throws org.apache.thrift.TException
{
forceOffline_result result = new forceOffline_result();
receiveBase(result, "forceOffline");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "forceOffline failed: unknown result");
}
public String reboot(String obj) throws org.apache.thrift.TException
{
send_reboot(obj);
return recv_reboot();
}
public void send_reboot(String obj) throws org.apache.thrift.TException
{
reboot_args args = new reboot_args();
args.setObj(obj);
sendBase("reboot", args);
}
public String recv_reboot() throws org.apache.thrift.TException
{
reboot_result result = new reboot_result();
receiveBase(result, "reboot");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "reboot failed: unknown result");
}
}
public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface {
public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> {
private org.apache.thrift.async.TAsyncClientManager clientManager;
private org.apache.thrift.protocol.TProtocolFactory protocolFactory;
public Factory(org
没有合适的资源?快使用搜索试试~ 我知道了~
消息分发框架(基于JAVA阻塞队列实现、 生产者消费者模型)
共444个文件
class:218个
java:105个
jar:68个
需积分: 50 64 下载量 10 浏览量
2017-05-16
15:39:10
上传
评论 1
收藏 25.84MB ZIP 举报
温馨提示
消息分发框架,基于java阻塞队列实现,生产者消费者模型 可用于任务分发,服务器消息消息,以及网络IO 性能优化,多线程
资源推荐
资源详情
资源评论
收起资源包目录
消息分发框架(基于JAVA阻塞队列实现、 生产者消费者模型) (444个子文件)
.project.bak 1KB
deploy.bat 284B
HttpClientUtil.class 13KB
JwifiRPCService$asyncDispatch_args.class 13KB
JwifiRPCService$dispatch_args.class 12KB
ServerControllerTest.class 12KB
DispatchController.class 12KB
JwifiRPCService$forceOffline_args.class 11KB
JwifiRPCService$gather_args.class 11KB
JwifiRPCService$asyncDispatch_result.class 10KB
JwifiRPCService$forceOffline_result.class 10KB
JwifiRPCService$dispatch_result.class 10KB
JwifiRPCService$reboot_result.class 10KB
JwifiRPCService$gather_result.class 10KB
JwifiRPCService$reboot_args.class 10KB
UserControllerStandaloneSetupTest.class 10KB
EpsdnUDP.class 9KB
BaseMultiActionController.class 8KB
UdpClientUtil.class 8KB
JobWrapperManager.class 6KB
JwifiRPCService$Client.class 6KB
GwebSyncJob.class 6KB
PengNorthServlet.class 6KB
HibernateDao.class 5KB
ThriftClientTest.class 5KB
JThriftServer.class 5KB
JobWrapper.class 5KB
LoginController.class 5KB
UserController.class 5KB
TaskDispatcher.class 4KB
ThriftServerTest.class 4KB
AbstractTaskProcess.class 4KB
DefaultUdpServer.class 4KB
JwifiRPCService$AsyncClient.class 4KB
FileServlet.class 4KB
DBTaskProcess.class 4KB
JwifiRPCServiceImpl.class 4KB
DefaultUdpServer$ServerHandler.class 4KB
DisruptorServer.class 4KB
UserControllerWebAppContextSetupTest.class 4KB
TransformUtil.class 4KB
JsonUtils.class 4KB
Message.class 4KB
JwifiRPCService$AsyncProcessor$asyncDispatch.class 4KB
JwifiRPCService$AsyncProcessor$forceOffline.class 3KB
JwifiRPCService$AsyncClient$asyncDispatch_call.class 3KB
JwifiRPCService$AsyncProcessor$dispatch.class 3KB
JwifiRPCService$AsyncClient$dispatch_call.class 3KB
InformPostProcess.class 3KB
JwifiRPCService$AsyncProcessor$gather.class 3KB
UdpTaskProcess.class 3KB
JwifiRPCService$AsyncClient$forceOffline_call.class 3KB
JwifiRPCService$AsyncProcessor$reboot.class 3KB
JwifiRPCService$asyncDispatch_args$_Fields.class 3KB
JwifiRPCService$AsyncClient$gather_call.class 3KB
JwifiRPCService$dispatch_args$_Fields.class 3KB
JwifiRPCService$forceOffline_args$_Fields.class 3KB
JwifiRPCService$AsyncClient$reboot_call.class 3KB
JwifiRPCService$asyncDispatch_result$_Fields.class 3KB
JwifiRPCService$forceOffline_result$_Fields.class 3KB
SysController.class 3KB
JwifiRPCService$gather_args$_Fields.class 3KB
JwifiRPCService$dispatch_result$_Fields.class 3KB
JwifiRPCService$gather_result$_Fields.class 3KB
JwifiRPCService$reboot_result$_Fields.class 3KB
JwifiRPCService$reboot_args$_Fields.class 3KB
JwifiRPCService$asyncDispatch_args$asyncDispatch_argsStandardScheme.class 3KB
MyConversionService.class 3KB
JwifiRPCService$AsyncProcessor$asyncDispatch$1.class 3KB
HTTPTaskProcess.class 3KB
JwifiRPCService$AsyncProcessor$forceOffline$1.class 3KB
HeartRequest.class 3KB
JwifiRPCService$dispatch_args$dispatch_argsStandardScheme.class 3KB
JwifiRPCService$AsyncProcessor$dispatch$1.class 3KB
DefaultUdpClient.class 3KB
JwifiRPCService$AsyncProcessor$gather$1.class 3KB
JwifiRPCService$AsyncProcessor$reboot$1.class 3KB
HTTPTask.class 3KB
JwifiRPCService$forceOffline_args$forceOffline_argsStandardScheme.class 3KB
User.class 3KB
JwifiRPCService$gather_args$gather_argsStandardScheme.class 3KB
JstlController.class 3KB
JwifiRPCService$asyncDispatch_result$asyncDispatch_resultStandardScheme.class 3KB
JwifiRPCService$forceOffline_result$forceOffline_resultStandardScheme.class 3KB
JwifiRPCService$AsyncProcessor.class 3KB
JwifiRPCService$dispatch_result$dispatch_resultStandardScheme.class 3KB
Hotspot.class 3KB
JwifiRPCService$gather_result$gather_resultStandardScheme.class 3KB
JwifiRPCService$reboot_result$reboot_resultStandardScheme.class 3KB
DefaultUdpServer$1.class 3KB
JwifiRPCService$reboot_args$reboot_argsStandardScheme.class 3KB
JwifiRPCService$Processor.class 3KB
TaskBase.class 3KB
TaskDispatcher$DispatcherTask.class 3KB
ClientConnectionRelease.class 3KB
JwifiRPCService$asyncDispatch_args$asyncDispatch_argsTupleScheme.class 3KB
TaskProcessManager.class 2KB
JwifiRPCService$dispatch_args$dispatch_argsTupleScheme.class 2KB
JwifiRPCService$Processor$asyncDispatch.class 2KB
HibernateDao$1.class 2KB
共 444 条
- 1
- 2
- 3
- 4
- 5
资源评论
INTRUSTION
- 粉丝: 9
- 资源: 26
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功