Examples of org.apache.qpid.test.framework.localcircuit.LocalReceiverImpl

Package org.apache.qpid.test.framework.localcircuit

Examples of org.apache.qpid.test.framework.localcircuit.LocalReceiverImpl

org.apache.qpid.test.framework.localcircuit.LocalReceiverImpl

Provides an implementation of the {@link Receiver} interface that wraps a single message producer and consumer ona single controlSession, as a {@link CircuitEnd}. A local receiver also acts as a circuit end, because for a locally located circuit the assertions may be applied directly, there does not need to be any inter process messaging between the publisher and its single circuit end, in order to ascertain its status.

CRC Card
Responsibilities	Collaborations
Provide a message producer for sending messages.
Provide a message consumer for receiving messages.
Provide assertion that the receivers received no exceptions.
Provide assertion that the receivers received all test messages sent to it.

            // Start listening for incoming messages.
            connection.start();


            // Package everything up.
            LocalPublisherImpl publisher = createPublisherFromCircuitEnd(publisherEnd);
            LocalReceiverImpl receiver = createReceiverFromCircuitEnd(receiverEnd);


            result = new LocalCircuitImpl(testProperties, publisher, receiver, connection, publisher.getExceptionMonitor());
        }
        catch (JMSException e)
        {

View Full Code Here

     *
     * @return A {@link Receiver}.
     */
    protected LocalReceiverImpl createReceiverFromCircuitEnd(CircuitEndBase receiverEnd)
    {
        return new LocalReceiverImpl(receiverEnd);
    }

View Full Code Here

            // Start listening for incoming messages.
            connection.start();


            // Package everything up.
            LocalPublisherImpl publisher = createPublisherFromCircuitEnd(publisherEnd);
            LocalReceiverImpl receiver = createReceiverFromCircuitEnd(receiverEnd);


            result = new LocalCircuitImpl(testProperties, publisher, receiver, connection, publisher.getExceptionMonitor());
        }
        catch (JMSException e)
        {

View Full Code Here

     *
     * @return A {@link Receiver}.
     */
    protected LocalReceiverImpl createReceiverFromCircuitEnd(CircuitEndBase receiverEnd)
    {
        return new LocalReceiverImpl(receiverEnd);
    }

View Full Code Here

            // Start listening for incoming messages.
            connection.start();


            // Package everything up.
            LocalPublisherImpl publisher = createPublisherFromCircuitEnd(publisherEnd);
            LocalReceiverImpl receiver = createReceiverFromCircuitEnd(receiverEnd);


            result = new LocalCircuitImpl(testProperties, publisher, receiver, connection, publisher.getExceptionMonitor());
        }
        catch (JMSException e)
        {

View Full Code Here

     *
     * @return A {@link Receiver}.
     */
    protected LocalReceiverImpl createReceiverFromCircuitEnd(CircuitEndBase receiverEnd)
    {
        return new LocalReceiverImpl(receiverEnd);
    }

View Full Code Here

TOP

Related Classes of org.apache.qpid.test.framework.localcircuit.LocalReceiverImpl

org.apache.qpid.test.framework.LocalCircuitFactory

org.apache.qpid.test.framework.NotApplicableAssertion

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.