Source code for geonode.messaging

#########################################################################
#
# 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 geonode.notifications_helper import NotificationsAppConfigBase
from django.utils.translation import ugettext_noop as _


[docs]
connections = None


[docs]
producers = None


[docs]
url = None


[docs]
task_serializer = None


[docs]
broker_transport_options = None


[docs]
broker_socket_timeout = None


[docs]
connection = None




[docs]
class MessagingAppConfig(NotificationsAppConfigBase):

[docs]
    name = "geonode.messaging"



[docs]
    NOTIFICATIONS = (("message_received", _("Message received"), _("New message received in one of your threads")),)



[docs]
    def ready(self):
        super().ready()

        from kombu import pools
        from kombu import BrokerConnection

        global connections
        global producers
        global url
        global task_serializer
        global broker_transport_options
        global broker_socket_timeout
        global connection

        connections = pools.Connections(limit=100)
        producers = pools.Producers(limit=connections.limit)

        # run in-memory if broker is not available
        # see producer code for synchronous queue
        url = getattr(settings, "BROKER_URL", "memory://")
        task_serializer = getattr(settings, "CELERY_TASK_SERIALIZER", "pickle")
        broker_transport_options = getattr(settings, "BROKER_TRANSPORT_OPTIONS", {"socket_timeout": 10})
        broker_socket_timeout = broker_transport_options["socket_timeout"]
        connection = BrokerConnection(url, connect_timeout=broker_socket_timeout)

        from geonode.messaging.notifications import initialize_notification_signal

        initialize_notification_signal()





[docs]
default_app_config = "geonode.messaging.MessagingAppConfig"