org.ikasan.testharness.flow.producer

Class InspectableProducer<T>

java.lang.Object

org.ikasan.component.endpoint.jms.spring.producer.JmsTemplateProducer<T>

org.ikasan.testharness.flow.producer.InspectableProducer<T>

All Implemented Interfaces:

Producer<T>, org.ikasan.spec.configuration.Configured<SpringMessageProducerConfiguration>, org.ikasan.spec.configuration.ConfiguredResource<SpringMessageProducerConfiguration>, org.ikasan.spec.management.ManagedResource

public class InspectableProducer<T>
extends JmsTemplateProducer<T>

Dummy producer to test last messages/events in unit tests. It can be used with or without an actual IkasanJmsTemplate setup. If you want to use it with a IkasanJmsTemplate simple provide the instance of the template in constructor (directly or in Spring config) and provide "configuration" and "configuredResourceId" parameters. Useful for Unittest by providing a Spring config that will override the original producer with this implementation, so that you can check the persisted messages by calling the getEvents() and getEventCount() methods.

Author:

Ikasan Development Team

Constructor Summary

Constructors

Constructor and Description
InspectableProducer() Constructs a InspectableProducer.
InspectableProducer(IkasanJmsTemplate jmsTemplate) Constructs a InspectableProducer with an IkasanJmsTemplate.

Method Summary

Methods

Modifier and Type	Method and Description
int	getEventCount()
List<T>	getEvents()
void	invoke(T message)
boolean	isUseJms()
void	setUseJms(boolean useJms)

Methods inherited from class org.ikasan.component.endpoint.jms.spring.producer.JmsTemplateProducer

getConfiguration, getConfiguredResourceId, isCriticalOnStartup, setConfiguration, setConfiguredResourceId, setCriticalOnStartup, setManagedResourceRecoveryManager, startManagedResource, stopManagedResource

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InspectableProducer

public InspectableProducer()

Constructs a InspectableProducer. All messages that the producer processes will be collected and not further processed.

InspectableProducer

public InspectableProducer(IkasanJmsTemplate jmsTemplate)

Constructs a InspectableProducer with an IkasanJmsTemplate. All messages that the producer processes will be collected and also send via the jms template.

Parameters:

jmsTemplate -

Method Detail

isUseJms

public boolean isUseJms()

Returns:

the value of the useJms property

setUseJms

public void setUseJms(boolean useJms)

Parameters:

useJms - configuration if the messages are processed via Jms after collection

getEventCount

public int getEventCount()

Returns:

the count of the currently collected events.

getEvents

public List<T> getEvents()

Returns:

the events that the producer processed

invoke

public void invoke(T message)
            throws EndpointException

Specified by:

invoke in interface Producer<T>

Overrides:

invoke in class JmsTemplateProducer<T>

Throws:

EndpointException