fix(repos) all elastic mq repos should be based on libtrustbirdge (#48)

intergov/repos/api_inbox/elasticmq/elasticmqrepo.py

@@ -1,6 +1,6 @@
-from intergov.repos.base.elasticmq import elasticmqrepo
+from libtrustbridge.repos.elasticmqrepo import ElasticMQRepo
 
 
-class APIInboxElasticRepo(elasticmqrepo.ElasticMQRepo):
+class APIInboxElasticRepo(ElasticMQRepo):
     def _get_queue_name(self):
         return 'api-inbox'

intergov/repos/channel_pending_message/elasticmq/elasticmqrepo.py

@@ -1,12 +1,12 @@
-from intergov.repos.base.elasticmq import elasticmqrepo
+from libtrustbridge.repos.elasticmqrepo import ElasticMQRepo
 
-"""
-This repo receives pending messages to provide
-them to worker which will poll their status from the
-coresponding channels.
-"""
 
+class ChannelPendingMessageElasticMQRepo(ElasticMQRepo):
+    """
+    This repo receives pending messages to provide
+    them to worker which will poll their status from the
+    coresponding channels.
+    """
 
-class ChannelPendingMessageElasticMQRepo(elasticmqrepo.ElasticMQRepo):
     def _get_queue_name(self):
         return 'channel-pending-messages'

intergov/repos/delivery_outbox/elasticmq/elasticmq_repo.py

@@ -1,6 +1,6 @@
-from intergov.repos.base.elasticmq import elasticmqrepo
+from libtrustbridge.repos.elasticmqrepo import ElasticMQRepo
 
 
-class DeliveryOutboxRepo(elasticmqrepo.ElasticMQRepo):
+class DeliveryOutboxRepo(ElasticMQRepo):
     def _get_queue_name(self):
         return 'delivery-outbox'

intergov/repos/message_updates/elasticmq/elasticmqrepo.py

@@ -1,10 +1,10 @@
-from intergov.repos.base.elasticmq import elasticmqrepo
+from libtrustbridge.repos.elasticmqrepo import ElasticMQRepo
 
-"""
-This repo is used to delay message updates
-"""
 
+class MessageUpdatesElasticMQRepo(ElasticMQRepo):
+    """
+    This repo is used to delay message updates
+    """
 
-class MessageUpdatesElasticMQRepo(elasticmqrepo.ElasticMQRepo):
     def _get_queue_name(self):
         return 'message-updates'