if (currentChannels < targetChannels) {
            // Add more channels
            establishAdditionalChannels();
        } else if (currentChannels > targetChannels) {
            // Remove excess channels
            removeExcessChannels(currentChannels - targetChannels);
        }
    }

    private void removeExcessChannels(int excessCount) {
        List<ChannelInfo> channelsToRemove = channels.values()

 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

        bb.putShort((short) 0);

        // Decode with exact length
        int decodedSize = referral.decode(testBuffer, 0, 24);
        assertEquals(24, decodedSize);

        // Decode with excess length
        Referral referral2 = new Referral();
        decodedSize = referral2.decode(testBuffer, 0, 512);
        assertEquals(24, decodedSize);
    }

    // Multiple Expanded Names Tests

    @Test

        
        if (currentChannels < targetChannels) {
            // Add more channels
            establishAdditionalChannels();
        } else if (currentChannels > targetChannels) {
            // Remove excess channels
            removeExcessChannels(currentChannels - targetChannels);
        }
    }
    
    public void shutdown() {
        scheduler.shutdown();
        

 * in compliance with the License. You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License
 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express

Joel Sing <******@****.***> 1718380829 +1000

 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language

     * @throws FessSystemException if no access token is available
     */
    public String getServerPath() {
        return getSessionManager().getAttribute(Constants.SEARCH_ENGINE_API_ACCESS_TOKEN, String.class)
                .map(token -> ADMIN_SERVER + token)
                .orElseThrow(() -> new FessSystemException("Cannot create an access token."));
    }

    /**

            fieldRuleMap.put("access", "//address/item/access");
            fieldRuleMap.put("image", "//address/item/image/@file");
            fieldRuleMap.put("email", "//address/item/access[@kind='email']");
            fieldRuleMap.put("url", "//address/item/access[@kind='url']");
            fieldRuleMap.put("tel", "//address/item/access[@kind='tel']");
            xmlTransformer.setFieldRuleMap(fieldRuleMap);

 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language