org.fcrepo.jms

Class JMSTopicPublisher

java.lang.Object

org.fcrepo.jms.JMSTopicPublisher

public class JMSTopicPublisher
extends Object

Machinery to publish JMS messages when an EventBus message is received.

Author:

barmintor, awoods

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.jms.Session	jmsSession

Constructor Summary

Constructors

Constructor and Description
JMSTopicPublisher() Create a JMS Topic with the default name of "fedora"

Method Summary

Modifier and Type	Method and Description
void	acquireConnections() Connect to JCR Repostory and JMS queue
protected javax.jms.Destination	createDestination()
void	publishJCREvent(FedoraEvent fedoraEvent) When an EventBus mesage is received, map it to our JMS message payload and push it onto the queue.
void	releaseConnections() Close external connections

Methods inherited from class java.lang.Object

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

Field Detail

jmsSession

protected javax.jms.Session jmsSession

Constructor Detail

JMSTopicPublisher

public JMSTopicPublisher()

Create a JMS Topic with the default name of "fedora"

Method Detail

createDestination

protected javax.jms.Destination createDestination()
                                           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

publishJCREvent

public void publishJCREvent(FedoraEvent fedoraEvent)
                     throws javax.jms.JMSException

When an EventBus mesage is received, map it to our JMS message payload and push it onto the queue.

Parameters:

fedoraEvent - the fedora event

Throws:

javax.jms.JMSException - if JMS exception occurred

acquireConnections

@PostConstruct
public void acquireConnections()
                                       throws javax.jms.JMSException

Connect to JCR Repostory and JMS queue

Throws:

javax.jms.JMSException - if JMS Exception occurred

releaseConnections

@PreDestroy
public void releaseConnections()
                                    throws javax.jms.JMSException

Close external connections

Throws:

javax.jms.JMSException - if JMS exception occurred