#########################################################################
#
# Copyright (C) 2017 OSGeo
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#
#########################################################################
from django.conf import settings
from kombu import Queue
[docs]
geoserver_exchange = settings.GEOSERVER_EXCHANGE
[docs]
queue_all_events = Queue("broadcast", geoserver_exchange, routing_key="#")
[docs]
queue_email_events = Queue("email.events", geoserver_exchange, routing_key="email")
[docs]
queue_geoserver = Queue("all.geoserver", geoserver_exchange, routing_key="geoserver.#")
[docs]
queue_geoserver_catalog = Queue("geoserver.catalog", geoserver_exchange, routing_key="geoserver.catalog")
[docs]
queue_geoserver_data = Queue("geoserver.data", geoserver_exchange, routing_key="geoserver.catalog")
[docs]
queue_geoserver_events = Queue("geoserver.events", geoserver_exchange, routing_key="geonode.geoserver")
[docs]
queue_notifications_events = Queue("notifications.events", geoserver_exchange, routing_key="notifications")
[docs]
queue_dataset_viewers = Queue("geonode.layer.viewer", geoserver_exchange, routing_key="geonode.viewer")
[docs]
QUEUES = (
queue_all_events,
queue_email_events,
queue_geoserver,
queue_geoserver_catalog,
queue_geoserver_data,
queue_geoserver_events,
queue_notifications_events,
queue_dataset_viewers,
)