Examples of ConversationFactory

org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory
@author Gerhard Petracek

org.apache.qpid.test.utils.ConversationFactory

ange greetings. conversation.send(sendDestination, conversation.getSession().createTextMessage("Hello.")); Message greeting = conversation.receive(); // Exchange goodbyes. conversation.send(conversation.getSession().createTextMessage("Goodbye.")); Message goodbye = conversation.receive(); } finally { conversation.end(); } } } class Responder { ConversationHelper conversation = new ConversationHelper(connection, receiveDestination, java.util.concurrent.LinkedBlockingQueue.class); respondToConversation() { try { // Exchange greetings. Message greeting = conversation.receive(); conversation.send(conversation.getSession().createTextMessage("Hello.")); // Exchange goodbyes. Message goodbye = conversation.receive(); conversation.send(conversation.getSession().createTextMessage("Goodbye.")); } finally { conversation.end(); } } }

Conversation correlation id's are generated on a per thread basis.

The same controlSession is shared amongst all conversations. Calls to send are therefore synchronized because JMS sessions are not multi-threaded.

CRC Card
Responsibilities	Collaborations
Associate messages to an ongoing conversation using correlation ids.
Auto manage sessions for conversations.
Store messages not in a conversation in dead letter box.

org.apache.qpid.util.ConversationFactory

Conversation correlation id's are generated on a per thread basis.

The same controlSession is shared amongst all conversations. Calls to send are therefore synchronized because JMS sessions are not multi-threaded.

CRC Card
Responsibilities	Collaborations
Associate messages to an ongoing conversation using correlation ids.
Auto manage sessions for conversations.
Store messages not in a conversation in dead letter box.

org.bukkit.conversations.ConversationFactory
A ConversationFactory is responsible for creating a {@link Conversation}from a predefined template. A ConversationFactory is typically created when a plugin is instantiated and builds a Conversation each time a user initiates a conversation with the plugin. Each Conversation maintains its own state and calls back as needed into the plugin.
The ConversationFactory implements a fluid API, allowing parameters to be set as an extension to the constructor.

Examples of org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory

        Class<? extends Annotation> scopeType = convertToScope(this.beanManager, conversationGroupKey, qualifiers);


        ConversationKey conversationKey =
                new DefaultConversationKey(scopeType, conversationGroupKey, qualifiers);


        ConversationFactory conversationFactory = CodiUtils.getContextualReferenceByClass(ConversationFactory.class);
        return conversationFactory.createConversation(conversationKey, this.conversationConfig);
    }

View Full Code Here

Examples of org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory

        Class<? extends Annotation> scopeType = convertToScope(this.beanManager, conversationGroupKey, qualifiers);


        ConversationKey conversationKey =
                new DefaultConversationKey(scopeType, conversationGroupKey, qualifiers);


        ConversationFactory conversationFactory = CodiUtils.getContextualReferenceByClass(ConversationFactory.class);


        if(conversationFactory instanceof BeanManagerAware)
        {
            ((BeanManagerAware)conversationFactory).setBeanManager(this.beanManager);
        }
        return conversationFactory.createConversation(conversationKey, this.conversationConfig);
    }

View Full Code Here

Examples of org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory

        Class<? extends Annotation> scopeType = convertToScope(this.beanManager, conversationGroupKey, qualifiers);


        ConversationKey conversationKey =
                new DefaultConversationKey(scopeType, conversationGroupKey, qualifiers);


        ConversationFactory conversationFactory = CodiUtils.getContextualReferenceByClass(ConversationFactory.class);


        if(conversationFactory instanceof BeanManagerAware)
        {
            ((BeanManagerAware)conversationFactory).setBeanManager(this.beanManager);
        }
        return conversationFactory.createConversation(conversationKey, this.conversationConfig);
    }

View Full Code Here

Examples of org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory

        Class<? extends Annotation> scopeType = convertToScope(this.beanManager, conversationGroupKey, qualifiers);


        ConversationKey conversationKey =
                new DefaultConversationKey(scopeType, conversationGroupKey, qualifiers);


        ConversationFactory conversationFactory = CodiUtils.getContextualReferenceByClass(ConversationFactory.class);
        return conversationFactory.createConversation(conversationKey, this.conversationConfig);
    }

View Full Code Here

Examples of org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory

        Class<? extends Annotation> scopeType = convertToScope(this.beanManager, conversationGroupKey, qualifiers);


        ConversationKey conversationKey =
                new DefaultConversationKey(scopeType, conversationGroupKey, qualifiers);


        ConversationFactory conversationFactory = CodiUtils.getContextualReferenceByClass(ConversationFactory.class);
        return conversationFactory.createConversation(conversationKey, this.conversationConfig);
    }

View Full Code Here

Examples of org.apache.myfaces.extensions.cdi.jsf.impl.scope.conversation.spi.ConversationFactory

        Class<? extends Annotation> scopeType = convertToScope(this.beanManager, conversationGroupKey, qualifiers);


        ConversationKey conversationKey =
                new DefaultConversationKey(scopeType, conversationGroupKey, qualifiers);


        ConversationFactory conversationFactory = CodiUtils.getContextualReferenceByClass(ConversationFactory.class);
        return conversationFactory.createConversation(conversationKey, this.conversationConfig);
    }

View Full Code Here

Examples of org.apache.qpid.test.utils.ConversationFactory

        log.debug("public Circuit createCircuit(ParsedProperties testProperties): called");


        List<TestClientDetails> senders = new LinkedList<TestClientDetails>();
        senders.add(getSender());
        List<TestClientDetails> receivers = getReceivers();
        ConversationFactory conversationFactory = getConversationFactory();


        return DistributedCircuitImpl.createCircuit(testProperties, senders, receivers, conversationFactory);
    }

View Full Code Here

Examples of org.apache.qpid.test.utils.ConversationFactory

    {
        log.debug("protected Message[] sequenceTest(Object... testProperties = " + testProperties + "): called");


        TestClientDetails sender = getSender();
        List<TestClientDetails> receivers = getReceivers();
        ConversationFactory conversationFactory = getConversationFactory();


        try
        {
            Session session = conversationFactory.getSession();
            Destination senderControlTopic = session.createTopic(sender.privateControlKey);
            Destination receiverControlTopic = session.createTopic(receivers.get(0).privateControlKey);


            ConversationFactory.Conversation senderConversation = conversationFactory.startConversation();
            ConversationFactory.Conversation receiverConversation = conversationFactory.startConversation();


            Message assignSender = conversationFactory.getSession().createMessage();
            TestUtils.setPropertiesOnMessage(assignSender, testProperties);
            assignSender.setStringProperty("CONTROL_TYPE", "ASSIGN_ROLE");
            assignSender.setStringProperty("ROLE", "SENDER");


            senderConversation.send(senderControlTopic, assignSender);

View Full Code Here

Examples of org.apache.qpid.test.utils.ConversationFactory

        log.debug("public Circuit createCircuit(ParsedProperties testProperties): called");


        List<TestClientDetails> senders = new LinkedList<TestClientDetails>();
        senders.add(getSender());
        List<TestClientDetails> receivers = getReceivers();
        ConversationFactory conversationFactory = getConversationFactory();


        return DistributedCircuitImpl.createCircuit(testProperties, senders, receivers, conversationFactory);
    }

View Full Code Here

Examples of org.apache.qpid.test.utils.ConversationFactory

    {
        log.debug("protected Message[] sequenceTest(Object... testProperties = " + testProperties + "): called");


        TestClientDetails sender = getSender();
        List<TestClientDetails> receivers = getReceivers();
        ConversationFactory conversationFactory = getConversationFactory();


        try
        {
            // Create a conversation on the sender clients private control route.
            Session session = conversationFactory.getSession();
            Destination senderControlTopic = session.createTopic(sender.privateControlKey);
            ConversationFactory.Conversation senderConversation = conversationFactory.startConversation();


            // Assign the sender role to the sending test client.
            Message assignSender = conversationFactory.getSession().createMessage();
            TestUtils.setPropertiesOnMessage(assignSender, testProperties);
            assignSender.setStringProperty("CONTROL_TYPE", "ASSIGN_ROLE");
            assignSender.setStringProperty("ROLE", "SENDER");
            assignSender.setStringProperty("CLIENT_NAME", "Sustained_SENDER");

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.