ftw.publisher.sender.interfaces.IQueue

All Samples(21) | Call(15) | Derive(0) | Import(6)

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/browser/views.py ftw.publisher.sender(Download)

from ftw.publisher.sender.events import AfterPushEvent, QueueExecutedEvent
from ftw.publisher.sender.events import BeforeQueueExecutionEvent
from ftw.publisher.sender.interfaces import IPathBlacklist, IConfig, IQueue
from ftw.publisher.sender.utils import add_transaction_aware_status_message
from ftw.publisher.sender.utils import sendJsonToRealm

        # create Job
        portal = self.context.portal_url.getPortalObject()
        queue = IQueue(portal)
        queue.createJob('push', self.context, username)
        self.logger.info('Created "%s" Job for "%s" at %s' % (

        # create Job
        portal = self.context.portal_url.getPortalObject()
        queue = IQueue(portal)
        queue.createJob('move', self.context, username, )
        self.logger.info('Created "%s" Job for "%s" at %s' % (

        # create Job
        portal = self.context.portal_url.getPortalObject()
        queue = IQueue(portal)
        queue.createJob('delete', self.context, username)
        self.logger.info('Created "%s" Job for "%s" at %s' % (

        portal = self.context.portal_url.getPortalObject()
        self.config = IConfig(portal)
        self.queue = IQueue(portal)
        # remove job from queue
        if job in self.queue.getJobs():

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/browser/configlet.py ftw.publisher.sender(Download)

from ftw.publisher.sender.browser.interfaces import IRealmSchema
from ftw.publisher.sender.interfaces import IConfig
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.persistence import Realm
from ftw.publisher.sender.utils import sendRequestToRealm

    def __init__(self, *args, **kwargs):
        super(PublisherConfigletView, self).__init__(*args, **kwargs)
        self.config = IConfig(self.context)
        self.queue = IQueue(self.context)

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/upgrades/__init__.py ftw.publisher.sender(Download)

from ftw.publisher.sender.interfaces import IQueue
from transaction import savepoint
from zope.annotation.interfaces import IAnnotations

    """
    portal = portal_setup.portal_url.getPortalObject()
    queue = IQueue(portal)
    annotations = IAnnotations(portal)

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/persistence.py ftw.publisher.sender(Download)

from ftw.publisher.sender.interfaces import IConfig
from ftw.publisher.sender.interfaces import IOverriddenRealmRegistry
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.interfaces import IRealm
from persistent import Persistent

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/tests/test_publisher_subscribers.py ftw.publisher.sender(Download)

from Products.CMFCore.utils import getToolByName
from ftw.builder import Builder
from ftw.builder import create
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.testing import PUBLISHER_SENDER_FUNCTIONAL_TESTING

        Workflow().do_transition('publish')
 
        queue = IQueue(self.portal)
        self.assertEquals(1, queue.countJobs())

        Workflow().do_transition('submit')
 
        queue = IQueue(self.portal)
        self.assertEquals(0, queue.countJobs())

        Workflow().do_transition('revise')
 
        queue = IQueue(self.portal)
        self.assertEquals(0, queue.countJobs())

    def test_no_job_when_object_has_no_publisher_workflow(self):
        queue = IQueue(self.portal)
        page = create(Builder('page'))
        Plone().login().visit(page, 'delete_confirmation')
        self.assertEquals(0, queue.countJobs())

src/f/t/ftw.publisher.sender-2.2.0/ftw/publisher/sender/tests/test_simplelayout.py ftw.publisher.sender(Download)

from Products.CMFCore.utils import getToolByName
from ftw.builder import Builder
from ftw.builder import create
from ftw.publisher.sender.interfaces import IQueue
from ftw.publisher.sender.testing import PUBLISHER_SENDER_FUNCTIONAL_TESTING

        Workflow().do_transition('publish')
 
        queue = IQueue(self.portal)
        self.assertEquals(
            2, queue.countJobs(),

        Workflow().do_transition('publish')
 
        queue = IQueue(self.portal)
        self.assertEquals(
            3, queue.countJobs(),