modules/andes-core/broker/src/main/java/org/wso2/andes/store/rdbms/RDBMSMessageStoreImpl.java
private void addContentToBatch(PreparedStatement preparedStatement, AndesMessagePart messagePart)
            throws SQLException {
        preparedStatement.setLong(1, messagePart.getMessageID());
        preparedStatement.setInt(2, messagePart.getOffset());
        preparedStatement.setBytes(3, messagePart.getData());
        preparedStatement.addBatch();
    }
/**
     * Adds message content to provided prepared statements batch.
     *
     * @param preparedStatement Prepared statement for storing message content
     * @param messagePart       message content to be stored
     * @throws SQLException
     */
Adds message content to provided prepared statements batch.
@param preparedStatement Prepared statement for storing message content
@param messagePart       message content to be stored
@throws SQLException
Adds message content to provided prepared statements batch . @param preparedStatement Prepared statement for storing message content @param messagePart message content to be stored @throws SQLException
private void addContentToBatch(PreparedStatement preparedStatement, AndesMessagePart messagePart)
            throws SQLException {
        preparedStatement.setLong(1, messagePart.getMessageID());
        preparedStatement.setInt(2, messagePart.getOffset());
        preparedStatement.setBytes(3, messagePart.getData());
        preparedStatement.addBatch();
    }
private void addContentToBatch ( PreparedStatement preparedStatement , AndesMessagePart messagePart ) throws SQLException { preparedStatement . setLong ( 1 , messagePart . getMessageID ( ) ) ; preparedStatement . setInt ( 2 , messagePart . getOffset ( ) ) ; preparedStatement . setBytes ( 3 , messagePart . getData ( ) ) ; preparedStatement . addBatch ( ) ; }
Adds message content to provided prepared statements batch.
Adds message content to provided prepared statements batch .