org.finra.herd.service.impl

Class JmsPublishingServiceImpl

java.lang.Object

org.finra.herd.service.impl.JmsPublishingServiceImpl

All Implemented Interfaces:

JmsPublishingService

@Service
 @Transactional(value="herdTransactionManager")
public class JmsPublishingServiceImpl
extends Object
implements JmsPublishingService

The JMS publishing service implementation.

Constructor Summary

Constructors

Constructor and Description
JmsPublishingServiceImpl()

Method Summary

Modifier and Type	Method and Description
JmsMessage	addJmsMessageToDatabaseQueue(String jmsQueueName, String messageText) Adds a JMS message to the database queue.
protected JmsMessage	addJmsMessageToDatabaseQueueImpl(String jmsQueueName, String messageText) Adds a JMS message to the database queue.
boolean	publishOldestJmsMessageFromDatabaseQueue() Publishes and removes from the database queue the oldest JMS message.
protected boolean	publishOldestJmsMessageFromDatabaseQueueImpl() Publishes and removes from the database queue the oldest JMS message.

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsPublishingServiceImpl

public JmsPublishingServiceImpl()

Method Detail

addJmsMessageToDatabaseQueue

@Transactional(propagation=REQUIRES_NEW)
public JmsMessage addJmsMessageToDatabaseQueue(String jmsQueueName,
                                                                                        String messageText)

Adds a JMS message to the database queue.

This implementation starts a new transaction.

Specified by:

addJmsMessageToDatabaseQueue in interface JmsPublishingService

Parameters:

jmsQueueName - the JMS queue name

messageText - the message text

Returns:

the JMS message added to the queue

publishOldestJmsMessageFromDatabaseQueue

@Transactional(propagation=REQUIRES_NEW)
public boolean publishOldestJmsMessageFromDatabaseQueue()

Publishes and removes from the database queue the oldest JMS message.

This implementation starts a new transaction.

Specified by:

publishOldestJmsMessageFromDatabaseQueue in interface JmsPublishingService

Returns:

true if a message was sent or false if no message was sent (i.e. no message needed to be sent).

addJmsMessageToDatabaseQueueImpl

protected JmsMessage addJmsMessageToDatabaseQueueImpl(String jmsQueueName,
                                                      String messageText)

Adds a JMS message to the database queue.

Parameters:

jmsQueueName - the JMS queue name

messageText - the message text

Returns:

the JMS message added to the queue

publishOldestJmsMessageFromDatabaseQueueImpl

protected boolean publishOldestJmsMessageFromDatabaseQueueImpl()

Publishes and removes from the database queue the oldest JMS message.

Returns:

true if a message was sent or false if no message was sent (i.e. no message needed to be sent).