modules/andes-core/broker/src/main/java/org/wso2/andes/store/rdbms/RDBMSMessageStoreImpl.java
private void addExpiryTableEntryToBatch(PreparedStatement preparedStatement, AndesMessageMetadata metadata)
            throws SQLException {
        preparedStatement.setLong(1, metadata.getMessageID());
        preparedStatement.setLong(2, metadata.getExpirationTime());
        preparedStatement.setString(3, metadata.getStorageQueueName());
        preparedStatement.addBatch();
    }
/**
     * Does a batch update on the given prepared statement to add entries to expiry table.
     *
     * @param preparedStatement PreparedStatement. Object is not closed within the method
     * @param metadata          AndesMessageMetadata
     * @throws SQLException
     */
Does a batch update on the given prepared statement to add entries to expiry table.
Does a batch update on the given prepared statement to add entries to expiry table .
private void addExpiryTableEntryToBatch(PreparedStatement preparedStatement, AndesMessageMetadata metadata)
            throws SQLException {
        preparedStatement.setLong(1, metadata.getMessageID());
        preparedStatement.setLong(2, metadata.getExpirationTime());
        preparedStatement.setString(3, metadata.getStorageQueueName());
        preparedStatement.addBatch();
    }
private void addExpiryTableEntryToBatch ( PreparedStatement preparedStatement , AndesMessageMetadata metadata ) throws SQLException { preparedStatement . setLong ( 1 , metadata . getMessageID ( ) ) ; preparedStatement . setLong ( 2 , metadata . getExpirationTime ( ) ) ; preparedStatement . setString ( 3 , metadata . getStorageQueueName ( ) ) ; preparedStatement . addBatch ( ) ; }
Does a batch update on the given prepared statement to add entries to expiry table.
Does a batch update on the given prepared statement to add entries to expiry table .