org.apache.qpid.test.framework.localcircuit
Class LocalAMQPPublisherImpl
java.lang.Object
org.apache.qpid.test.framework.CircuitEndBase
org.apache.qpid.test.framework.localcircuit.LocalPublisherImpl
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
|
---|
|
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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.
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