Examples of org.fcrepo.server.messaging.JMSManager

org.fcrepo.server.messaging.JMSManager
The JMSManager class is a facade in that it provides a very simple interface for using JMS. Whether a destination is a topic or queue is hidden as an implementation detail. Adapted from code originally written by Eric J. Bruno. @author Eric J. Bruno @author Edwin Shin @author Bill Branan @since 3.0 @version $Id$

        private void connect() throws MessagingException {
            int retries = 0;


            while(m_jmsManager == null && retries < MAX_RETRIES) {
                try {
                    m_jmsManager = new JMSManager(m_connectionProperties, m_clientId);
                } catch(MessagingException me) {
                    Throwable rootCause = me.getCause();
                    while(rootCause.getCause() != null) {
                        rootCause = rootCause.getCause();
                    }

View Full Code Here

        checkMessage(clientId, TOPIC);
        messagingClient.stop(true);
    }


    private void sendMessage(String jndiName) throws Exception {
        JMSManager jmsManager = new JMSManager(properties);
        TextMessage message = jmsManager.createTextMessage(jndiName, messageText);
        message.setStringProperty(propertyName, propertyValue);
        jmsManager.send(jndiName, message);
        jmsManager.stop(jndiName);
        jmsManager.close();
    }

View Full Code Here

0 1

TOP

Related Classes of org.fcrepo.server.messaging.JMSManager

org.fcrepo.client.messaging.JmsMessagingClient$JMSBrokerConnector

org.fcrepo.client.messaging.TestMessagingClient

org.fcrepo.server.messaging.JMSManagerTest

org.fcrepo.server.messaging.Listener

javax.jms.ConnectionFactory

javax.jms.MessageProducer

javax.naming.Context

javax.jms.Topic

javax.naming.InitialContext

javax.jms.Message

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.