001/*-
002 * #%L
003 * HAPI FHIR - Server Framework
004 * %%
005 * Copyright (C) 2014 - 2024 Smile CDR, Inc.
006 * %%
007 * Licensed under the Apache License, Version 2.0 (the "License");
008 * you may not use this file except in compliance with the License.
009 * You may obtain a copy of the License at
010 *
011 *      http://www.apache.org/licenses/LICENSE-2.0
012 *
013 * Unless required by applicable law or agreed to in writing, software
014 * distributed under the License is distributed on an "AS IS" BASIS,
015 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
016 * See the License for the specific language governing permissions and
017 * limitations under the License.
018 * #L%
019 */
020package ca.uhn.fhir.subscription;
021
022public class SubscriptionConstants {
023
024        /**
025         * The number of threads used in subscription channel processing
026         */
027        public static final int MATCHING_CHANNEL_CONCURRENT_CONSUMERS = 5;
028
029        public static final int DELIVERY_CHANNEL_CONCURRENT_CONSUMERS = 2;
030
031        /**
032         * The maximum number of subscriptions that can be active at once
033         */
034        public static final int MAX_SUBSCRIPTION_RESULTS = 10000;
035
036        /**
037         * The size of the queue used for sending resources to the subscription matching processor and by each subscription delivery queue
038         */
039        public static final int DELIVERY_EXECUTOR_QUEUE_SIZE = 1000;
040
041        public static final String SUBSCRIPTION_STATUS = "Subscription.status";
042        public static final String SUBSCRIPTION_TYPE = "Subscription.channel.type";
043        // These STATUS codes are unchanged from DSTU2 Subscription onwards
044        public static final String REQUESTED_STATUS = "requested";
045        public static final String ACTIVE_STATUS = "active";
046        public static final String ERROR_STATUS = "error";
047        public static final String SUBSCRIPTION_TOPIC_PROFILE_URL =
048                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-subscription";
049        public static final String SUBSCRIPTION_TOPIC_FILTER_URL =
050                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-filter-criteria";
051        public static final String SUBSCRIPTION_TOPIC_CHANNEL_HEARTBEAT_PERIOD_URL =
052                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-heartbeat-period";
053        public static final String SUBSCRIPTION_TOPIC_CHANNEL_TIMEOUT_URL =
054                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-timeout";
055        public static final String SUBSCRIPTION_TOPIC_CHANNEL_MAX_COUNT =
056                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-max-count";
057        public static final String SUBSCRIPTION_TOPIC_CHANNEL_PAYLOAD_CONTENT =
058                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-payload-content";
059        public static final String SUBSCRIPTION_TOPIC_STATUS =
060                        "http://hl7.org/fhir/uv/subscriptions-backport/StructureDefinition/backport-subscription-status-r4";
061}