public void putMessage()

in java/core/src/main/java/com/aliyun/openservices/tablestore/agent/memory/MemoryStoreImpl.java [409:434]

• 25 lines of code
• 4 McCabe index (conditional complexity)

    public void putMessage(Message message) {
        ValidationUtils.ensureNotNull(message, "message");
        ValidationUtils.ensureNotNull(message.getSessionId(), "sessionId");
        ValidationUtils.ensureNotNull(message.getMessageId(), "messageId");
        ValidationUtils.ensureGreaterThanAndEqualZero(message.getCreateTime(), "createTime");

        PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
        primaryKeyBuilder.addPrimaryKeyColumn(Message.MESSAGE_SESSION_ID, PrimaryKeyValue.fromString(message.getSessionId()));
        primaryKeyBuilder.addPrimaryKeyColumn(Message.MESSAGE_CREATE_TIME, PrimaryKeyValue.fromLong(message.getCreateTime()));
        primaryKeyBuilder.addPrimaryKeyColumn(Message.MESSAGE_MESSAGE_ID, PrimaryKeyValue.fromString(message.getMessageId()));
        PrimaryKey primaryKey = primaryKeyBuilder.build();
        RowPutChange rowPutChange = new RowPutChange(messageTableName, primaryKey);
        List<Column> columns = TablestoreHelper.metadataToColumns(message.getMetadata());
        if (message.getContent() != null) {
            columns.add(new Column(Message.MESSAGE_CONTENT, ColumnValue.fromString(message.getContent())));
        }
        rowPutChange.addColumns(columns);
        try {
            client.putRow(new PutRowRequest(rowPutChange));
            if (log.isDebugEnabled()) {
                log.debug("put message:{}", message);
            }
        } catch (Exception e) {
            throw Exceptions.runtimeThrowable(String.format("put message:%s failed", message), e);
        }
    }