本文整理了Java中org.apache.thrift.protocol.TProtocolException.getMessage()方法的一些代码示例，展示了TProtocolException.getMessage()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TProtocolException.getMessage()方法的具体详情如下：
包路径：org.apache.thrift.protocol.TProtocolException
类名称：TProtocolException
方法名：getMessage

TProtocolException.getMessage介绍

暂无

代码示例

代码示例来源：origin: apache/hive

iprot.readMessageEnd();
TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR,
  e.getMessage());
oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));
x.write(oprot);

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  write_args args = new write_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("write", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  write_result result = new write_result();
  result.success = iface_.write(args.stream, args.data);
  
  oprot.writeMessageBegin(new TMessage("write", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  truncate_args args = new truncate_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("truncate", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  truncate_result result = new truncate_result();
  result.success = iface_.truncate(args.stream, args.dlsn, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("truncate", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  writeBulkWithContext_args args = new writeBulkWithContext_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("writeBulkWithContext", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  writeBulkWithContext_result result = new writeBulkWithContext_result();
  result.success = iface_.writeBulkWithContext(args.stream, args.data, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("writeBulkWithContext", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  create_args args = new create_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("create", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  create_result result = new create_result();
  result.success = iface_.create(args.stream, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("create", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  heartbeatWithOptions_args args = new heartbeatWithOptions_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("heartbeatWithOptions", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  heartbeatWithOptions_result result = new heartbeatWithOptions_result();
  result.success = iface_.heartbeatWithOptions(args.stream, args.ctx, args.options);
  
  oprot.writeMessageBegin(new TMessage("heartbeatWithOptions", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  writeWithContext_args args = new writeWithContext_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("writeWithContext", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  writeWithContext_result result = new writeWithContext_result();
  result.success = iface_.writeWithContext(args.stream, args.data, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("writeWithContext", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  release_args args = new release_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("release", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  release_result result = new release_result();
  result.success = iface_.release(args.stream, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("release", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  delete_args args = new delete_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("delete", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  delete_result result = new delete_result();
  result.success = iface_.delete(args.stream, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("delete", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  handshakeWithClientInfo_args args = new handshakeWithClientInfo_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("handshakeWithClientInfo", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  handshakeWithClientInfo_result result = new handshakeWithClientInfo_result();
  result.success = iface_.handshakeWithClientInfo(args.clientInfo);
  
  oprot.writeMessageBegin(new TMessage("handshakeWithClientInfo", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  heartbeat_args args = new heartbeat_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("heartbeat", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  heartbeat_result result = new heartbeat_result();
  result.success = iface_.heartbeat(args.stream, args.ctx);
  
  oprot.writeMessageBegin(new TMessage("heartbeat", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  setAcceptNewStream_args args = new setAcceptNewStream_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("setAcceptNewStream", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  setAcceptNewStream_result result = new setAcceptNewStream_result();
  iface_.setAcceptNewStream(args.enabled);
  
  oprot.writeMessageBegin(new TMessage("setAcceptNewStream", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
 {
  handshake_args args = new handshake_args();
  try {
   args.read(iprot);
  } catch (TProtocolException e) {
   iprot.readMessageEnd();
   TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
   oprot.writeMessageBegin(new TMessage("handshake", TMessageType.EXCEPTION, seqid));
   x.write(oprot);
   oprot.writeMessageEnd();
   oprot.getTransport().flush();
   return;
  }
  iprot.readMessageEnd();
  handshake_result result = new handshake_result();
  result.success = iface_.handshake();
  
  oprot.writeMessageBegin(new TMessage("handshake", TMessageType.REPLY, seqid));
  result.write(oprot);
  oprot.writeMessageEnd();
  oprot.getTransport().flush();
 }
}

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);

代码示例来源：origin: twitter/distributedlog

try {
 iprot.readMessageEnd();
 TApplicationException x = new TApplicationException(TApplicationException.PROTOCOL_ERROR, e.getMessage());
 TMemoryBuffer memoryBuffer = new TMemoryBuffer(512);
 TProtocol oprot = protocolFactory.getProtocol(memoryBuffer);