org.apache.qpid.test.framework.localcircuit
Class LocalAMQPPublisherImpl

java.lang.Object
  extended by org.apache.qpid.test.framework.CircuitEndBase
      extended by org.apache.qpid.test.framework.localcircuit.LocalPublisherImpl
          extended by org.apache.qpid.test.framework.localcircuit.LocalAMQPPublisherImpl
All Implemented Interfaces:
AMQPPublisher, CircuitEnd, Publisher

public class LocalAMQPPublisherImpl
extends LocalPublisherImpl
implements AMQPPublisher

LocalAMQPPublisherImpl is an extension of LocalPublisherImpl that adds AMQP specific features. Specifically extra assertions for AMQP features not available through generic JMS.

CRC Card
Responsibilities Collaborations


Field Summary
 
Fields inherited from class org.apache.qpid.test.framework.localcircuit.LocalPublisherImpl
circuit
 
Constructor Summary
LocalAMQPPublisherImpl(CircuitEndBase end)
          Creates a circuit end point from the producer, consumer and controlSession in a circuit end base implementation.
LocalAMQPPublisherImpl(MessageProducer producer, MessageConsumer consumer, Session session, MessageMonitor messageMonitor, ExceptionMonitor exceptionMonitor)
          Creates a circuit end point on the specified producer, consumer and controlSession.
 
Method Summary
 Assertion noConsumersAssertion(org.apache.qpid.junit.extensions.util.ParsedProperties testProps)
          Provides an assertion that the publisher got a no consumers exception on every message.
 Assertion noRouteAssertion(org.apache.qpid.junit.extensions.util.ParsedProperties testProps)
          Provides an assertion that the publisher got a no rout exception on every message.
 
Methods inherited from class org.apache.qpid.test.framework.localcircuit.LocalPublisherImpl
channelClosedAssertion, exceptionAssertion, noExceptionsAssertion, setCircuit
 
Methods inherited from class org.apache.qpid.test.framework.CircuitEndBase
close, getConsumer, getExceptionMonitor, getMessageMonitor, getProducer, getSession, send
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.qpid.test.framework.Publisher
channelClosedAssertion, exceptionAssertion, noExceptionsAssertion
 

Constructor Detail

LocalAMQPPublisherImpl

public LocalAMQPPublisherImpl(MessageProducer producer,
                              MessageConsumer consumer,
                              Session session,
                              MessageMonitor messageMonitor,
                              ExceptionMonitor exceptionMonitor)
Creates a circuit end point on the specified producer, consumer and controlSession. Monitors are also configured for messages and exceptions received by the circuit end.

Parameters:
producer - The message producer for the circuit end point.
consumer - The message consumer for the circuit end point.
session - The controlSession for the circuit end point.
messageMonitor - The monitor to notify of all messages received by the circuit end.
exceptionMonitor - The monitor to notify of all exceptions received by the circuit end.

LocalAMQPPublisherImpl

public LocalAMQPPublisherImpl(CircuitEndBase end)
Creates a circuit end point from the producer, consumer and controlSession in a circuit end base implementation.

Parameters:
end - The circuit end base implementation to take producers and consumers from.
Method Detail

noConsumersAssertion

public Assertion noConsumersAssertion(org.apache.qpid.junit.extensions.util.ParsedProperties testProps)
Provides an assertion that the publisher got a no consumers exception on every message.

Specified by:
noConsumersAssertion in interface AMQPPublisher
Parameters:
testProps - The test configuration properties.
Returns:
An assertion that the publisher got a no consumers exception on every message.

noRouteAssertion

public Assertion noRouteAssertion(org.apache.qpid.junit.extensions.util.ParsedProperties testProps)
Provides an assertion that the publisher got a no rout exception on every message.

Specified by:
noRouteAssertion in interface AMQPPublisher
Parameters:
testProps - The test configuration properties.
Returns:
An assertion that the publisher got a no rout exception on every message.


Licensed to the Apache Software Foundation