org.ikasan.component.endpoint.jms.producer

Class GenericJmsProducer<T>

java.lang.Object

org.ikasan.component.endpoint.jms.producer.GenericJmsProducer<T>

All Implemented Interfaces:

Producer<T>, Configured<GenericJmsProducerConfiguration>, ConfiguredResource<GenericJmsProducerConfiguration>, ManagedIdentifierService<ManagedEventIdentifierService>, ManagedResource

public class GenericJmsProducer<T>
extends Object
implements Producer<T>, ManagedIdentifierService<ManagedEventIdentifierService>, ManagedResource, ConfiguredResource<GenericJmsProducerConfiguration>

Implementation of a producer based on the JMS specification.

Author:

Ikasan Development Team

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	GenericJmsProducer.ByteArrayToMessage Specific converter implementation for converting byte[] to Message
protected class	GenericJmsProducer.MapToMessage Specific converter implementation for converting any Map to Message
protected class	GenericJmsProducer.SerializableToMessage Specific converter implementation for converting any serializable object to Message
protected class	GenericJmsProducer.StringToMessage Specific converter implementation for converting String to JMS Text Message

Field Summary

Fields

Modifier and Type	Field and Description
protected Converter<byte[],javax.jms.Message>	byteArrayToMessageConverter
protected GenericJmsProducerConfiguration	configuration JMS consumer configuration - default to vanilla instance
protected String	configuredResourceId configured resource id
protected javax.jms.Connection	connection JMS Connection
protected javax.jms.ConnectionFactory	connectionFactory JMS Connection Factory
protected javax.jms.Destination	destination JMS Destination instance
protected DestinationResolver	destinationResolver destination resolver for locating and returning the configured destination instance
protected boolean	isCriticalOnStartup determines whether this managed resource failure will fail the startup of the flow
protected ManagedEventIdentifierService<String,javax.jms.Message>	managedEventIdentifierService default event identifier service - can be overridden via the setter
protected Converter<Map<String,Object>,javax.jms.Message>	mapToMessageConverter
protected PostProcessor	postProcessor post processing operations on the JMS message before being sent over the wire
protected Converter<Serializable,javax.jms.Message>	serializableToMessageConverter
protected javax.jms.Session	session session has to be closed prior to connection being closed
protected Converter<String,javax.jms.TextMessage>	stringToMessageConverter Incoming object to JMS message converters.

Constructor Summary

Constructors

Constructor and Description
GenericJmsProducer() Constructor.
GenericJmsProducer(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination) Constructor.
GenericJmsProducer(javax.jms.ConnectionFactory connectionFactory, DestinationResolver destinationResolver) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
protected javax.jms.Message	convertToMessage(Object object)
GenericJmsProducerConfiguration	getConfiguration()
String	getConfiguredResourceId()
protected Object	getPayload(Object message) Extract the payload based on event coming in.
void	invoke(T message)
boolean	isCriticalOnStartup()
void	setConfiguration(GenericJmsProducerConfiguration configuration)
void	setConfiguredResourceId(String configuredResourceId)
void	setCriticalOnStartup(boolean isCriticalOnStartup)
void	setManagedIdentifierService(ManagedEventIdentifierService managedEventIdentifierService) Override the default producer event life identifier service
void	setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)
void	setPostProcessor(PostProcessor postProcessor) Allow the setting of a custom message property provider.
void	startManagedResource()
void	stopManagedResource()

Methods inherited from class java.lang.Object

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

Field Detail

connectionFactory

protected javax.jms.ConnectionFactory connectionFactory

JMS Connection Factory

destination

protected javax.jms.Destination destination

JMS Destination instance

connection

protected javax.jms.Connection connection

JMS Connection

configuredResourceId

protected String configuredResourceId

configured resource id

configuration

protected GenericJmsProducerConfiguration configuration

JMS consumer configuration - default to vanilla instance

managedEventIdentifierService

protected ManagedEventIdentifierService<String,javax.jms.Message> managedEventIdentifierService

default event identifier service - can be overridden via the setter

session

protected javax.jms.Session session

session has to be closed prior to connection being closed

isCriticalOnStartup

protected boolean isCriticalOnStartup

determines whether this managed resource failure will fail the startup of the flow

destinationResolver

protected DestinationResolver destinationResolver

destination resolver for locating and returning the configured destination instance

postProcessor

protected PostProcessor postProcessor

post processing operations on the JMS message before being sent over the wire

stringToMessageConverter

protected Converter<String,javax.jms.TextMessage> stringToMessageConverter

Incoming object to JMS message converters.

mapToMessageConverter

protected Converter<Map<String,Object>,javax.jms.Message> mapToMessageConverter

byteArrayToMessageConverter

protected Converter<byte[],javax.jms.Message> byteArrayToMessageConverter

serializableToMessageConverter

protected Converter<Serializable,javax.jms.Message> serializableToMessageConverter

Constructor Detail

GenericJmsProducer

public GenericJmsProducer()

Constructor.

GenericJmsProducer

public GenericJmsProducer(javax.jms.ConnectionFactory connectionFactory,
                  javax.jms.Destination destination)

Constructor.

Parameters:

connectionFactory -

destination -

GenericJmsProducer

public GenericJmsProducer(javax.jms.ConnectionFactory connectionFactory,
                  DestinationResolver destinationResolver)

Constructor.

Parameters:

connectionFactory -

destinationResolver -

Method Detail

convertToMessage

protected javax.jms.Message convertToMessage(Object object)

invoke

public void invoke(T message)
            throws EndpointException

Specified by:

invoke in interface Producer<T>

Throws:

EndpointException

setPostProcessor

public void setPostProcessor(PostProcessor postProcessor)

Allow the setting of a custom message property provider.

Parameters:

postProcessor -

setManagedIdentifierService

public void setManagedIdentifierService(ManagedEventIdentifierService managedEventIdentifierService)

Override the default producer event life identifier service

Specified by:

setManagedIdentifierService in interface ManagedIdentifierService<ManagedEventIdentifierService>

Parameters:

managedEventIdentifierService -

getConfiguration

public GenericJmsProducerConfiguration getConfiguration()

Specified by:

getConfiguration in interface Configured<GenericJmsProducerConfiguration>

getConfiguredResourceId

public String getConfiguredResourceId()

Specified by:

getConfiguredResourceId in interface ConfiguredResource<GenericJmsProducerConfiguration>

setConfiguration

public void setConfiguration(GenericJmsProducerConfiguration configuration)

Specified by:

setConfiguration in interface Configured<GenericJmsProducerConfiguration>

setConfiguredResourceId

public void setConfiguredResourceId(String configuredResourceId)

Specified by:

setConfiguredResourceId in interface ConfiguredResource<GenericJmsProducerConfiguration>

startManagedResource

public void startManagedResource()

Specified by:

startManagedResource in interface ManagedResource

stopManagedResource

public void stopManagedResource()

Specified by:

stopManagedResource in interface ManagedResource

isCriticalOnStartup

public boolean isCriticalOnStartup()

Specified by:

isCriticalOnStartup in interface ManagedResource

setCriticalOnStartup

public void setCriticalOnStartup(boolean isCriticalOnStartup)

Specified by:

setCriticalOnStartup in interface ManagedResource

setManagedResourceRecoveryManager

public void setManagedResourceRecoveryManager(ManagedResourceRecoveryManager managedResourceRecoveryManager)

Specified by:

setManagedResourceRecoveryManager in interface ManagedResource

getPayload

protected Object getPayload(Object message)

Extract the payload based on event coming in.

Parameters:

message -

Returns: