com.google.protobuf.ByteString#toString ( )源码实例Demo

下面列出了com.google.protobuf.ByteString#toString ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： heroic 文件： SeriesKeyEncoding.java

public SeriesKey decode(ByteString key, Transform<String, Series> transform) throws Exception {
    final String string = key.toString(Charsets.UTF_8);
    final List<String> parts = SPLITTER.splitToList(string);

    if (parts.size() != 3) {
        throw new IllegalArgumentException("Not a valid key: " + string);
    }

    final String category = parts.get(0);

    if (!this.category.equals(category)) {
        throw new IllegalArgumentException(
            "Key is in the wrong category (expected " + this.category + "): " + string);
    }

    final LocalDate date = LocalDate.parse(parts.get(1));
    final Series series = transform.transform(parts.get(2));
    return new SeriesKey(date, series);
}

源代码2 项目： clarity 文件： Util.java

public static String convertByteString(ByteString s, String charsetName) {
    try {
        return s.toString(charsetName);
    } catch (UnsupportedEncodingException e) {
        Util.uncheckedThrow(e);
        return null;
    }
}

源代码3 项目： wind-im 文件： U2MessageTextHandler.java

public Boolean handle(Command command) {
	try {
		int type = command.getMsgType();

		if (CoreProto.MsgType.TEXT_VALUE == type) {
			ImCtsMessageProto.ImCtsMessageRequest request = ImCtsMessageProto.ImCtsMessageRequest
					.parseFrom(command.getParams());
			String siteUserId = command.getSiteUserId();
			String proxySiteUserId = request.getText().getSiteUserId();
			String siteFriendId = request.getText().getSiteFriendId();
			String msgId = request.getText().getMsgId();
			ByteString byteStr = request.getText().getText();
			String msgText = byteStr.toString(Charset.forName("UTF-8"));
			command.setSiteFriendId(siteFriendId);

			long msgTime = System.currentTimeMillis();
			U2MessageBean u2Bean = new U2MessageBean();
			u2Bean.setMsgId(msgId);
			u2Bean.setMsgType(type);
			u2Bean.setSiteUserId(siteFriendId);
			u2Bean.setSendUserId(command.isProxy() ? proxySiteUserId : siteUserId);
			u2Bean.setReceiveUserId(siteFriendId);
			u2Bean.setContent(msgText);
			u2Bean.setMsgTime(msgTime);

			LogUtils.requestDebugLog(logger, command, u2Bean.toString());

			boolean success = messageDao.saveU2Message(u2Bean);

			if (success && command.isProxy()) {
				U2MessageBean proxyBean = new U2MessageBean();
				proxyBean.setMsgId(buildU2MsgId(proxySiteUserId));
				proxyBean.setMsgType(type);
				proxyBean.setSiteUserId(proxySiteUserId);
				proxyBean.setSendUserId(proxySiteUserId);
				proxyBean.setReceiveUserId(siteFriendId);
				proxyBean.setContent(msgText);
				proxyBean.setMsgTime(msgTime);
				messageDao.saveU2Message(proxyBean);
			}

			msgStatusResponse(command, msgId, msgTime, success);

			return success;
		}

		return true;
	} catch (Exception e) {
		LogUtils.requestErrorLog(logger, command, this.getClass(), e);
	}

	return false;
}

源代码4 项目： openzaly 文件： U2MessageTextHandler.java

public Boolean handle(Command command) {
	try {
		int type = command.getMsgType();

		if (CoreProto.MsgType.TEXT_VALUE == type) {
			ImCtsMessageProto.ImCtsMessageRequest request = ImCtsMessageProto.ImCtsMessageRequest
					.parseFrom(command.getParams());
			String siteUserId = command.getSiteUserId();
			String proxySiteUserId = request.getText().getSiteUserId();
			String siteFriendId = request.getText().getSiteFriendId();
			String msgId = request.getText().getMsgId();
			ByteString byteStr = request.getText().getText();
			String msgText = byteStr.toString(Charset.forName("UTF-8"));
			command.setSiteFriendId(siteFriendId);

			long msgTime = System.currentTimeMillis();
			U2MessageBean u2Bean = new U2MessageBean();
			u2Bean.setMsgId(msgId);
			u2Bean.setMsgType(type);
			u2Bean.setSiteUserId(siteFriendId);
			u2Bean.setSendUserId(command.isProxy() ? proxySiteUserId : siteUserId);
			u2Bean.setReceiveUserId(siteFriendId);
			u2Bean.setContent(msgText);
			u2Bean.setMsgTime(msgTime);

			LogUtils.requestDebugLog(logger, command, u2Bean.toString());

			boolean success = messageDao.saveU2Message(u2Bean);

			if (success && command.isProxy()) {
				U2MessageBean proxyBean = new U2MessageBean();
				proxyBean.setMsgId(buildU2MsgId(proxySiteUserId));
				proxyBean.setMsgType(type);
				proxyBean.setSiteUserId(proxySiteUserId);
				proxyBean.setSendUserId(proxySiteUserId);
				proxyBean.setReceiveUserId(siteFriendId);
				proxyBean.setContent(msgText);
				proxyBean.setMsgTime(msgTime);
				messageDao.saveU2Message(proxyBean);
			}

			msgStatusResponse(command, msgId, msgTime, success);

			return success;
		}

		return true;
	} catch (Exception e) {
		LogUtils.requestErrorLog(logger, command, this.getClass(), e);
	}

	return false;
}

源代码5 项目： openzaly 文件： U2MessageTextHandler.java

public Boolean handle(Command command) {
	try {
		int type = command.getMsgType();

		if (CoreProto.MsgType.TEXT_VALUE == type) {
			ImCtsMessageProto.ImCtsMessageRequest request = ImCtsMessageProto.ImCtsMessageRequest
					.parseFrom(command.getParams());
			String siteUserId = command.getSiteUserId();
			String proxySiteUserId = request.getText().getSiteUserId();
			String siteFriendId = request.getText().getSiteFriendId();
			String msgId = request.getText().getMsgId();
			ByteString byteStr = request.getText().getText();
			String msgText = byteStr.toString(Charset.forName("UTF-8"));
			command.setSiteFriendId(siteFriendId);

			long msgTime = System.currentTimeMillis();
			U2MessageBean u2Bean = new U2MessageBean();
			u2Bean.setMsgId(msgId);
			u2Bean.setMsgType(type);
			u2Bean.setSiteUserId(siteFriendId);
			u2Bean.setSendUserId(command.isProxy() ? proxySiteUserId : siteUserId);
			u2Bean.setReceiveUserId(siteFriendId);
			u2Bean.setContent(msgText);
			u2Bean.setMsgTime(msgTime);

			LogUtils.requestDebugLog(logger, command, u2Bean.toString());

			boolean success = messageDao.saveU2Message(u2Bean);

			if (success && command.isProxy()) {
				U2MessageBean proxyBean = new U2MessageBean();
				proxyBean.setMsgId(buildU2MsgId(proxySiteUserId));
				proxyBean.setMsgType(type);
				proxyBean.setSiteUserId(proxySiteUserId);
				proxyBean.setSendUserId(proxySiteUserId);
				proxyBean.setReceiveUserId(siteFriendId);
				proxyBean.setContent(msgText);
				proxyBean.setMsgTime(msgTime);
				messageDao.saveU2Message(proxyBean);
			}

			msgStatusResponse(command, msgId, msgTime, success);

			return success;
		}

		return true;
	} catch (Exception e) {
		LogUtils.requestErrorLog(logger, command, this.getClass(), e);
	}

	return false;
}

源代码6 项目： DataflowTemplates 文件： TestUtils.java

static String toString(ByteString byteString) {
  return byteString.toString(Charset.forName("UTF-8"));
}